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