943      敦煌網

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

本文檔介紹 OnsMessageGetByMsgKey 接口，該接口通過傳入 Topic 和 MsgKey 進行模煳查詢，得到符合條件的消息的信息列表。

1. 使用場景

根據 MsgKey 查詢消息屬於模煳查詢，由於業務方的 key 可能不唯一，所以查詢結果可能為多條。一般用在業務方無法獲取 MsgId 的場景下，先進行模煳查詢得到 msgId 列表，再調用 OnsMessageGetByMsgId 接口查詢。

2. 請求參數列表

3. 返回參數列表

OnsRestMessageDo 數據結構

4. 相關 API

• OnsMesageGetByMsgId：根據 MsgId 精確查詢消息
• 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);
           OnsMessageGetByKeyRequest request = new OnsMessageGetByKeyRequest();
            /**
            *ONSRegionId是指你需要API訪問MQ哪個區域的資源.
            *該值必須要根據OnsRegionList方法獲取的列表來選擇和配置，因為OnsRegionId是變動的，不能夠寫固定值
            */
           request.setOnsRegionId("daily");
           request.setPreventCache(System.currentTimeMillis());
           request.setAcceptFormat(FormatType.JSON);
           request.setTopic("MingduanTest");
           request.setKey("hello");
           try {
               OnsMessageGetByKeyResponse response = iAcsClient.getAcsResponse(request);
               List<OnsMessageGetByKeyResponse.OnsRestMessageDo> onsRestMessageDoList=response.getData();
               for(OnsMessageGetByKeyResponse.OnsRestMessageDo onsRestMessageDo:onsRestMessageDoList){
                   byte[] messageBody = Base64.decode(onsRestMessageDo.getBody());
                   String message =new String (messageBody);
                   System.out.println(onsRestMessageDo.getTopic()+"  "+message+"  "+
                   onsRestMessageDo.getFlag()+" "+
                   onsRestMessageDo.getBornHost()+"  "+
                   onsRestMessageDo.getStoreSize()+"  "+
                   onsRestMessageDo.getStoreHost()+"  "+
                   onsRestMessageDo.getStoreTimestamp()+"  "+
                   onsRestMessageDo.getReconsumeTimes());
               }
           } catch (ServerException e) {
               e.printStackTrace();
           } catch (ClientException e) {
               e.printStackTrace();
           }