558      微信

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

本文介绍 OnsPublishSearch 接口，调用该接口根据搜索条件查询相关的发布关系。

1. 使用场景

OnsPublishSearch 接口一般用在用户账号下 PID 太多无法同时展现时，根据关键字搜索符合条件的发布关系，展现的数据格式和 OnsPublishGet 接口一致。

2. 请求参数列表

3. 返回参数列表

PublishInfoDo数据结构

4. 相关 API

• OnsPublishDelete：删除发布关系
• OnsPublishGet：查询发布关系
• OnsPublishCreate：新建发布关系

5. 使用示例

调用示例

本示例以 PID_Mingduan 为搜索条件搜索 daily 区域下相关的 PID 信息，并将结果打印。

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