@TOC

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專業(yè)術(shù)語：
https://blog.csdn.net/weixin_42526326/article/details/121578780

MQ之RocketMQ環(huán)境詳細(xì)配置：
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:安裝編譯后文件

解壓安裝

解壓到指定的目錄下即可

環(huán)境配置

新建系統(tǒng)變量

加入到PATH

啟動

必要條件：已安裝JDK 1.8+及maven

配置以下兩個命令行會自動設(shè)置MQ詳細(xì)的環(huán)境變量

• 啟動mqnameserv

cmd命令行——進入到RocketMQ的bin目錄下——執(zhí)行：start mqnamesrv.cmd

若成功會彈出如下提示框，勿關(guān)閉

出現(xiàn)警告沒問題，只是JDK版本的提示而已

主要錯誤: 找不到或無法加載主類 Files

解決方法：查看CLASSPATH路徑中的文件夾是否有空格，如果有修改所在文件夾，一般是JAVA安裝在Program Files (x86)目錄下，這個是有空格的，需要移動到其他的目錄

• 啟動mqbroker，自動創(chuàng)建Topic

在RocketMQ的bin目錄下，執(zhí)行：start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true ， 啟動BROKER。成功后會彈出提示框，勿關(guān)閉

錯誤: 找不到或無法加載主類 xxxxxx。在bin下找到并打開runbroker.cmd，改為一下

set "JAVA_OPT=%JAVA_OPT% -cp %CLASSPATH%" 

關(guān)閉

進入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-externalsrocketmq-consolesrcmainresourcesApplication.properties

server.port: 可視化插件的端口

rocketmq.config.namesrvAddr=127.0.0.1:9876：rocketmq 的默認(rèn)鏈接信息

編譯

cmd —— 進入 rocketmq-externalsrocketmq-console 目錄 ——執(zhí)行執(zhí)行 mvn clean package -Dmaven.test.skip=true

運行

編譯成功之后，進入編譯后的 target 文件夾，執(zhí)行 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";
        // 標(biāo)簽名
        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 生產(chǎn)者
     * @Author wanglei
     * @Param [groupName 分組名, topicName 主題名, tagName 標(biāo)簽名]
     **/
    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 標(biāo)簽名]
     **/
    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();
    }
}

最終顯示結(jié)果 Hello, World!

控制臺

主題

手動創(chuàng)建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 （當(dāng)然應(yīng)該也是可以使用其它解壓命令的，如 tar 等，這里還是和官方保持一致，當(dāng)沒有安裝 unzip 命令包時是使用不了，此時應(yīng)該先安裝 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 （進入解壓目錄下執(zhí)行此命令）
• 接著就會從 Maven 中央倉庫下載項目依賴的 jar 包編譯部署安裝，這可能需要一點時間。

• 項目部署完成后，可以進入 cd distribution/target/rocketmq-4.7.1/rocketmq-4.7.1 目錄查看，此發(fā)布目錄才是將來真正需要使用到的目錄，腳本、配置文件等等全在里面

配置啟動

必要條件：已安裝JDK 1.8+及maven 并設(shè)置相關(guān)的環(huán)境變量

進入 RocketMQ 的
distribution/target/apache-rocketmq 目錄，先啟動 namesrv，再啟動 broker

# 啟動命令，并且常駐內(nèi)存，nohup 屬于后臺啟動，當(dāng)前目錄下生成 nohup.out 日志文件，也可以指定日志輸出位置。

# 啟動namesrv
# sh bin/mqnamesrv ：屬于終端啟動，直接輸出日志信息，按 ctrl+c 可直接關(guān)閉退出
$ 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 可直接關(guān)閉退出

tail -f ~/logs/rocketmqlogs/broker.log
#看到 "The broker[%s, 172.30.30.233:10911] boot success..." ,則表示啟動成功

關(guān)閉

-- 關(guān)閉broker
sh bin/mqshutdown broker
The mqbroker(36695) is running...
Send shutdown request to mqbroker(36695) OK
-- 關(guān)閉namesrv
sh bin/mqshutdown namesrv
The mqnamesrv(36664) is running...
Send shutdown request to mqnamesrv(36664) OK

常用命令行

除了上面啟動與關(guān)閉幾個命令之外，還有如下一些較常用的命令，IP 請以實際為準(zhǔn)

--查看集群情況	
./bin//mqadmin clusterList -n 127.0.0.1:9876
--查看 broker 狀態(tài)	
./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 狀態(tài)	
./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

https://www.jianshu.com/p/db8b6d25fca7