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

原文地址:https://www.cnblogs.com/wgslucky/p/9199333.html