Apache RocketMQ 常用命令及执行结果示例

avatar 2024年3月15日18:49:21 评论 893 次浏览

Apache RocketMQ 是一个开源的分布式消息中间件系统,常用于构建高性能、可靠的消息传递系统。本文将介绍一些常用的 RocketMQ 命令,并提供执行结果示例,以帮助用户更好地管理和监控 RocketMQ 集群。

1. 启动 NameServer

 nohup sh bin/mqnamesrv &

执行结果示例:

 The Name Server boot success. serializeType=JSON

2. 启动 Broker

 nohup sh bin/mqbroker -n localhost:9876 &

执行结果示例:

 The broker[192.168.0.1:10911] boot success. serializeType=JSON and name server is localhost:9876

3. 查看 NameServer 配置信息

 sh bin/mqadmin clusterList -n localhost:9876

执行结果示例:

 #Cluster Name     #Broker Name            #Addr
 DefaultCluster     broker-a               192.168.0.1:10911
 DefaultCluster     broker-b               192.168.0.2:10911

4. 创建 Topic

 sh bin/mqadmin updateTopic -c DefaultCluster -n localhost:9876 -t TopicTest

执行结果示例:

 create topic to 192.168.0.1:10911 success.

5. 发送消息

 sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

执行结果示例:

 SendResult [sendStatus=SEND_OK, msgId=...

6. 消费消息

 sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

执行结果示例:

 ConsumeMessageThread_1 Receive New Messages: ...

7. 查看消息堆积情况

 sh bin/mqadmin queryMsgById -n localhost:9876 -i XXXXXXXX

执行结果示例:

 Message ID: XXXXXXXX
 Topic: TopicTest
 Queue ID: 0
 StoreSize: 1024
 BornTimestamp: 1646755200000
 StoreTimestamp: 1646755201000

结论

通过本文介绍的常用 RocketMQ 命令示例,您可以更好地管理和监控 Apache RocketMQ 集群,包括启动 NameServer、Broker,查看集群配置信息,创建 Topic,发送和消费消息,以及查看消息堆积情况等。这些命令可以帮助您更高效地操作 RocketMQ,确保其正常运行和消息传递的可靠性。

avatar

发表评论

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen: