@
Apache 上開源官方地址：https://rocketmq.apache.org/
GitHub 托管地址：https://github.com/apache/rocketmq
阿里官方的介紹文檔：http://jm.taobao.org/2017/01/12/rocketmq-quick-start-in-10-minutes/
Apache 官方 “快速入門” 文檔：https://rocketmq.apache.org/docs/quick-start/
MQ筆記
MQ之主流MQkafaka+RocketMQ+RabbitMQ對比：https://blog.csdn.net/weixin_42526326/article/details/121604583
MQ之RocketMQ常見錯誤：https://blog.csdn.net/weixin_42526326/article/details/121578747
MQ之RocketMQ專業術語：https://blog.csdn.net/weixin_42526326/article/details/121578780
MQ之RocketMQ環境詳細配置：https://blog.csdn.net/weixin_42526326/article/details/121522113
版本兼容
Windows
下載
Linux wget 命令行直接下載
wget https://mirror.bit.edu.cn/apache/rocketmq/4.7.1/rocketmq-all-4.7.1-source-release.zip
選擇自己需要的版本 source:源碼 binary:安裝編譯后文件
解壓安裝
解壓到指定的目錄下即可
環境配置
新建系統變量
加入到PATH
啟動
必要條件：已安裝JDK 1.8+及maven
配置以下兩個命令行會自動設置MQ詳細的環境變量
- 啟動mqnameserv
cmd命令行——進入到RocketMQ的bin目錄下——執行：start mqnamesrv.cmd
若成功會彈出如下提示框，勿關閉
出現警告沒問題，只是JDK版本的提示而已
主要錯誤: 找不到或無法加載主類 Files
解決方法：查看CLASSPATH路徑中的文件夾是否有空格，如果有修改所在文件夾，一般是JAVA安裝在Program Files (x86)目錄下，這個是有空格的，需要移動到其他的目錄
- 啟動mqbroker，自動創建Topic
在RocketMQ的bin目錄下，執行：start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true ， 啟動BROKER。成功后會彈出提示框，勿關閉
錯誤: 找不到或無法加載主類 xxxxxx。在bin下找到並打開runbroker.cmd，改為一下
set "JAVA_OPT=%JAVA_OPT% -cp %CLASSPATH%"
關閉
進入bin目錄，在cmd中先輸入：mqshutdown.cmd broker，再輸入mqshutdown.cmd namesrv
可視化插件
下載解壓
[下載路徑]https://gitcode.net/mirrors/apache/incubator-rocketmq-externals?utm_source=csdn_github_accelerator
[碼雲]https://gitee.com/mirrors/RocketMQ-Externals
百度鏈接：https://pan.baidu.com/s/1sMO6W-562IFJF1uUBQFXYg
提取碼：fuzy
解壓到MQ同目錄下就可以
配置
配置 rocketmq-externals\rocketmq-console\src\main\resources\application.properties
server.port: 可視化插件的端口
rocketmq.config.namesrvAddr=127.0.0.1:9876：rocketmq 的默認鏈接信息
編譯
cmd —— 進入 rocketmq-externals\rocketmq-console 目錄 ——執行執行 mvn clean package -Dmaven.test.skip=true
運行
編譯成功之后，進入編譯后的 target 文件夾，執行 java -jar rocketmq-console-ng-1.0.1.jar 啟動程序
測試
啟動成功之后，在瀏覽器輸入地址 http://127.0.0.1:9999 進行訪問控制台
簡單使用
public class RocketMQDemo {
static final String MQ_NAMESRVADDR = "127.0.0.1:9876";
public static void main(String[] args) {
// 分組名
String groupName = "myGroup-1";
// 主題名
String topicName = "myTopic-1";
// 標簽名
String tagName = "myTag-1";
new Thread(() -> {
try {
producer(groupName, topicName, tagName);
} catch (InterruptedException e) {
e.printStackTrace();
} catch (RemotingException e) {
e.printStackTrace();
} catch (MQClientException e) {
e.printStackTrace();
} catch (MQBrokerException e) {
e.printStackTrace();
}
}).start();
new Thread(() -> {
try {
consumer(groupName, topicName, tagName);
} catch (MQClientException e) {
e.printStackTrace();
}
}).start();
}
/**
* @Description 生產者
* @Author wanglei
* @Param [groupName 分組名, topicName 主題名, tagName 標簽名]
**/
public static void producer(String groupName, String topicName, String tagName) throws InterruptedException, RemotingException, MQClientException, MQBrokerException {
DefaultMQProducer producer = new DefaultMQProducer(groupName);
producer.setNamesrvAddr(MQ_NAMESRVADDR);
producer.start();
String body = "Hello, World!";
Message message = new Message(topicName, tagName, body.getBytes());
producer.send(message);
producer.shutdown();
}
/**
* @Description 消費者
* @Author wanglei
* @Param [groupName 分組名, topicName 主題名, tagName 標簽名]
**/
public static void consumer(String groupName, String topicName, String tagName) throws MQClientException {
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(groupName);
consumer.setNamesrvAddr(MQ_NAMESRVADDR);
consumer.subscribe(topicName, tagName);
consumer.registerMessageListener((MessageListenerConcurrently) (msgs, context) -> {
for (MessageExt msg : msgs) {
System.out.println(new String(msg.getBody()));
}
return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
});
consumer.start();
}
}
最終顯示結果 Hello, World!
控制台
主題
手動創建topic： 192.168.1.108:10911是啟動mqbroker時獲得的，-b是單機，-c是集群
mqadmin.cmd updateTopic -b 192.168.1.108:10911 -n localhost:9876 -t myT
Linux
下載
wget 命令行直接下載
wget https://mirror.bit.edu.cn/apache/rocketmq/4.7.1/rocketmq-all-4.7.1-source-release.zip
選擇自己需要的版本 source:源碼 binary:安裝編譯后文件
解壓安裝
解壓到指定的目錄下即可
官方推薦解壓命令：unzip rocketmq-all-4.7.1-source-release.zip （當然應該也是可以使用其它解壓命令的，如 tar 等，這里還是和官方保持一致，當沒有安裝 unzip 命令包時是使用不了，此時應該先安裝 unzip 命令包）
yum list unzip：查看 unzip 包的安裝情況
yum install unzip.x86_64：沒有安裝時，使用命令安裝 unzip
rm rocketmq-all-4.7.1-source-release.zip #解壓后，可以刪除原來的壓縮包
mv rocketmq-all-4.7.1-source-release/ rocketmq-4.7.1 #對解壓后的目錄重命名
-
使用 Maven 來編譯整個項目，官方推薦命令：mvn -Prelease-all -DskipTests clean install -U （進入解壓目錄下執行此命令）
-
接着就會從 Maven 中央倉庫下載項目依賴的 jar 包編譯部署安裝，這可能需要一點時間。
-
項目部署完成后，可以進入 cd distribution/target/rocketmq-4.7.1/rocketmq-4.7.1 目錄查看，此發布目錄才是將來真正需要使用到的目錄，腳本、配置文件等等全在里面
配置啟動
必要條件：已安裝JDK 1.8+及maven 並設置相關的環境變量
進入 RocketMQ 的 distribution/target/apache-rocketmq 目錄，先啟動 namesrv，再啟動 broker
# 啟動命令，並且常駐內存，nohup 屬於后台啟動，當前目錄下生成 nohup.out 日志文件，也可以指定日志輸出位置。
# 啟動namesrv
# sh bin/mqnamesrv ：屬於終端啟動，直接輸出日志信息，按 ctrl+c 可直接關閉退出
$ nohup sh bin/mqnamesrv &
# 查看啟動日志，能看到 "The Name Server boot success" 字樣則成功
$ tail -f ~/logs/rocketmqlogs/namesrv.log
#看到 “ The Name Server boot success. serializeType=JSON ” 表示啟動成功
#啟動broker
nohup sh bin/mqbroker -n localhost:9876 &
sh bin/mqbroker -n localhost:9876 ：屬於終端啟動，直接輸出日志信息，按 ctrl+c 可直接關閉退出
tail -f ~/logs/rocketmqlogs/broker.log
#看到 "The broker[%s, 172.30.30.233:10911] boot success..." ,則表示啟動成功
關閉
-- 關閉broker
sh bin/mqshutdown broker
The mqbroker(36695) is running...
Send shutdown request to mqbroker(36695) OK
-- 關閉namesrv
sh bin/mqshutdown namesrv
The mqnamesrv(36664) is running...
Send shutdown request to mqnamesrv(36664) OK
常用命令行
除了上面啟動與關閉幾個命令之外，還有如下一些較常用的命令，IP 請以實際為准
--查看集群情況
./bin//mqadmin clusterList -n 127.0.0.1:9876
--查看 broker 狀態
./bin/mqadmin brokerStatus -n 127.0.0.1:9876 -b 172.20.1.138:10911
--查看 topic 列表
./bin/mqadmin topicList -n 127.0.0.1:9876
--查看 topic 狀態
./bin/mqadmin topicStatus -n 127.0.0.1:9876 -t MyTopic (換成想查詢的 topic)
--查看 topic 路由
./bin/mqadmin topicRoute -n 127.0.0.1:9876 -t MyTopic
可視化插件
同上
參考：
https://blog.csdn.net/wangmx1993328/article/details/81536168