閱讀154 返回首頁    go windows


獲取所有訂閱信息__訂閱管理相關接口_Open API_消息隊列 MQ-阿裏雲

本文介紹 OnsSubscribeList 接口,調用該接口將獲取用戶所有的 CID 信息的列表。

1. 使用場景

OnsSubscribeList 接口一般用於用戶 CID 資源的列表展示,並不用於具體的信息查詢。

2. 請求參數列表

名稱 類型 是否必須 描述
OnsRegionId String 當前查詢 MQ 所在區域,可以通過 OnsRegionList 方法獲取
OnsPlatform String 該請求來源,默認是從 POP 平台
PreventCache Long 用於 CSRF 校驗,設置為係統當前時間即可

3. 返回參數列表

名稱 類型 描述
RequestId String 為公共參數,每個請求獨一無二
HelpUrl String 幫助鏈接
Data List(SubscribeInfoDo) 查詢到的訂閱關係集合

SubscribeInfoDo 數據結構

名稱 類型 描述
Id Long 訂閱信息在數據庫中的索引編號
channelId Integer 該 Topic 所在區域 ID,0-ALIYUN,1-CLOUD,2,3,4
channelName String 該 Topic 所在區域名稱,ALIYUN 代表阿裏雲,CLOUD 代表聚石塔,…
onsRegionId Long 該 Topic 所在區域 ID,就是 ONSRegionList 方法獲取的內容
regionName String 該 Topic 所在區域名稱
Owner String 該發布信息的擁有者
ConsumerId String 消費集群 ID
Topic String Topic 名稱
Status Long 當前狀態
StatusName String 狀態名稱,服務中,已下線等
CreateTime Long 創建時間
UpdateTime Long 最後更新時間

4. 相關 API

  • OnsSubcribeCreate:創建訂閱關係
  • OnsSubcribeDelete:刪除訂閱關係
  • OnsSubscribeGet:訂閱關係精確查詢

5. 使用示例

調用示例

本示例查詢 daily 區域下所有的 CID 列表,並打印。

  1. public static void main(String []args) {
  2. String regionId = "cn-hangzhou";
  3. String accessKey = "XXXXXXXXXXXXXXXXX";
  4. String secretKey = "XXXXXXXXXXXXXXXXX";
  5. String endPointName ="cn-hangzhou";
  6. String productName ="Ons";
  7. String domain ="ons.cn-hangzhou.aliyuncs.com";
  8. /**
  9. *根據自己需要訪問的區域選擇Region,並設置對應的接入點
  10. */
  11. try {
  12. DefaultProfile.addEndpoint(endPointName,regionId,productName,domain);
  13. } catch (ClientException e) {
  14. e.printStackTrace();
  15. }
  16. IClientProfile profile= DefaultProfile.getProfile(regionId,accessKey,secretKey);
  17. IAcsClient iAcsClient= new DefaultAcsClient(profile);
  18. OnsSubscriptionListRequest request = new OnsSubscriptionListRequest();
  19. /**
  20. *ONSRegionId是指你需要API訪問MQ哪個區域的資源.
  21. *該值必須要根據OnsRegionList方法獲取的列表來選擇和配置,因為OnsRegionId是變動的,不能夠寫固定值
  22. */
  23. request.setOnsRegionId("daily");
  24. request.setPreventCache(System.currentTimeMillis());
  25. request.setAcceptFormat(FormatType.JSON);
  26. try {
  27. OnsSubscriptionListResponse response=iAcsClient.getAcsResponse(request);
  28. List<OnsSubscriptionListResponse.SubscribeInfoDo> subscribeInfoDoList=response.getData();
  29. for(OnsSubscriptionListResponse.SubscribeInfoDo subscribeInfoDo:subscribeInfoDoList){
  30. System.out.println(subscribeInfoDo.getId()+" "+
  31. subscribeInfoDo.getChannelId()+" "+
  32. subscribeInfoDo.getChannelName()+" "+
  33. subscribeInfoDo.getOnsRegionId()+" "+
  34. subscribeInfoDo.getRegionName()+" "+
  35. subscribeInfoDo.getOwner()+" "+
  36. subscribeInfoDo.getConsumerId()+" "+
  37. subscribeInfoDo.getTopic()+" "+
  38. subscribeInfoDo.getStatus()+" "+
  39. subscribeInfoDo.getStatusName()+" "+
  40. subscribeInfoDo.getCreateTime()+" "+
  41. subscribeInfoDo.getUpdateTime());
  42. }
  43. } catch (ServerException e) {
  44. e.printStackTrace();
  45. } catch (ClientException e) {
  46. e.printStackTrace();
  47. }
  48. }

最後更新:2016-11-23 18:56:25

  上一篇:go 查詢指定訂閱信息__訂閱管理相關接口_Open API_消息隊列 MQ-阿裏雲
  下一篇:go 搜索指定訂閱信息__訂閱管理相關接口_Open API_消息隊列 MQ-阿裏雲