rocketmq 使用中碰到的一些問題

1.rocket 入門使用

http://rocketmq.apache.org/docs/quick-start/

2.內存不夠

默認配置內存配置比較高，在測試環境啓動會有問題所以須要調整默認的內存配置。

編輯runbroker.sh

JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx1g -Xmn512m"

編輯runserver.sh

JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx1g -Xmn512m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

3. No route info of this topic

這個錯誤比較離譜，在同步發送隊列沒有問題，在異步的狀況下出現這個錯誤。

最後發現問題是jar的版本的問題。

須要使用 fastjson  版本兼容，系統中使用的版本是1.2.32 ，修改爲版本 1.2.51 才能夠。

4.org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to <172.17.0.1:10911> failed

編輯 broker.conf

增長內容：

namesrvAddr=192.168.31.100:9876
brokerIP1=192.168.31.100

在使用如下命令啓動broker。

nohup sh bin/mqbroker -n 192.168.31.100:9876 autoCreateTopicEnable=true -c conf/broker.conf &

5.rocketmq 生產者的消息發送方式

https://blog.csdn.net/l18848956739/article/details/83111269

6.使用rocketmq 控制檯

https://github.com/apache/rocketmq-externals

下載包

去到 console 目錄中

D:\software\java\rocketmq-externals-master\rocketmq-console

執行如下命令進行編譯

mvn clean package -Dmaven.test.skip=true

生成jar包

rocketmq-console-ng-1.0.1.jar

java -jar rocketmq-console-ng-1.0.1.jar --rocketmq.config.namesrvAddr='192.168.31.100:9876'

使用上面的命令啓動 控制檯。