分布式消息服务ROCKETMQ版-使用客户端连接RocketMQ(关闭SSL):命令行模式连接实例
命令行模式连接实例
- 登录客户端所在服务器。
- 下载“rocketmq-tutorial”示例软件包。
wget https://dms-demos.obs.cn-north-1.myhuaweicloud.com/rocketmq-tutorial.zip
- 解压“rocketmq-tutorial”。
unzip rocketmq-tutorial.zip
- (可选)如果RocketMQ实例开启了ACL访问控制,执行mqadmin命令时,需要鉴权。
切换到解压后的软件包目录下,在“conf/tools.yml”文件中,增加如下内容。
accessKey:******* secretKey:*******
accessKey和secretKey表示在控制台“用户管理”页面,创建的用户名和密钥,具体可参见创建用户。
- 进入“rocketmq-tutorial/bin”目录。
cd rocketmq-tutorial/bin
- 运行生产普通消息示例。
sh mqadmin sendMessage -n "${连接地址}" -t ${Topic名称} -p "hello rocketmq"
参数说明如下:
- 连接地址:表示RocketMQ实例的“连接地址”(内网访问)/“公网连接地址”(公网访问)。
- Topic名称:RocketMQ实例下创建的Topic名称。
示例如下,其中“11.xxx.xxx.89:8200;11.xxx.xxx.144:8200”为RocketMQ实例的元数据公网连接地址,“topic-test”为Topic名称。
sh mqadmin sendMessage -n "11.xxx.xxx.89:8200;11.xxx.xxx.144:8200" -t topic-test -p "hello rocketmq"
使用Ctrl+C命令退出。
- 运行消费普通消息示例。
sh mqadmin consumeMessage -n "${连接地址}" -t ${Topic名称}
参数说明如下:
- 连接地址:表示RocketMQ实例的“连接地址”(内网访问)/“公网连接地址”(公网访问)。
- Topic名称:RocketMQ实例下创建的Topic名称。
示例如下,其中“11.xxx.xxx.89:8200;11.xxx.xxx.144:8200”为RocketMQ实例的元数据公网连接地址,“topic-test”为Topic名称。
sh mqadmin consumeMessage -n "11.xxx.xxx.89:8200;11.xxx.xxx.144:8200" -t topic-test
如需停止消费使用Ctrl+C命令退出。
- 运行生产带消息轨迹的消息示例。
sh mqadmin sendMessage -n "${连接地址}" -t ${Topic名称} -p "hello rocketmq" -m true
参数说明如下:
- 连接地址:表示RocketMQ实例的“连接地址”(内网访问)/“公网连接地址”(公网访问)。
- Topic名称:RocketMQ实例下创建的Topic名称。
示例如下,其中“11.xxx.xxx.89:8200;11.xxx.xxx.144:8200”为RocketMQ实例的元数据公网连接地址,“topic-test”为Topic名称。
sh mqadmin sendMessage -n "11.xxx.xxx.89:8200;11.xxx.xxx.144:8200" -t topic-test -p "hello rocketmq" -m true
使用Ctrl+C命令退出。
- 运行消费消息示例,并发送消息轨迹。
sh mqadmin consumeMessage -n "${连接地址}" -t ${Topic名称} -m true
参数说明如下:
- 连接地址:表示RocketMQ实例的“连接地址”(内网访问)/“公网连接地址”(公网访问)。
- Topic名称:RocketMQ实例下创建的Topic名称。
示例如下,其中“11.xxx.xxx.89:8200;11.xxx.xxx.144:8200”为RocketMQ实例的元数据公网连接地址,“topic-test”为Topic名称。
sh mqadmin consumeMessage -n "11.xxx.xxx.89:8200;11.xxx.xxx.144:8200" -t topic-test -m true
使用Ctrl+C命令退出。
- RocketMQ是什么_RocketMQ介绍_分布式消息服务RocketMQ版
- 分布式消息服务Kafka版与分布式消息服务RocketMQ版的区别_Kafka与RocketMQ对比_Kafka与RocketMQ差异
- 分布式消息服务有哪些_分布式消息服务哪个好_分布式消息-华为云
- 分布式消息中间件实战_分布式消息实战_分布式消息-华为云
- RocketMQ的架构_RocketMQ的消息模式_分布式消息RocketMQ-华为云
- kafka是什么_kafka介绍_分布式消息服务Kafka版
- 分布式消息队列是什么_分布式消息队列好处_消息队列-华为云
- 分布式消息中间件的作用_分布式消息中间件_分布式消息-华为云
- 分布式消息服务优势_分布式消息服务_消息队列-华为云
- RocketMQ主要应用场景有哪些_分布式消息中间件_分布式消息RocketMQ-华为云