TIPS
本文基于RocketMQ 4.5.1,理论支持RocketMQ 4.0+
本文详细探讨如何搭建RocketMQ
前往 http://rocketmq.apache.org/release_notes/release-notes-4.5.1/
,下载 Binary
文件即可。
例如RocketMQ 4.5.1的下载地址:
解压压缩包
unzip rocketmq-all-4.5.1-bin-release.zip
切换目录到RocketMQ根目录
cd rocketmq-all-4.5.1-bin-release
启动Name Server
nohup sh bin/mqnamesrv &
验证是否启动OK:
- tail -f ~/logs/rocketmqlogs/namesrv.log
-
- # 如果成功启动,能看到类似如下的日志:
- 2019-07-18 17:03:56 INFO main - The Name Server boot success. ...
启动 Broker
nohup sh bin/mqbroker -n localhost:9876 &
验证是否启动OK:
- tail -f ~/logs/rocketmqlogs/broker.log
-
- # 如果启动成功,能看到类似如下的日志:
- 2019-07-18 17:08:41 INFO main - The broker[itmuchcomdeMacBook-Pro.local, 192.168.43.197:10911] boot success. serializeType=JSON and name server is localhost:9876
3.2.1 验证生产消息正常
执行如下命令:
- export NAMESRV_ADDR=localhost:9876
- sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
能看到类似如下输出:
SendResult [sendStatus=SEND_OK, msgId=C0A82BC5F36C511D50C05B41...
3.2.2 验证消费消息正常
执行如下命令:
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
能看到类似如下输出:
ConsumeMessageThread_4 Receive New Messages: [MessageExt [queueId=3, stor....
依次执行以下两条命令即可
- # 命令
- sh bin/mqshutdown broker
- # 输出如下信息说明停止成功
- The mqbroker(36695) is running...
- Send shutdown request to mqbroker(36695) OK
-
- # 命令
- sh bin/mqshutdown namesrv
- # 输出如下信息说明停止成功
- The mqnamesrv(36664) is running...
- Send shutdown request to mqnamesrv(36664) OK
RocketMQ集群搭建说明 ,集群安装模式非常多,本文不展开了。请各位看客根据自己的需求,选择适合自己的模式自行搭建。