812      魔兽

创建授权__资源授权接口_Open API_消息队列 MQ-阿里云

本文介绍 OnsEmpowerCreate 接口，调用该接口可以将目标 Topic 授权给指定用户使用，包括发布消息和订阅消息的权限。

1. 使用场景

MQ 的 Topic 资源属于申请的 Owner 账号所有，当需要跨账号访问 Topic 资源时，Owner 账号可以使用授权接口对目标账号进行发布消息或者接收消息的权限授予。

授权注意事项:

• 授权可以支持三种权限：发布、订阅、发布&订阅。
• 发起授权的账号必须是资源的 Owner 账号，目标账号可以是子账号或者主账号。
• 授权后，目标账号仍然需要创建自己的订阅 CID，而不是使用 Owner 账号的 CID 来收消息。

2. 请求参数列表

3. 返回参数列表

4. 相关 API

• OnsEmpowerList：查看授权列表
• OnsEmpowerDelet：删除授权

5. 使用示例

调用示例

    public static void main(String []args) {
            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);
                    OnsEmpowerCreateRequest request = new OnsEmpowerCreateRequest();
                    request.setOnsRegionId("cn-qingdao-publictest");
                    request.setPreventCache(System.currentTimeMillis());
                    request.setAcceptFormat(FormatType.JSON);
                    request.setEmpowerUser("167535647680831312");
                    request.setTopic("topic_for_public_msg_test");
                    request.setRelation(2);
                    try {
                        OnsEmpowerCreateResponse response=iAcsClient.getAcsResponse(request);
                        System.out.println(response.getRequestId());
                    } catch (ServerException e) {
                        e.printStackTrace();
                    } catch (ClientException e) {
                        e.printStackTrace();
                    }
                }