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