RocketMQ 启动 & 关闭
一则或许对你有用的小广告
欢迎加入小哈的星球 ，你将获得：专属的项目实战 / 1v1 提问 / Java 学习路线 / 学习打卡 / 每月赠书 / 社群讨论
- 新项目:《从零手撸：仿小红书（微服务架构）》 正在持续爆肝中，基于
Spring Cloud Alibaba + Spring Boot 3.x + JDK 17...，点击查看项目介绍 ; - 《从零手撸：前后端分离博客项目（全栈开发）》 2 期已完结，演示链接： http://116.62.199.48/ ;
截止目前， 星球 内专栏累计输出 80w+ 字，讲解图 3365+ 张，还在持续爆肝中.. 后续还会上新更多项目，目标是将 Java 领域典型的项目都整一波，如秒杀系统, 在线商城, IM 即时通讯，权限管理，Spring Cloud Alibaba 微服务等等，已有 2700+ 小伙伴加入学习 ，欢迎点击围观
本节中，您将学习如何启动以及关闭单机版 RocketMQ。
开始
单机版 RocketMQ 启动非常简单，您无需做任何配置，仅仅需要依次启动 NameServer 和 Broker 即可。首先，让我们进入 RocketMQ 的安装目录。
一、启动 NameServer
后台启动 NameServer:
nohup sh bin/mqnamesrv &
查看 NameServer 启动日志：
tail -f ~/logs/rocketmqlogs/namesrv.log
启动成功的情况下，日志中会包含如下日志：
The Name Server boot success...
二、启动 Broker
后台启动 Broker:
sh bin/mqbroker -n localhost:9876 autoCreateTopicEnable=true &
autoCreateTopicEnable=true参数的意义为自动创建 Topic。
查看 Broker 启动日志：
tail -f ~/logs/rocketmqlogs/broker.log
启动成功的情况下，日志中会包含如下日志：
The broker[%s, 172.30.30.233:10911] boot success...
RocketMQ 发送与接收消息测试
NameServer 和 Broker 均启动成功后，让我们来测试一下，是否能够正常的发送与接收消息。我们通过 RocketMQ 自身 bin/tools.sh 脚本来做一个快速的测试，但是在那之前，需要设置一下 NAMESRV_ADDR 的环境变量 ：
> export NAMESRV_ADDR=localhost:9876
> sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
SendResult [sendStatus=SEND_OK, msgId= ...
> sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
ConsumeMessageThread_%d Receive New Messages: [MessageExt...
若能正确打印上述日志，则表明单击版 RocketMQ 部署成功！
关闭 RocketMQ
您可以通过 bin/mqshutdown 脚本来关闭 NameServer 和 Broker:
> 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