615      英雄联盟

查询 Topic 当前位点__Topic 相关接口_Open API_消息队列 MQ-阿里云

本文介绍 OnsTopicStatus 接口，调用该接口可以查询指定 Topic 当前的消息状态。

1. 使用场景

查询当前 Topic 下的消息总量以及最后更新时间，一般用于判断 Topic 资源的使用率。TopicStatus 接口返回当前服务器上该 Topic 下所有的消息数，以及最后消息写入时间。

2. 请求参数列表

3. 返回参数列表

OnsTopicStatusResponse.Data 数据结构

4. 相关 API

• OnsTopicCreate：创建 Topic
• OnsConsumerStatus：查询订阅组的消费者状态

5. 使用示例

调用示例:

本示例仅仅提供一个参考，从华东1接入点接入，查询当前用户下名为”JODIE_TEST_27dd”的 Topic 的消息数量。

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);
        OnsTopicStatusRequest request = new OnsTopicStatusRequest();
        request.setAcceptFormat(FormatType.JSON);
            /**
            *ONSRegionId是指你需要API访问MQ哪个区域的资源.
            *该值必须要根据OnsRegionList方法获取的列表来选择和配置，因为OnsRegionId是变动的，不能够写固定值
            */
        request.setOnsRegionId("daily");
        request.setPreventCache(System.currentTimeMillis());
        request.setTopic("JODIE_TEST_27dd");
        try {
            OnsTopicStatusResponse response = iAcsClient.getAcsResponse(request);
            OnsTopicStatusResponse.Data data=response.getData();
            Long totalCount =data.getTotalCount();
            Long lastTimeStamp =data.getLastTimeStamp();
            System.out.println(response.getRequestId());
        } catch (ClientException e) {
            e.printStackTrace();
        }
        catch (Exception e) {
            e.printStackTrace();
        }
    }