RocketMQ 是一款分布式、队列模型的消息中间件,在淘宝和支付宝有着广泛的应用,其前身是Metaq,当 Metaq 3.0发布时,产品名称改为 ,现已捐赠给 Apache,成为 Apache 孵化项目。
它具有以下特点:
1.能够保证严格的消息顺序
2.支持分布式事务消息
3.消费失败支持定时重试
4.支持定时消息、延时消息
5.支持Broker端的消息过滤
搭建MQ服务器
1.RocketMQ是用JAVA编写的,首先要确保已安装JDK
2.从GitHub下载https://github.com/alibaba/RocketMQ最新的源码
3.编译打包,执行 RocketMQ-master/install.bat,或者手动执行 mvn -Dmaven.test.skip=true clean package install assembly:assembly -U
4.将生成的文件从RocketMQ-master\target\alibaba-rocketmq-broker.tar.gz 拷贝出来解压。
5.部署NameServer,alibaba-rocketmq-broker\alibaba-rocketmq\bin\mqnamesrv.exe,
6.部署Broker(消息中转角色,负责存储消息,转发消息),指定broker的NameServer启动:mqbroker.exe -n "127.0.0.1:9876"
其商业版的 Aliware 消息队列 MQ已在阿里云使用,文档地址:
https://help.aliyun.com/document_detail/29532.html?spm=5176.doc44711.6.539.1sDtAw