@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专业术语：
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-externalsrocketmq-consolesrcmainresourcesApplication.properties

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

rocketmq.config.namesrvAddr=127.0.0.1:9876：rocketmq 的默认链接信息

编译

cmd —— 进入 rocketmq-externalsrocketmq-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

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