RocketMQ 服务搭建

概述

学习此文，可以快速的搭建一个单机的 RocketMQ 服务。

RocketMQ 单机服务搭建

搭建架构

相关地址

• RocketMQ官网地址
• 二进制下载主页，选择对应版本下载
• 启动参数步骤 github

前置操作

[root@hadoop02 soft]# pwd
/data/soft
[root@hadoop02 soft]# unzip rocketmq-all-5.1.4-bin-release.zip

• 上传：rocketmq-all-5.1.4-bin-release.zip
• 解压：unzip rocketmq-all-5.1.4-bin-release.zip

NameServer 启动

• 在 mqnameserv.sh 文件中设置：export ROCKETMQ_HOME=/data/soft/rocketmq-all-5.1.4-bin-release ，或者直接配置环境变量
• 修改 runserver.sh 如果 JAVA_HOME 没有设置，需要 export 一下
• 启动 mqnameserv.sh

配置启动

[root@hadoop02 bin]# vi /etc/profile
export ROCKETMQ_HOME=/data/soft/rocketmq-all-5.1.4-bin-release

[root@hadoop02 bin]# vi runserver.sh 
export JAVA_HOME=/data/soft/jdk-11.0.20

[root@hadoop02 bin]# nohup sh mqnamesrv &
[1] 30047
[root@hadoop02 bin]# nohup: 忽略输入并把输出追加到"nohup.out"

[root@hadoop02 bin]# 

[root@hadoop02 bin]# nohup sh mqnamesrv &

解决 java 版本的问题

[root@hadoop02 bin]# vi runserver.sh 
export JAVA_HOME=/data/soft/jdk-11.0.20

Broker 启动

• 新建 brokersrv.sh ，内容为： /mqbroker -n localhost:9876 autoCreateTopicEnable=true 设置 chmod 777 brokersrv.sh，也可以不建，直接执行命令
• 修改 runbroker.sh 如没有设置 JAVA_HOME 的话
• 在 mqborker.sh 文件中设置： ROCKETMQ_HOME
• 为了找到存储的目录，如果想做改变，在 runbroker.sh 文件中设置： JAVA_OPT=“${JAVA_OPT}-Duser.home=xxx”，此处默认设置

[root@hadoop02 bin]# vi runbroker.sh
export JAVA_HOME=/data/soft/jdk-11.0.20

[root@hadoop02 rocketmq-all-5.1.4-bin-release]# nohup sh bin/mqbroker -n localhost:9876 &

如果想可以自动创建 Topic ，那么命令改为 nohup sh bin/mqbroker -n localhost:9876 autoCreateTopicEnable=true &

测试

参考官网

export NAMESRV_ADDR=localhost:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

上述命令测试结果如下图：

关闭

sh bin/mqshutdown broker
sh bin/mqshutdown namesrv

结束

至此，RocketMQ 服务搭建 就结束了，如有疑问，欢迎评论区留言。