898      阿裏雲  技術社區[雲棲]

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

本文介紹 OnsConsumerAccumulate 接口，用於查詢指定訂閱組的消費堆積情況，可以獲取到訂閱組當前未消費的消息數以及大概的延遲時間。

1. 使用場景

消費堆積查詢一般在生產環境中需要關注訂閱組消費進度時使用，用於粗略判斷消息消費情況和延遲情況。

2. 請求參數列表

3. 返回參數列表

Data 數據結構

DetailInTopicList 數據結構

4. 相關 API

• OnsConsumerStatus：消費者狀態詳情查詢
• OnsConsumerConnection：消費者連接查詢
• OnsResetOffset：消費清理堆積

5. 使用示例

調用示例

    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);
            OnsConsumerAccumulateRequest request = new OnsConsumerAccumulateRequest();
            //      request.setCluster("taobaodaily");
            /**
            *ONSRegionId是指你需要API訪問MQ哪個區域的資源.
            *該值必須要根據OnsRegionList方法獲取的列表來選擇和配置，因為OnsRegionId是變動的，不能夠寫固定值
            */
            request.setOnsRegionId("daily");
            request.setPreventCache(System.currentTimeMillis());
            request.setAcceptFormat(FormatType.JSON);
            request.setDetail(true);
            request.setConsumerId("RTDSQ_1013_GROUP");
            try {
                OnsConsumerAccumulateResponse response=iAcsClient.getAcsResponse(request);
                OnsConsumerAccumulateResponse.Data data =response.getData();
                System.out.println(data.getOnline()+"  "+data.getTotalDiff()+"  "+data.getConsumeTps()+"  "
                        +data.getDelayTime()+"  "+data.getLastTimestamp());
                for (OnsConsumerAccumulateResponse.Data.DetailInTopicDo detailInTopicDo:data.getDetailInTopicList()){
                    System.out.println(detailInTopicDo.getTopic()+"  "
                            +detailInTopicDo.getTotalDiff()+"  "
                            +detailInTopicDo.getLastTimestamp()+"  "+detailInTopicDo.getDelayTime());
                }
            } catch (ServerException e) {
                e.printStackTrace();
            } catch (ClientException e) {
                e.printStackTrace();
            }
        }