521      windows

查詢指定 Topic 狀態__Topic 相關接口_Open API_消息隊列 MQ-阿裏雲

查詢 Topic

本文介紹 OnsTopicGet 接口，用於查詢指定 Topic 的信息，屬於精確查詢。

1. 使用場景

查詢賬號下指定 Topic 的分布情況，並獲取 Topic 當前的開通狀態和權限關係等信息。由於是精確查詢，因此輸入參數必須包含 Topic 名稱。

2. 請求參數列表

3. 返回參數列表

PublishInfoDo 數據結構

4. 相關 API

• OnsTopicCreate：創建 Topic
• OnsTopicList：查看 Topic 列表
• OnsPublishDelete：刪除發布關係
• OnsSubscribeDelete：刪除訂閱關係

5. 使用示例

調用示例：

本示例僅僅提供一個參考，從華東1接入點接入，查詢名為”MingduanTest”的 Topic，並打印 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);
        OnsTopicGetRequest request = new OnsTopicGetRequest();
        request.setAcceptFormat(FormatType.JSON);
        request.setTopic("MingduanTest");
            /**
            *ONSRegionId是指需要API訪問MQ哪個區域的資源.
            *該值必須要根據OnsRegionList方法獲取的列表來選擇和配置，因為OnsRegionId是變動的，不能夠寫固定值
            */
        request.setOnsRegionId("daily");
        request.setPreventCache(System.currentTimeMillis());
        try {
            OnsTopicGetResponse response = IAcsClient.getAcsResponse(request);
            List<OnsTopicGetResponse.PublishInfoDo> publishInfoDoList=response.getData();
            for (OnsTopicGetResponse.PublishInfoDo publishInfoDo:publishInfoDoList){
                System.out.println(publishInfoDo.getId()+"  "+
                        publishInfoDo.getChannelId()+"  "+
                publishInfoDo.getChannelName()+"  "+
                publishInfoDo.getOnsRegionId()+"  "+
                publishInfoDo.getRegionName()+"  "+
                publishInfoDo.getTopic()+"  "+
                publishInfoDo.getOwner()+"  "+
                publishInfoDo.getRelation()+"  "+
                publishInfoDo.getRelationName()+"  "+
                publishInfoDo.getStatus()+"  "+
                publishInfoDo.getStatusName()+"  "+
                publishInfoDo.getAppkey()+"  "+
                publishInfoDo.getCreateTime()+"  "+
                publishInfoDo.getUpdateTime()+"  "+
                publishInfoDo.getRemark());
            }
            System.out.println(response.getRequestId());
        }
        catch (ServerException e) {
            e.printStackTrace();
        }
        catch (ClientException e) {
            e.printStackTrace();
        }
        catch (Exception e) {
            e.printStackTrace();
        }
    }