下载
官网下载,地址如下:
https://maven.apache.org/download.cgi
解压
在自己的环境安装目录下解压:
1 | tar -zxvf apache-maven-3.6.2-bin.tar.gz |
A thousand miles begins with a single step .
官网下载,地址如下:
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
即可。
定时任务的是很常见的开发工作,在springboot中我们可以用注解很easy的实现。首先,需要加入@EnableScheduling
注解开启定时任务功能,如下所示:
1 | @SpringBootApplication |