开发者学堂课程【RocketMQ知识精讲与项目实战(第一阶段):测试发送消息和接受消息】学习笔记,与课程紧密联系,让用户快速学习知识
课程地址:https://developer.aliyun.com/learning/course/702/detail/12364
测试发送消息和接受消息
内容介绍:
一、消息的发送
二、接受消息
三、停止 rocketmq
一、消息的发送
1.准备工作
需要执行以下命令:
1 # 1.设置环境变量
2 export NAMESRV_ADDR=localhost:9876
3 #2.使用安装包的 Demo 发送消息
4 shbin/tools.shorg.apache.rocketmq.example.quickastart. Producer
需要使用 rocketmq 示例中的脚本文件,简单进行消息的发送和接收。需要重新启
动一个进程,启动一个新的窗口。
如图:
创建俩个新的窗口,一个充当消息的发送者,一个充当消息的接受者。
如图:将俩个窗口进入到 rocketmq 的 bin 录当中目,做好准备工作。
2.发送消息
执行以下命令:
1 # 1.设置环境变量
2 export NAMESRV_ADDR=localhost:9876
3 #2.使用安装包的 Demo 发送消息
4 shbin/tools.shorg.apache.rocketmq.example.quickastart. Producer
输入完上述命令后,此时正在发送消息:
二、接受消息
需要执行以下命令:
1 # 1.设置环境变量
2 export NAMESRV_ADDR=localhost:9876
3 # 2.接受消息
4 sh bin/tools.sh org.apache.rocketmq.example.quickstart.consumer
执行完上述命令之后,如果接收到了消息,则会发现右边页面正在打印消息。
如图
观察后发现,这俩个系统一直处于启动监听的状态。
在消息的发送方,再次发送消息,消费方,应该可以再次打印消息的消费情况。
如图:
此时,则说明 rocketmq 安装的环境正常,已经安装成功。
三、停止rocketmq
执行以下命令:
1 #1.关闭 nameserver
2 sb bin/mqshutdown namesrv
3 # 2.关闭 broker
4 sh bin/mqshutdown broker