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();
               }
       }