快速连接RocketMQ并生产消费消息
更新时间 2025-12-30 17:08:36
最近更新时间: 2025-12-30 17:08:36
本节介绍如何快速连接RocketMQ并生产和消费消息。
本章节将为您介绍分布式消息服务RocketMQ(以下简称RocketMQ)入门的使用流程,以创建一个开启SSL的RocketMQ实例,客户端使用内网通过同一个VPC连接RocketMQ实例生产消费消息为例,帮助您快速上手RocketMQ。
在ECS环境中进入“rocketmq-tutorial/bin”目录。
cd rocketmq-tutorial/bin运行生产普通消息命令。
命令示例如下:
JAVA_OPT=-Dtls.enable=true sh mqadmin sendMessage -n "10.xxx.xxx.89:8100;10.xxx.xxx.144:8100" -t Topic01 -p "hello rocketmq"10.xxx.xxx.89:8100;10.xxx.xxx.144:8100:表示RocketMQ实例的“连接地址”,即11中记录的连接地址。
Topic01:表示RocketMQ实例下创建的Topic名称,即4中创建的Topic名称。
hello rocketmq:表示生产消息的内容,可自定义。
运行消费普通消息命令。
命令示例如下:
JAVA_OPT=-Dtls.enable=true sh mqadmin consumeMessage -n "10.xxx.xxx.89:8100;10.xxx.xxx.144:8100" -t Topic01如上图中BODY显示的内容即为消费消息的内容。
如需停止消费使用Ctrl+C命令退出。