RocketMQ 第一章核心功能 2 RocketMQ 快速入门 2.4 测试RocketMQ & 2.5 关闭RocketMQ

来两个窗口，一个消息发送者，一个接收者

这…

还是请出俺的 Xshell 吧

在这里插入图片描述

两个都记得进到 RocketMQ 的安装目录的 bin 里

在这里插入图片描述

# 1.设置环境变量
export NAMESRV_ADDR=localhost:9876
# 2.使用安装包的Demo发送消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

设置环境变量

在这里插入图片描述

使用安装包的Demo 发送消息

在这里插入图片描述

已经在bin 下了，那一级目录就可以不写了

直接回车

在这里插入图片描述

OK，好像是发了一堆吧，没报错就完成了消息的发送

# 1.设置环境变量
export NAMESRV_ADDR=localhost:9876
# 2.接收消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

直接执行就行

在这里插入图片描述

回车！！

在这里插入图片描述

没毛病，消息拿到了，而且可以看到，消费方并没有停，而是在一直监听着队列

我再运行一次生产者，这次笔者用动图

在这里插入图片描述

没毛病哈，左边在发，右边在收

这个命令之前启动报错已经用过了，但是笔者没有提，知道就行了

# 1.关闭NameServer
sh bin/mqshutdown namesrv
# 2.关闭Broker
sh bin/mqshutdown broker