1020      阿里云

搜索指定订阅信息__订阅管理相关接口_Open API_消息队列 MQ-阿里云

本文介绍 OnsSubscribeSearch 接口，调用该接口可以通过 Topic 或者 CID 信息搜索符合条件的 CID 信息。

1. 使用场景

OnsSubscribeSearch 接口一般用于不确定 CID 名称的时候，可以通过 Topic 来搜索 CID 信息。

2. 请求参数列表

3. 返回参数列表

SubscribeInfoDo 数据结构

4. 相关 API

• OnsSubcribeCreate：创建订阅关系
• OnsSubcribeDelete：删除订阅关系
• OnsSubscribeList：获取订阅关系列表

5. 使用示例

调用示例

本示例通过设定搜索条件 CID_Mingduan 来获取符合的 CID 信息，并打印。

 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);
         OnsSubscriptionSearchRequest request = new OnsSubscriptionSearchRequest();
            /**
            *ONSRegionId是指你需要API访问MQ哪个区域的资源.
            *该值必须要根据OnsRegionList方法获取的列表来选择和配置，因为OnsRegionId是变动的，不能够写固定值
            */
         request.setOnsRegionId("daily");
         request.setPreventCache(System.currentTimeMillis());
         request.setAcceptFormat(FormatType.JSON);
         request.setSearch("CID_Mingduan");
         try {
             OnsSubscriptionSearchResponse response=iAcsClient.getAcsResponse(request);
             List<OnsSubscriptionSearchResponse.SubscribeInfoDo> subscribeInfoDoList=response.getData();
             for(OnsSubscriptionSearchResponse.SubscribeInfoDo subscribeInfoDo:subscribeInfoDoList){
                 System.out.println(subscribeInfoDo.getId()+"  "+
                         subscribeInfoDo.getChannelId()+"  "+
                         subscribeInfoDo.getChannelName()+"  "+
                         subscribeInfoDo.getOnsRegionId()+"  "+
                         subscribeInfoDo.getRegionName()+"  "+
                         subscribeInfoDo.getOwner()+"  "+
                         subscribeInfoDo.getConsumerId()+"  "+
                         subscribeInfoDo.getTopic()+"  "+
                         subscribeInfoDo.getStatus()+"  "+
                         subscribeInfoDo.getStatusName()+" "+
                         subscribeInfoDo.getCreateTime()+"  "+
                         subscribeInfoDo.getUpdateTime());
             }
         } catch (ServerException e) {
             e.printStackTrace();
         } catch (ClientException e) {
             e.printStackTrace();
         }
     }