rocketmq控制台指令(3)

1.2.10. 根据消息ID查询消息 指queryMsgById 类com.alibaba.rocketmq.tools.command.message.QueryMsgByIdSubCommand 令 路径 参数 是说明 否必填 -i -h -n 是 msgId 否 打印帮助 是 nameserve服务地址列表，格式ip:port;ip:port;... 举查询msgId= 0A2D2FA800002A9F0000000000000000的消息，nameserve地址为例 10.45.47.168:9876 sh mqadmin queryMsgById –n 10.45.47.168:9876 –i 0A2D2FA800002A9F0000000000000000 打印内容: Topic: ZTEExample Tags: [SimpleTest] Keys: [SimpleTest-1] Queue ID: 0 Queue Offset: 0 CommitLog Offset: 0 Born Timestamp: 2014-02-26 14:49:10,875 Store Timestamp: 2014-02-26 14:48:44,840 Born Host: 10.45.46.229:4231 Store Host: 10.45.47.168:10911 System Flag: 0 Properties: {TAGS=SimpleTest, KEYS=SimpleTest-1, WAIT=true} Message Body Path: /tmp/rocketmq/msgbodys/0A2D2FA800002A9F0000000000000000 1.2.11. 根据消息Key查询消息 指queryMsgByKey 类com.alibaba.rocketmq.tools.command.message.QueryMsgByKeySubCommand 令 路径 参数 是说明 否必填 -f -k -t -h -n 否 被查询消息的截止时间 是 msgKey 是 Topic名称 否 打印帮助 是 nameserve服务地址列表，格式ip:port;ip:port;... 举查询Topic= ZTEExample下key= SimpleTest-1的消息，nameserve地址为10.45.47.168:9876 例 sh mqadmin queryMsgByKey -n 10.45.47.168:9876 -t ZTEExample -k SimpleTest-1 打印内容: #Message ID #QID #Offset 0A2D2FA800002A9F0000000000000000 0 0 1.2.12. 根据Offset查询消息 指queryMsgByOffset 类com.alibaba.rocketmq.tools.command.message.QueryMsgByOffsetSubCommand 令 路径 参数 是说明 否必填 -b 是 Broker名称，表示订阅组建在该broker（这里需要注意填写的是broker的名称，不是broker的地址，broker名称可以在clusterList查到） -i -o -t -h -n 是 query队列id 是 offset值 是 topic名称 否 打印帮助 是 nameserve服务地址列表，格式ip:port;ip:port;... 举查询brokerName=crm-168，Topic= ZTEExample的第1个队列下offset=0的消息，nameserve地例 址为10.45.47.168:9876 sh mqadmin queryMsgByOffset -n 10.45.47.168:9876 -b crm-168 -i 0 -t ZTEExample -o 0 打印内容: Topic: ZTEExample Tags: [SimpleTest] Keys: [SimpleTest-1] Queue ID: 0 Queue Offset: 0 CommitLog Offset: 0 Born Timestamp: 2014-02-26 14:49:10,875 Store Timestamp: 2014-02-26 14:48:44,840 Born Host: 10.45.46.229:4231 Store Host: 10.45.47.168:10911 System Flag: 0 Properties: {TAGS=SimpleTest, KEYS=SimpleTest-1, WAIT=true} Message Body Path: /tmp/rocketmq/msgbodys/0A2D2FA800002A9F0000000000000000 1.2.13. 查询Producer的网络连接 l 该命令只打印当前与cluster连接的producer网络连接信息 指producerConnection 类com.alibaba.rocketmq.tools.command.connection.ProducerConnectionSubComman令 路径 参数 是说明 否必填 -g -t -h -n 是 生产者所属组名 是 topic名称 否 打印帮助 是 nameserve服务地址列表，格式ip:port;ip:port;... 举查询当前属于group（生产者组）=simple-producer-test的生产者到topic=ZTEExample的网络连接，例 nameserve地址为10.45.47.168:9876 sh mqadmin producerConnection -n 10.45.47.168:9876 -g simple-producer-test -t ZTEExample 打印内容: 0001 10.45.46.229@simple-producer-test-99f09de2a20a4b6284bb949b452bee0c 10.45.46.229:4332 Java V3_0_7 1.2.14. 查询Consumer的网络连接 l 该命令只打印当前与cluster连接的consumer网络连接信息 指consumerConnection 类com.alibaba.rocketmq.tools.command.connection.ConsumerConnectionSubComm令 路径 参数 是说明 否必填 -g -h -n 是 消费者所属组名 否 打印帮助 是 nameserve服务地址列表，格式ip:port;ip:port;... 举查询当前属于group（消费者组）=simple-consumer-test的消费者的网络连接，nameserve地址为例 10.45.47.168:9876 sh mqadmin consumerConnection -n 10.45.47.168:9876 -g simple-consumer-test 打印内容: 001 10.45.46.229@simple-consumer-test-7babbb6021b040d29978494b16d559ae 10.45.46.229:4355 JAVA V3_0_7 Below is subscription: 001 Topic: ZTEExample SubExpression: * ConsumeType: CONSUME_ACTIVELY MessageModel: CLUSTERING ConsumeFromWhere: CONSUME_FROM_LAST_OFFSET