<span style="font-family: Arial, Helvetica, sans-serif; background-color: rgb(255, 255, 255);">	</span><span style="font-family: Arial, Helvetica, sans-serif; background-color: rgb(255, 255, 255);">MQ相關介紹：http://blog.csdn.net/luckyzhoustar/article/details/51286554</span>

RocketMq是一個純

Java、分散式、佇列模型的的開源的訊息中介軟體，但是目前相關的資料較少，所以出現了問題很難找到解決方案。

1、MQ 訊息生產：http://blog.csdn.net/luckyzhoustar/article/details/51286559

2、MQ 訊息訂閱：http://blog.csdn.net/luckyzhoustar/article/details/51286560

在使用過程中，需要用查詢生產的訊息，可以根據Key和Id查詢訊息。

一、根據key查詢訊息

1、運維命令    

文件：

指令	queryMsgByKey		類路徑	com.alibaba.rocketmq.tools.command.message.QueryMsgByKeySubCommand
引數			是否必填		說明
-f			否		被查詢訊息的截止時間
-k			是		msgKey
-t			是		Topic名稱
-h			否		列印幫助
-n			是		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

2、例項：

sh mqadmin queryMsgByKey -n 10.10.4.184:9876 -t SCANRECORD -k b4d83f23-36fe-4890-946c-a2dcccc67572

3、結果：

Java HotSpot(TM) 64-Bit Server VM warning: ignoring option PermSize=128m; support was removed in 8.0
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=128m; support was removed in 8.0
#Message ID                                        #QID                                  #Offset
0A0A04B800002A9F0000005C597BACE1                      1                                 66788391

可以得到訊息的這個key下面所有的msgId，然後可以通過查詢到的id在定位到具體訊息

二、根據msgId查詢訊息

1、文件：

指令	queryMsgById		類路徑	com.alibaba.rocketmq.tools.command.message.QueryMsgByIdSubCommand
引數			是否必填		說明
-i			是		msgId
-h			否		列印幫助
-n			是		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

2、例項：

[[email protected] bin]# sh mqadmin queryMsgById -n 10.10.4.184:9876 -i 0A0A04B800002A9F0000005C597BACE1

3、結果：

ava HotSpot(TM) 64-Bit Server VM warning: ignoring option PermSize=128m; support was removed in 8.0
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=128m; support was removed in 8.0
Topic:               SCANRECORD
Tags:                [1]
Keys:                [b4d83f23-36fe-4890-946c-a2dcccc67572]
Queue ID:            1
Queue Offset:        66788391
CommitLog Offset:    396638268641
Reconsume Times:     0
Born Timestamp:      2016-08-18 20:18:51,648
Store Timestamp:     2016-08-18 20:19:15,456
Born Host:           10.10.42.177:62899
Store Host:          10.10.4.184:10911
System Flag:         0
Properties:          {KEYS=b4d83f23-36fe-4890-946c-a2dcccc67572, WAIT=true, TAGS=1}
Message Body Path:   /tmp/rocketmq/msgbodys/0A0A04B800002A9F0000005C597BACE1



MessageTrack [consumerGroup=WOBUXINHAIYOU, trackType=UNKNOW_EXCEPTION, exceptionDesc=com.alibaba.rocketmq.client.exception.MQBrokerException: CODE: 206  DESC: the consumer group[WOBUXINHAIYOU] not online
For more information, please visit the url, https://github.com/alibaba/RocketMQ/issues/48, com.alibaba.rocketmq.client.impl.MQClientAPIImpl.getConsumerConnectionList(MQClientAPIImpl.java:1189)]

通過ID查詢到訊息，可以看到訊息的存放路徑，和該訊息的相關資訊，已經該訊息的消費狀態。

通過API 方式呼叫查詢訊息。通過此功能可以在原始碼的基礎上，自己封裝成頁面，查詢每條訊息的生命週期。

一、根據Key查詢訊息

DefaultMQProducer 類中有提供 queryMessage 方法，

 @Override
    public QueryResult queryMessage(String topic, String key, int maxNum, long begin, long end)
            throws MQClientException, InterruptedException {
        return this.defaultMQProducerImpl.queryMessage(topic, key, maxNum, begin, end);
    }

但是方法中需要的引數，maxNum，bengin，end 在沒有註釋的情況下，並不知道具體傳什麼引數，在閱讀原始碼後，

begin和end 需要的是時間戳格式，所以確認傳入的應該是查詢時間。同時通過key可以查詢多個msgId，maxNum應該的查詢個數。

	QueryResult res =mqProducerBiz.queryMessage(topic, key, 100, 

<span style="white-space:pre">		</span>(new Date().getTime()-(2*60*60*1000)),(new Date().getTime()+(2*60*60*1000)));

嘗試當前時間前後兩小時 該KEY下面的100條資料。

當時返回結果為null。失敗。。。。

github，oschina，官方文件在查詢無果之後，最後上了阿里雲，查詢和rocketMQ收費版的ONS文件，

在查詢訊息的文件中發現很重要的一句話

貼上原文地址：https://help.aliyun.com/document_detail/29540.html?spm=5176.doc29536.6.107.HVVHro

查詢數量不能超過64條，修改maxNum為10.

成功查詢到剛剛丟進去的訊息。。。

根據ID查詢相對簡單，

  @Override
    public MessageExt viewMessage(String msgId) throws RemotingException, MQBrokerException,
            InterruptedException, MQClientException {
        return this.defaultMQProducerImpl.viewMessage(msgId);
    }

呼叫此方法可以直接查詢到。。。