10 張圖 | 一文帶你用 Mac M1 跑 RocketMQ
你好，我是悟空。
本文主要內(nèi)容如下：
目錄
前言
最近在倒騰RocketMQ消息隊列，首先就得把 RocketMQ 跑起來對吧，我們一般都是 Windows 或者 Linux 機器上，按照官方教程一下子就跑起來了，另外用 Intel 芯片的 Mac 也能輕松跑起來。
但是我在 Mac M1? 上的機器上跑的時候，就遇到了各種問題，折騰了一天，最后終于把 RocketMQ 在 Mac M1 上用Docker跑起來了，這里總結下心路歷程。
雖然演示環(huán)境是用 Mac M1系統(tǒng)，但其實 Linux 系統(tǒng)也適用~
關于用源碼方式跑 RocketMQ 的方式下文也有介紹。
一、用源碼跑 RocketMQ
最開始我用 Docker 跑，會報錯，后來我就用源碼跑，可以跑起來，能夠發(fā)送和消費消息。
源碼地址：https://github.com/apache/rocketmq
我用的版本是 4.9.2。
二、用 Docker 跑 RocketMQ
總共啟動了三個容器，用到的鏡像分別為
- nameserver 鏡像：rocketmqinc/rocketmq
- broker 鏡像：dyrnq/rocketmq:4.8.0
- 控制臺鏡像：apacherocketmq/rocketmq-dashboard:latest
三個容器啟動成功
2.1 拉取 rocketmq 鏡像
docker pull rocketmqinc/rocketmq2.2 啟動 nameserver 命令
鏡像：rocketmqinc/rocketmq
docker run -d -p 9876:9876 -v `pwd`/data/namesrv/logs:/root/logs -v `pwd`/data/namesrv/store:/root/store --name rmqnamesrv rocketmqinc/rocketmq sh mqnamesrv
2.3 啟動 broker 命令
鏡像：dyrnq/rocketmq:4.8.0
docker run -d -p 10911:10911 -p 10909:10909 -v `pwd`/data/broker/logs:/root/logs -v `pwd`/data/broker/store:/root/store --name rmqbrokerv2 --link rmqnamesrv:namesrv -e "NAMESRV_ADDR=namesrv:9876" dyrnq/rocketmq:4.8.0 sh mqbroker -c ../conf/broker.conf
進入容器
docker exec -it b6b /bin/bash
進入到 broker 容器
修改 broker.conf 文件，提示未安裝 vim 工具，則需要安裝下 vim
vim ../conf/broker.conf
apt-get update
apt-get install vim
vim ../conf/broker.conf
然后將 這行命令拷貝到 broker.conf 文件中。192.168.10.197 為自己的本機 IP
brokerIP1=192.168.10.197
不知道自己 IP 的地址的，可以通過這個命令獲取 mac 機器的本機 IP，如下所示：
ifconfig | grep "inet"
最后 broker.conf 配置如下：
broker.conf 配置
三、啟動控制臺 rocketmq-dashboard
原來的控制臺是 rocketmq-console-ng，但是發(fā)現(xiàn) Github 上已經(jīng)移除了。官方提示如下：
官方提示移除了 rocketmq-console-ng。
上面公告的表示之前的rocket-console已經(jīng)不在這個倉庫了，已經(jīng)創(chuàng)建了一個獨立的倉庫并命名為RocketMQ Dashboard。倉庫路徑：https://github.com/apache/rocketmq-dashboard。
我們直接執(zhí)行下面的命令：
docker run -d --name rocketmq-dashboard -e "JAVA_OPTS=-Drocketmq.namesrv.addr=172.16.8.62:9876 -Drocketmq.config.isVIPChannel=false" -p 8080:8080 -t apacherocketmq/rocketmq-dashboard:latest
啟動 dashboard 容器。
注意：這里的 IP 地址為本機 IP。
isVIPChannel=false，這里必須這樣設置，不然打開控制臺后，無法獲取數(shù)據(jù)。
容器啟動成功后訪問 http://localhost:8080/。
四、測試發(fā)送消息
往 test_topic 發(fā)送一條消息
選擇往哪個隊列發(fā)送消息
在消息主題中輸入 悟空聊架構，www.passjava.cn，點擊確定按鈕發(fā)送消息。
發(fā)送的消息內(nèi)容
發(fā)送結果如下：
發(fā)送結果
看下 Message 菜單欄，選擇 test_top 主題，可以看到一條消息：
消息列表
消息內(nèi)容如下，和發(fā)送的消息一致。
接收到的消息
五、問題匯總
broker 無法連到 NameServer
需要到容器里面修改 broker.conf 文件，加上。
brokerIP1=192.168.10.197。
并且 docker 啟動 broker 時需要增加命令參數(shù)-c ../conf/broker.conf。
原因
這里的 ip 地址需要指定為外網(wǎng)地址。因為 rockerMQ broker 默認會選擇內(nèi)網(wǎng)地址。
只有當參數(shù)行中有-c參數(shù)時才會使用配置文件的參數(shù)。這里卡了很長時間。
源碼如下：
if (commandLine.hasOption('c')) {
String file = commandLine.getOptionValue('c');
if (file != null) {
configFile = file;
InputStream in = new BufferedInputStream(new FileInputStream(file));
properties = new Properties();
properties.load(in);
properties2SystemEnv(properties);
MixAll.properties2Object(properties, brokerConfig);
MixAll.properties2Object(properties, nettyServerConfig);
MixAll.properties2Object(properties, nettyClientConfig);
MixAll.properties2Object(properties, messageStoreConfig);
BrokerPathConfigHelper.setBrokerConfigPath(file);
in.close();
}
}
啟動 broker 報錯
wukong@wukongs-MacBook-Pro ~ docker restart b6b
Error response from daemon: Cannot restart container b6b: Cannot link to a non running container: /rmqnamesrv AS /rmqbrokerv2/namesrv
報錯提示
原因
這個問題其實就是 name server 沒啟動成功。
關于我
8 年互聯(lián)網(wǎng)開發(fā)經(jīng)驗，擅長微服務、分布式、架構設計。目前在一家大型上市公司從事基礎架構和性能優(yōu)化工作。
InfoQ 簽約作者、藍橋簽約作者、阿里云專家博主、51CTO 紅人。
