812      windows

創建授權__資源授權接口_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();
                    }
                }