这里以在ubuntu18.04上安装为例,来说明安装单个实例rocketmq的过程和验证情况。
安装
下载
下载地址如下,选择想要下载的版本即可:
http://rocketmq.apache.org/release_notes/
解压
在自己的环境安装目录下解压
1 | $ unzip rocketmq-all-4.5.2-bin-release.zip |
A thousand miles begins with a single step .
这里以在ubuntu18.04上安装为例,来说明安装单个实例rocketmq的过程和验证情况。
下载地址如下,选择想要下载的版本即可:
http://rocketmq.apache.org/release_notes/
在自己的环境安装目录下解压
1 | $ unzip rocketmq-all-4.5.2-bin-release.zip |
官网下载,地址如下:
https://maven.apache.org/download.cgi
在自己的环境安装目录下解压:
1 | tar -zxvf apache-maven-3.6.2-bin.tar.gz |
在rocketmq中,MQProducer
是承载消息发送的,消息的发送又可以分为常规消息的发送和事务消息的发送,其中常规消息发送用的是DefaultMQProducer
,事务消息的发送用的是TransactionMQProducer
。他们集成关系图如:
从功能上来说,rocketmq支持三种发送消息的方式,分别是同步发送(sync),异步发送(async)和直接发送(oneway)。下面来简单说明一下这三种发送消息的方式,以便了解它们之间的差异。
以下的案例代码将会使用spring-message风格进行展示,即使用
rocketMQTemplate
方式,详见rocketmq-spring
业务需求中,在计算人均通话数时,使用聚合的时候使用到了内联以及反内联聚合,当bucket_script
聚合作为反内联reverse_nested
的子聚和的时候,会报如下错误:
1 | org.elasticsearch.ElasticsearchException: Elasticsearch exception [type=class_cast_exception, reason=org.elasticsearch.search.aggregations.bucket.nested.InternalReverseNested cannot be cast to org.elasticsearch.search.aggregations.InternalMultiBucketAggregation] |
消息队列rocketmq是Apache旗下的开源项目(原是Alibaba开源的项目),当springboot盛行后,Apache团队开源了rocketmq-spring来帮助我们在springboot中快速集成rocketmq,只需引入rocketmq-spring-boot-starter
即可。