閱讀166 返回首頁    go 財經資訊


查詢指定發布信息__發布管理相關接口_Open API_消息隊列 MQ-阿裏雲

本文介紹 OnsPublishGet 接口,調用該接口查詢指定 PID 的詳細信息。

1. 使用場景

調用 OnsPublishGet 接口一般用於發布信息的展示和查詢。

2. 請求參數列表

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

3. 返回參數列表

名稱 類型 描述
RequestId String 為公共參數,每個請求獨一無二
HelpUrl String 幫助鏈接
Data List(PublishInfoDo) 查詢結果集合

PublishInfoDo 數據結構

成員 類型 描述
id Long 該發布信息在數據庫中的 ID
channelId Integer 該 Topic 所在區域 ID,0-ALIYUN,1-CLOUD,2,3,4
channelName String 該 Topic 所在區域名稱,ALIYUN 代表阿裏雲,CLOUD 代表聚石塔,…
onsRegionId Long 該 Topic 所在區域 ID,就是 ONSRegionList 方法獲取的內容
regionName String 該 Topic 所在區域名稱
topic String Topic 名稱
owner String Topic 所有者編號
relation Integer 所有關係編號1為持有者,2為可以發布,4為可以訂閱,6為可以發布和訂閱
relationName String 所有關係名稱,例如持有者、可訂閱、可發布、可發布訂閱
status Integer 當前狀態編號0—服務中
statusName String 當前狀態別名,服務中,
appkey Integer null
createTime Long 創建時間
updateTime Long 更新時間
remark String 備注,可以不填

4. 相關 API

  • OnsPublishDelete:刪除發布關係
  • OnsPublishList:獲取發布關係列表
  • OnsPublishCreate:新建發布關係

5. 使用示例

調用示例

以下示例用於查詢 daily 區域名為 PID_Mingduan 的 PID 信息,並打印主要屬性。

  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. OnsPublishGetRequest request = new OnsPublishGetRequest();
  19. /**
  20. *ONSRegionId是指你需要API訪問MQ哪個區域的資源.
  21. *該值必須要根據OnsRegionList方法獲取的列表來選擇和配置,因為OnsRegionId是變動的,不能夠寫固定值
  22. */
  23. request.setOnsRegionId("daily");
  24. request.setPreventCache(System.currentTimeMillis());
  25. request.setAcceptFormat(FormatType.JSON);
  26. request.setTopic("MingduanTest");
  27. request.setProducerId("PID_Mingduan");
  28. try {
  29. OnsPublishGetResponse response=iAcsClient.getAcsResponse(request);
  30. List<OnsPublishGetResponse.PublishInfoDo> publishInfoDoList =response.getData();
  31. for (OnsPublishGetResponse.PublishInfoDo publishInfoDo:publishInfoDoList){
  32. System.out.println(publishInfoDo.getId()+" "+
  33. publishInfoDo.getChannelId()+" "+
  34. publishInfoDo.getChannelName()+" "+
  35. publishInfoDo.getOnsRegionId()+" "+
  36. publishInfoDo.getRegionName()+" "+
  37. publishInfoDo.getOwner()+" "+
  38. publishInfoDo.getProducerId()+" "+
  39. publishInfoDo.getTopic()+" "+
  40. publishInfoDo.getStatus()+" "+
  41. publishInfoDo.getStatusName()+" "+
  42. publishInfoDo.getCreateTime()+" "+
  43. publishInfoDo.getUpdateTime());
  44. }
  45. } catch (ServerException e) {
  46. e.printStackTrace();
  47. } catch (ClientException e) {
  48. e.printStackTrace();
  49. }
  50. }

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

  上一篇:go 根據 Topic 查詢消息__消息管理相關接口_Open API_消息隊列 MQ-阿裏雲
  下一篇:go 獲取所有發布信息__發布管理相關接口_Open API_消息隊列 MQ-阿裏雲