java中的接口是类吗
731
2022-09-08
RocketMQ 4.9 安装教程(rocketmq如何保证消息顺序消费)
一、下载
前往 ,下载 Binary 文件即可。
例如RocketMQ 4.9.0的下载地址:
Binary:rocketmq-all-4.9.0-bin-release.zip
二、系统要求
64位操作系统,生产环境建议Linux/Unix/MacOS(Windows操作系统安装说明详见 Windows操作系统安装教程)64位JDK 1.8(目前RocketMQ不支持 JDK 11)4G+的可用磁盘
三、Linux/Unix/MacOS安装教程
3.1 搭建
解压压缩包
unzip rocketmq-all-4.9.0-bin-release.zip
切换目录到RocketMQ根目录
cd rocketmq-all-4.9.0-bin-release
启动Name Server
nohup sh bin/mqnamesrv &
验证是否启动OK:
tail -f ~/logs/rocketmqlogs/namesrv.log# 如果成功启动,能看到类似如下的日志:2021-07-06 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# 如果启动成功,能看到类似如下的日志:2020-07-06 17:08:41 INFO main - The broker[itmuchcomdeMacBook-Pro.local, 192.168.1.218:10911] boot success. serializeType=JSON and name server is localhost:9876
3.2 验证RocketMQ功能正常(可选)
3.2.1 验证生产消息正常
执行如下命令:
export NAMESRV_ADDR=localhost:9876sh 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....
3.3 停止
依次执行以下两条命令即可
# 命令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
版权声明:本文内容由网络用户投稿,版权归原作者所有,本站不拥有其著作权,亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容,请联系我们jiasou666@gmail.com 处理,核实后本网站将在24小时内删除侵权内容。
发表评论
暂时没有评论,来抢沙发吧~