<返回更多

MQ之RocketMQ环境详细配置

2021-12-07    好奇新NewBoy
加入收藏

@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详细的环境变量

cmd命令行——进入到RocketMQ的bin目录下——执行:start mqnamesrv.cmd

若成功会弹出如下提示框,勿关闭

出现警告没问题,只是JDK版本的提示而已

主要错误: 找不到或无法加载主类 Files

解决方法:查看CLASSPATH路径中的文件夹是否有空格,如果有修改所在文件夹,一般是JAVA安装在Program Files (x86)目录下,这个是有空格的,需要移动到其他的目录

在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    #对解压后的目录重命名

配置启动

必要条件:已安装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

声明:本站部分内容来自互联网,如有版权侵犯或其他问题请与我们联系,我们将立即删除或处理。
▍相关推荐
更多资讯 >>>