128      阿裏雲

根據 MsgID 查詢消息__消息管理相關接口_Open API_消息隊列 MQ-阿裏雲

本文介紹 OnsMessageGetByMsgId 接口，該接口通過傳入 MsgId 查詢指定消息的信息，包括發送時間，存儲服務器，消息的 Key 和 Tag 等熟悉，以及是否被消費過的判斷。

1. 使用場景

消息查詢功能用於判斷消息是否發送成功，發送時間以及目標服務器等信息。

根據 MsgId 查詢消息屬於精確查詢，查詢條件需要的 MsgId 由每次發送成功的 SendResult 中獲取，因此業務方必須存儲每次發送消息的結果。

2. 請求參數列表

3. 返回參數列表

Data 數據結構

4. 相關 API

• OnsMessageGetByMsgKey：根據 MsgKey 模煳匹配查詢消息
• OnsMessageGetByTopic：根據 Topic 和時間範圍查詢消息

5. 使用示例

調用示例

   public static void main(String []args) {
            String regionId = "cn-hangzhou";
            String accessKey = "XXXXXXXXXXXXXXXXX";
            String secretKey = "XXXXXXXXXXXXXXXXX";
            String endPointName ="cn-hangzhou";
            String productName ="Ons";
            String domain ="ons.cn-hangzhou.aliyuncs.com";
            /**
            *根據自己需要訪問的區域選擇Region，並設置對應的接入點
            */
            try {
                DefaultProfile.addEndpoint(endPointName，regionId，productName，domain);
            } catch (ClientException e) {
                e.printStackTrace();
            }
            IClientProfile profile= DefaultProfile.getProfile(regionId，accessKey，secretKey);
            IAcsClient iAcsClient= new DefaultAcsClient(profile);
           OnsMessageGetByMsgIdRequest request = new OnsMessageGetByMsgIdRequest();
            /**
            *ONSRegionId是指你需要API訪問MQ哪個區域的資源.
            *該值必須要根據OnsRegionList方法獲取的列表來選擇和配置，因為OnsRegionId是變動的，不能夠寫固定值
            */
           request.setOnsRegionId("daily");
           request.setPreventCache(System.currentTimeMillis());
           request.setAcceptFormat(FormatType.JSON);
           request.setMsgId("0ADA91A600002A9F000002ADDA8137E8");
           request.setTopic("TopicTest");
           try {
               OnsMessageGetByMsgIdResponse response = iAcsClient.getAcsResponse(request);
               OnsMessageGetByMsgIdResponse.Data data =response.getData();
               byte[] msgbody= Base64.decode(data.getBody());
               String message= new String(msgbody);
               System.out.println(data.getTopic()+"  "+
                       message+"  "+
                       data.getFlag()+" "+
                       data.getBornHost()+"  "+
                       data.getStoreSize()+"  "+
                       data.getStoreHost()+"  "+
                       data.getStoreTimestamp()+" “+
                       data.getReconsumeTimes());
           } catch (ServerException e) {
               e.printStackTrace();
           } catch (ClientException e) {
               e.printStackTrace();
           }
       }