如何创建订阅信息

本接口限企业铂金版客户专用，请前往铂金版购买页面查看详情。

描述

OnsSubscribeCreate 接口用于在服务器上创建对特定 Topic 的订阅关系。

使用场景

新应用上线时，在注册 Topic 资源后，如果需要订阅消息，需要首先在 MQ 控制台或者调用该 API 申请注册对目标 Topic 的注册关系，然后才能使用注册的 CID 订阅消息。

请求参数

名称    类型    是否必须    描述
OnsRegionId    String    是    当前查询 MQ 所在区域，可以通过 OnsRegionList 方法获取
OnsPlatform    String    否    该请求来源，默认是从 POP 平台
PreventCache    Long    是    用于 CSRF 校验，设置为系统当前时间即可
ConsumerId    String    是    创建的消息消费集群的 CID
Topic    String    是    订阅的 Topic
返回参数

名称    类型    描述
RequestId    String    为公共参数，每个请求独一无二
HelpUrl    String    帮助链接
相关 API

OnsSubscribeDelete：删除订阅关系
OnsSubscribeList：查询订阅关系列表
OnsSubscribeGet：精确查询订阅关系信息
使用示例

本示例在 daily 区域创建名为 CID_MingduanTest 的订阅关系用于消费 Mingduan_67dd 的消息。

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);
          OnsSubscriptionCreateRequest request = new OnsSubscriptionCreateRequest();
            /**
            *ONSRegionId是指你需要API访问ONS哪个区域的资源
            *该值必须要根据OnsRegionList方法获取的列表来选择和配置，因为OnsRegionId是变动的，不能够写固定值
            */
          request.setOnsRegionId("daily");
          request.setPreventCache(System.currentTimeMillis());
          request.setAcceptFormat(FormatType.JSON);
          request.setTopic("Mingduan_67dd");
          request.setConsumerId("CID_MingduanTest");
          try {
              OnsSubscriptionCreateResponse response=iAcsClient.getAcsResponse(request);
              System.out.println(response.getRequestId());
          } catch (ServerException e) {
              e.printStackTrace();
          } catch (ClientException e) {
              e.printStackTrace();
          }
      }