367      阿裏雲

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

本文檔介紹 OnsMessageTrack 接口，該接口用於判斷目標 MsgId 對應的消息是否已經消費過。

1. 使用場景

MessageTrack 接口一般用於判斷指定的消息是否曾經被消費過，查詢條件為單條消息的 MsgId。需要注意的是 MessagTrack 的實現基於 MQ 的內部位點機製，在大部分場景下判斷結果可信，但如果應用方進行過重置位點已經清除消息等操作，則判斷結果可能有誤。

2. 請求參數列表

3. 返回參數列表

MessageTrack 數據結構

4. 相關 API

• OnsMessageGetByMsgId：根據 MsgId 精確查詢消息

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);
           OnsMessageTraceRequest request = new OnsMessageTraceRequest();
            /**
            *ONSRegionId是指你需要API訪問MQ哪個區域的資源.
            *該值必須要根據OnsRegionList方法獲取的列表來選擇和配置，因為OnsRegionId是變動的，不能夠寫固定值
            */
           request.setOnsRegionId("daily");
           request.setPreventCache(System.currentTimeMillis());
           request.setAcceptFormat(FormatType.JSON);
           request.setTopic("MingduanTest");
           request.setMsgId("0A91883700001F90000001BF4723CB3E");
           try {
               OnsMessageTraceResponse response=iAcsClient.getAcsResponse(request);
               List<OnsMessageTraceResponse.MessageTrack> trackList =response.getData();
               for (OnsMessageTraceResponse.MessageTrack track:trackList){
                   System.out.println(track.getConsumerGroup()+"  "+track.getTrackType()+"  "+track.getExceptionDesc());
               }
           } catch (ServerException e) {
               e.printStackTrace();
           } catch (ClientException e) {
               e.printStackTrace();
           }
       }