创建 Topic

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

描述

Topic 创建接口一般是在有新的 Topic 需求的情况下调用，例如发布新应用，业务逻辑需要新的 Topic。

Topic 为全局唯一，不可重复创建，否则会创建失败，需要根据错误码进行处理。

主子帐号约束

本接口默认仅限主账号使用，RAM 子账号无法使用，除非该 RAM 子账号被授予了相关权限。

请求参数

返回参数

相关 API

• OnsTopicDelete：删除 Topic
• OnsTopicList：查看 Topic 列表
• OnsPublishCreate：在创建 Topic 之后一般需要创建发布关系
• OnsSubscribeCreate：在创建 Topic 之后一般需要创建订阅关系

使用示例

本示例仅仅提供一个参考，从华东1接入点接入，创建名为“XXX”的 Topic，创建到 daily 区域。

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