OnsMessagePageQueryByTopic_消息查询_管控 API 参考

使用 OnsMessagePageQueryByTopic 通过传入 Topic 名称和时间段，分页查询指定时间段内该 Topic 内存在的所有消息。

描述

按 Topic 查询消息的方式属于范围查询，查询结果会通过分页的方式展示给调用方，仅适用于没有任何搜索条件（Message ID 和 Message Key）查询场景。需注意的是，根据 Topic 查询消息应尽可能缩短查询的时间区间，否则匹配的消息过多，将无法定位问题。

调用流程如下所示：

传入 Topic、起止时间以及每页的大小，进行分页查询。如果有消息，默认返回第一页的消息、总页数和查询任务 ID。
根据返回的结果中的查询任务 ID，进行后续取消息，取消息时传入查询任务 ID 以及当前页数。

请求参数列表

名称	类型	是否必需	描述
PreventCache	Long	是	用于 CSRF 校验，设置为系统当前时间即可，单位毫秒（ms）
InstanceId	String	是	需查询的消息所对应的实例 ID
Topic	String	是	需查询的消息的 Topic 名称
BeginTime	Long	是	查询范围的起始时间戳
EndTime	Long	是	查询范围的终止时间戳
TaskId	String	否	查询任务的 ID，首次查询不需要输入，后续取消息必须传入，根据前一次的返回结果取出该字段
CurrentPage	Integer	是	当前取第几页消息，从 1 开始递增，最大值为 50，取消息时不可超过最大页数
PageSize	Integer	否	分页查询，每页最多显示消息数量，默认是 20，最小 5 条，最多 50 条

返回参数列表

名称	类型	描述
RequestId	String	为公共参数，每个请求的 ID 都是唯一的
HelpUrl	String	帮助链接
MsgFoundDo	MsgFoundDo	查询结果

MsgFoundDo 数据结构列表

名称	类型	描述
TaskId	String	第一次新建查询时，返回的查询任务 ID，用于后续取消息
MaxPageCount	Long	查询结果最大页数
CurrentPage	Long	当前位于第几页
Data	List(OnsRestMessageDo)	当前页的消息集合，该类型与 messageGetById 的返回结果一致

使用示例

新建查询调用示例


   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();
           request.setPreventCache(System.currentTimeMillis());
           request.setInstanceId("XXXXX");
           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();
           request.setPreventCache(System.currentTimeMillis());
           request.setInstanceId("XXXXXXX");
           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();
               }
       }