日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 编程问答 >内容正文

编程问答

Apache RocketMQ 安装、测试、报错解决

發布時間:2023/12/18 编程问答 25 豆豆
生活随笔 收集整理的這篇文章主要介紹了 Apache RocketMQ 安装、测试、报错解决 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

1. 準備

前些天發現了一個巨牛的人工智能學習網站,通俗易懂,風趣幽默,忍不住分享一下給大家。點擊跳轉到教程。

64bit OS, Linux/Unix/Mac? 64bit JDK 1.8+; Maven 3.2.x

2.下載和構建

下載 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-rocketmq

3.啟動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) OK

6.踩過的坑

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 安装、测试、报错解决的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。