Apache RocketMQ 安装、测试、报错解决
1. 準備
前些天發現了一個巨牛的人工智能學習網站,通俗易懂,風趣幽默,忍不住分享一下給大家。點擊跳轉到教程。
64bit OS, Linux/Unix/Mac? 64bit JDK 1.8+; Maven 3.2.x2.下載和構建
下載 4.2.0 源代碼版本地址:http://mirrors.hust.edu.cn/apache/rocketmq/4.2.0/rocketmq-all-4.2.0-source-release.zip
現在執行以下命令來解壓縮 4.2.0 源代碼版本并構建二進制工件。
> unzip rocketmq-all-4.2.0-source-release.zip> cd rocketmq-all-4.2.0/> mvn -Prelease-all -DskipTests clean install -U> cd distribution/target/apache-rocketmq3.啟動mqnamesrv? 、mqbroker?
> nohup sh bin/mqnamesrv &> tail -f ~/logs/rocketmqlogs/namesrv.log運行成功的日志輸出:The Name Server boot success...官方啟動 broker 方式如下:> nohup sh bin/mqbroker -n localhost:9876 & 經測試這樣是不行的,要在后面加上設置 : autoCreateTopicEnable=true 。最終運行命令為:(nohup 記錄日志,& 表示后臺運行 )> nohup sh mqbroker -n localhost:9876 autoCreateTopicEnable=true &> tail -f ~/logs/rocketmqlogs/broker.log 運行成功的日志輸出:The broker[%s, 172.30.30.233:10911] boot success...?4.修改配置、發送和接收消息
設置環境變量> export NAMESRV_ADDR=localhost:9876啟動生產者> sh bin/tools.sh org.apache.rocketmq.example.quickstart.ProducerSendResult [sendStatus=SEND_OK, msgId= ...啟動消費者> sh bin/tools.sh org.apache.rocketmq.example.quickstart.ConsumerConsumeMessageThread_%d Receive New Messages: [MessageExt...5.關閉服務
> sh bin/mqshutdown broker運行成功時日志輸出: The mqbroker(36695) is running... Send shutdown request to mqbroker(36695) OK> sh bin/mqshutdown namesrv運行成功時日志輸出: The mqnamesrv(36664) is running... Send shutdown request to mqnamesrv(36664) OK6.踩過的坑
1)報錯: There is insufficient memory for the Java Runtime Environment to continue
解決方式:??解決There is insufficient memory for the Java Runtime Environment to continue
2)報錯:org.apache.rocketmq.client.exception.MQClientException: No route info of this topic, TopicTest
解決方式:解決:org.apache.rocketmq.client.exception.MQClientException: No route info of this topic, TopicTest
3)報錯:Could not find or load main class org.apache.rocketmq.example.quickstart.Producer
解決方式:解決:Could not find or load main class org.apache.rocketmq.example.quickstart.Producer
?
參考官方文檔:https://rocketmq.apache.org/docs/quick-start/
總結
以上是生活随笔為你收集整理的Apache RocketMQ 安装、测试、报错解决的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: Qt中为自己的程序建立一个消息循环
- 下一篇: 解决: bash: unzip: com