开发者社区> 问答> 正文

如何搜索指定 Topic 详细信息

OnsTopicSeacrh 接口用于根据搜索条件搜索指定账号下所有的 Topic 信息列表。

使用场景

该接口适用于查询 Topic 信息时没有精确的 Topic 名称的情况,一般用于获取整个 Topic 列表,在选择特定的 Topic 后基于 OnsTopicGet 接口精确查询。

请求参数列表

名称    类型    是否必须    描述
OnsRegionId    String    是    当前查询 MQ 所在区域,可以通过 ONSRegionList 方法获取,参见公共术语
OnsPlatform    String    否    该请求来源,默认是从 POP 平台
PreventCache    Long    是    用于 CSRF 校验,设置为系统当前时间即可
Search    String    是    输入的搜索条件,可以是 Topic 或者 appname 等字段
3. 返回参数列表

名称    类型    描述
RequestId    String    为公共参数,每个请求独一无二
HelpUrl    String    帮助链接
Data    List(PublishInfoDo)    返回所有已发布的 Topic 信息列表
PublishInfoDo 数据结构

成员    类型    描述
id    Long    该 Topic 信息编号
channelId    Integer    该 Topic 所在区域 ID,0代表阿里云,1代表聚石塔
channelName    String    该 Topic 所在区域名称,ALIYUN,CLOUD,…
onsRegionId    Long    该 Topic 所在区域 ID,就是 ONSRegionList 方法获取的内容
regionName    String    该 Topic 所在区域名称
topic    String    Topic 名称
owner    String    Topic 所有者编号,为阿里云的 uid
relation    Integer    所有关系编号1为持有者,2为可以发布,4为可以订阅,6为可以发布和订阅
relationName    String    所有关系名称,例如持有者、可订阅、可发布、可发布订阅
status    Integer    当前状态编号(0 服务中 1 冻结 2 暂停)
statusName    String    当前状态别名,服务中,
appkey    Integer    null
createTime    Long    创建时间
updateTime    Long    更新时间
remark    String    备注信息
4. 相关 API

OnsTopicCreate:创建 Topic
OnsTopicList:查看 Topic 列表
OnsPublishDelete:删除发布关系
OnsSubscribeDelete:删除订阅关系
5. 使用示例

本示例仅仅提供一个参考,从华东1接入点接入,查询当前用户下所有的 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);
        OnsTopicSearchRequest request = new OnsTopicSearchRequest();
        request.setAcceptFormat(FormatType.JSON);
            /**
            *ONSRegionId是指你需要API访问MQ哪个区域的资源.
            *该值必须要根据OnsRegionList方法获取的列表来选择和配置,因为OnsRegionId是变动的,不能够写固定值
            */
        request.setOnsRegionId("daily");
        request.setPreventCache(System.currentTimeMillis());
        request.setSearch("JODIE_TEST_28dd");
        try {
            OnsTopicSearchResponse response = IAcsClient.getAcsResponse(request);
            List<OnsTopicSearchResponse.PublishInfoDo> publishInfoDoList=response.getData();
            for(OnsTopicSearchResponse.PublishInfoDo publishInfoDo:publishInfoDoList){
                System.out.println(publishInfoDo.getTopic()+"    "+publishInfoDo.getOwner());
            }
            System.out.println(response.getRequestId());
        } catch (ClientException e) {
            e.printStackTrace();
        }
        catch (Exception e) {
            e.printStackTrace();
        }
    }

展开
收起
猫饭先生 2017-10-27 13:31:03 2444 0
0 条回答
写回答
取消 提交回答
问答分类:
问答地址:
问答排行榜
最热
最新

相关电子书

更多
《开放搜索查询分析服务架构分享》 立即下载
JCLI使用说明文档 立即下载
阿里云搜索产品年度升级发布 立即下载