RocketMQ是一款分布式消息中间件,最初是由阿里巴巴消息中间件团队研发并大规模应用于生产系统,满足线上海量消息堆积的需求, 在2016年底捐赠给Apache开源基金会成为孵化项目,经过不到一年时间正式成为了Apache顶级项目;早期阿里曾经基于ActiveMQ研发消息系统, 随着业务消息的规模增大,瓶颈逐渐显现,后来也考虑过Kafka,但因为在低延迟和高可靠性方面没有选择,最后才自主研发了RocketMQ, 各方面的性能都比目前已有的消息队列要好,RocketMQ和Kafka在概念和原理上都非常相似,所以也经常被拿来对比;RocketMQ默认采用长轮询的拉模式, 单机支持千万级别的消息堆积,可以非常好的应用在海量消息系统中。
参考:https://blog.csdn.net/syq8023/article/details/102795056https://www.cnblogs.com/coder-lzh/p/9006048.html
http://rocketmq.apache.org/release_notes/release-notes-4.3.0/
在这里插入图片描述
配置环境变量:ROCKETMQ_HOME
变量值:MQ解压路径\MQ文件夹名
(这个路径不能有空格,否则会报错)
在path
下面配置
进入到安装目录的bin
目录下,执行start mqnamesrv.cmd
这个窗口不要关闭
在同样bin目录下的cmd窗口中输入start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true
出现这两个说明启动成功
git clone git://github.com/apache/rocketmq-externals.git
下载完成之后,进入rocketmq-externals\rocketmq-console\src\main\resources
文件夹,打开application.properties
进行配置。
进入\rocketmq-externals\rocketmq-console
文件夹,执行mvn clean package -Dmaven.test.skip=true
,编译生成。
编译成功之后,Cmd进入‘target’文件夹,执行java -jar rocketmq-console-ng-1.0.0.jar
,启动‘rocketmq-console-ng-1.0.0.jar’。
访问:http://localhost:6666/#/