RocketMQ 启动 & 关闭

更新时间: 2019-02-19 10:10:17   作者: 异常教程网

一则或许对你有用的小广告

欢迎加入小哈的星球 ,你将获得:专属的项目实战 / Java 学习路线 / 一对一提问 / 学习打卡/ 赠书活动

目前,正在 星球 内带小伙伴们做第一个项目:全栈前后端分离博客项目,采用技术栈 Spring Boot + Mybatis Plus + Vue 3.x + Vite 4手把手,前端 + 后端全栈开发,从 0 到 1 讲解每个功能点开发步骤,1v1 答疑,陪伴式直到项目上线,目前已更新了 204 小节,累计 32w+ 字,讲解图:1416 张,还在持续爆肝中,后续还会上新更多项目,目标是将 Java 领域典型的项目都整上,如秒杀系统、在线商城、IM 即时通讯、权限管理等等,已有 870+ 小伙伴加入,欢迎点击围观

本节中,您将学习如何启动以及关闭单机版 RocketMQ。

开始

单机版 RocketMQ 启动非常简单,您无需做任何配置,仅仅需要依次启动 NameServerBroker 即可。首先,让我们进入 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