627      英雄聯盟

查詢消費進度__消費管理相關接口_Open API_消息隊列 MQ-阿裏雲

本文介紹 OnsConsumerTimeSpan 接口，該接口提供查詢當前訂閱組訂閱的 Topic 的最新消息時間戳以及消費的最新時間戳。

1. 使用場景

使用本接口可以解決查詢某個 Topic 當前服務器上存在的消息的最新時間以及最早時間，以及查詢消費端最近消費的時間的需求。一般用於展示消費進度的概況，和 ConsumeAccumulate 接口配合使用。

2. 請求參數列表

3. 返回參數列表

Data 數據結構

4. 相關 API

• OnsConsumerAccumulate：查詢消費堆積
• OnsConsumerStatus：查詢消費端詳情
• OnsConsumerResetOffset：重置位點和清除消息

5. 使用示例

調用示例

   public static void main(String []args) {
          String regionId = "cn-hangzhou";
                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);
                  OnsConsumerTimeSpanRequest request = new OnsConsumerTimeSpanRequest();
                    /**
                    *ONSRegionId是指你需要API訪問MQ哪個區域的資源.
                    *該值必須要根據OnsRegionList方法獲取的列表來選擇和配置，因為OnsRegionId是變動的，不能夠寫固定值
                    */
                  request.setOnsRegionId("daily");
                  request.setPreventCache(System.currentTimeMillis());
                  request.setAcceptFormat(FormatType.JSON);
                  request.setConsumerId("CID_Mingduan");
                  request.setTopic("MingduanTest12");
                  try {
                      OnsConsumerTimeSpanResponse response=iAcsClient.getAcsResponse(request);
                      OnsConsumerTimeSpanResponse.Data data =response.getData();
                      System.out.println(data.getTopic()+"n"+
                      data.getConsumeTimeStamp()+"n"+
                      data.getMaxTimeStamp()+"n"+
                      data.getMinTimeStamp());
                  } catch (ServerException e) {
                      e.printStackTrace();
                  } catch (ClientException e) {
                      e.printStackTrace();
                  }
      }