一、linux单机部署:
1、到apache官网下载 | RocketMQ (apache.org)下载binary zip包,如我下载的4.9.6版本。
上传到建好的/usr/local/rocketmq目录下。
2、解压zip包
unzip rocketmq-all-4.9.6-bin-release.zip
3、进入解压后的文件夹,启动 Name Server:
nohup sh bin/mqnamesrv &
启动后会有日志输出到nohup.out文件上(自动生成),可以到上面去看看是否启动成功:
看到启动成功日志:The Name Server boot success. serializeType=JSON
4、启动broker:
nohup sh bin/mqbroker -n localhost:9876 &
同样日志也是输出到nohup.out文件上
看下日志:
看到启动成功日志:
The broker[i-8847E0CB, 172.31.7.9:10911] boot success. serializeType=JSON and name server is localhost:9876
5、测试收发消息:
在发送和接收消息之前,客户需要识别名称服务器的地址。 RocketMQ有多种方法可以在客户端设置名称服务器地址。其中之一是修改环境变量namesrv_addr:
export NAMESRV_ADDR=localhost:9876
(1)测试发送消息:
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
发送成功:
(2)测试接收消息:
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
接收成功:
6、停掉rocketmq:
sh bin/mqshutdown broker
sh bin/mqshutdown namesrv
成功关掉服务: 文章来源:https://www.toymoban.com/news/detail-732769.html
7、 Apache官网rocketmq文档:Quickstart | RocketMQ文章来源地址https://www.toymoban.com/news/detail-732769.html
到了这里,关于RocketMq(一)安装部署的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!