RocketMQ使用笔记

 

apache rocketmq document : http://rocketmq.apache.org/community/

rocketmq 工具下载地址：https://github.com/apache/rocketmq-externals

下载rocketmq-4.2版本源码导入eclipse报错的解决方法：https://blog.csdn.net/gwd1154978352/article/details/80649801

---

 

Linux 部署 rocketmq
下载地址：http://rocketmq.apache.org/dowloading/releases/ 我使用的版本是：rocketmq-all-4.2.0-bin-release.zip  （binary）

上传到服务器以后，解压，进入到解压的目录下面，再进入bin，这里就是全部的操做入口了。

启动rocketmq

　　首先启动mqnamesrv，执行./mqnamesrv   ，而后启动一个broker，启动broker有两种方式，

       一种简单的:  ./mqbroker -n 127.0.0.1:9876 autoCreateTopicEnable=true,这里-n表示的是mqnamesrv的服务地址和端口autoCreateTopicEnable=true表示在发送消息时，若是topic不存在，就自动建立。

　　一种是根据配置文件启动：./mqbroker -c ../conf/broker.conf，也能够指定到别的位置。

须要注意的是，通常来讲生产环境会autoCreateTopicEnable=false，关闭自动建立。无论理怎么样，咱们服务器在启动的时候，通常就会向某个topic启动监听或发送消息，可是，若是这个时候，topic不存在的话，就会报异常：

CODE: 17  DESC: No topic route info in name server for the topic: GateMessageProducerTopic4

这时候，就须要手动去建立一个topic。

手动建立topic

建立topic就须要用到rocketmq的CLI命令了。它是mqadmin操做。好比建立topic：./mqadmin updateTopic -n 127.0.0.1:9876 -c DefaultCluster -t TestTopic

命令参数列表：http://rocketmq.apache.org/docs/cli-admin-tool/

 

Window上运行RocketMQ

参考如下链接

https://blog.csdn.net/u014134180/article/details/51790988#22-%E8%A7%A3%E5%8E%8B%E7%BC%A9%E5%B9%B6%E8%BF%9B%E5%85%A5bin%E7%9B%AE%E5%BD%95

 

修改rocketmq mqnamesrv 的启动jvm参数

直接修改runserver.sh里面的jvm参数便可。

默认启动

先启动NameServer    ./mqnamesrv

再启动brokerServer  ./mqbroker