97      阿裏雲  技術社區[雲棲]

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

本文介紹 OnsMessagePageQueryByTopic 接口，該接口通過傳入 Topic 和時間段，分頁查詢指定時間段內存在的所有消息。

1. 使用場景

根據 Topic 查詢消息屬於範圍查詢，查詢結果會通過分頁的方式展示給調用方，僅適用於沒有任何搜索條件(MsgId 和 MsgKey)情況下的查詢。

注意：根據 Topic 查詢，需要盡可能縮短查詢的時間區間，否則匹配的消息過多，將無法定位問題。

2. 調用方式

• 首先，傳入 Topic，起止時間，以及每頁的大小，進行分頁查詢，如果有消息，默認返回第一頁的消息以及總頁數和查詢 Task ID。
• 根據返回的結果中的查詢 Task ID，進行後續取消息，取消息時傳入 Task ID 以及當前頁數。

3. 請求參數列表

4. 返回參數列表

MsgFoundDo 數據結構

5. 相關 API

• OnsMessageGetByMsgId：根據 MsgId 精確查詢消息
• OnsMessageGetByMsgKey：根據 MsgKey 模煳查詢消息

6. 使用示例

新建查詢調用示例

   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);
           OnsMessagePageQueryByTopicRequest request = new OnsMessagePageQueryByTopicRequest();
            /**
            *ONSRegionId是指你需要API訪問MQ哪個區域的資源.
            *該值必須要根據OnsRegionList方法獲取的列表來選擇和配置，因為OnsRegionId是變動的，不能夠寫固定值
            */
           request.setOnsRegionId("daily");
           request.setPreventCache(System.currentTimeMillis());
           request.setAcceptFormat(FormatType.JSON);
           request.setTopic("MingduanTest");
           request.setBeginTime(System.currentTimeMillis()-24*3600*1000);
           request.setEndTime(System.currentTimeMillis());
           request.setCurrentPage(1);
           request.setPageSize(20);
           try {
                   OnsMessagePageQueryByTopicResponse response = iAcsClient.getAcsResponse(request);
               } catch (ServerException e) {
                   e.printStackTrace();
               } catch (ClientException e) {
                   e.printStackTrace();
               }
       }

   public static void main(String []args) {
           String regionId = "cn-hangzhou";
           String accessKey = "XXXXX";
           String secretKey = "XXXXX";
           IClientProfile profile = DefaultProfile.getProfile(regionId， accessKey， secretKey);
           IAcsClient iAcsClient = new DefaultAcsClient(profile);
           OnsMessagePageQueryByTopicRequest request = new OnsMessagePageQueryByTopicRequest();
            /**
            *ONSRegionId是指你需要API訪問MQ哪個區域的資源.
            *該值必須要根據OnsRegionList方法獲取的列表來選擇和配置，因為OnsRegionId是變動的，不能夠寫固定值
            */
           request.setOnsRegionId("daily");
           request.setPreventCache(System.currentTimeMillis());
           request.setAcceptFormat(FormatType.JSON);
           request.setTopic("MingduanTest");
           request.setBeginTime(System.currentTimeMillis()-24*3600*1000);
           request.setEndTime(System.currentTimeMillis());
           request.setCurrentPage(3);
           request.setTaskId("0ADA91A600002A9F000002ADDA8137E8");
           try {
                   OnsMessagePageQueryByTopicResponse response = iAcsClient.getAcsResponse(request);
               } catch (ServerException e) {
                   e.printStackTrace();
               } catch (ClientException e) {
                   e.printStackTrace();
               }
       }