消息軌跡
在分布式應(yīng)用中，云消息隊(duì)列 RocketMQ 版作為全鏈路中異步解耦的關(guān)鍵服務(wù)，提供的消息軌跡數(shù)據(jù)可有效將業(yè)務(wù)上下游信息串聯(lián)起來，幫助您更好地排查異常信息，定位問題。本文介紹消息軌跡的使用場(chǎng)景、云消息隊(duì)列 RocketMQ 版定義的軌跡參數(shù)以及如何查看消息軌跡。
使用場(chǎng)景
云消息隊(duì)列 RocketMQ 版將消息收發(fā)流程中的關(guān)鍵數(shù)據(jù)定義為軌跡參數(shù)，并支持可視化查詢，通過查看軌跡信息可快速獲取當(dāng)前業(yè)務(wù)處理的狀態(tài)，幫助您快速定位異常問題。
消息軌跡的典型應(yīng)用場(chǎng)景如下：
場(chǎng)景一：查看某條消息是否發(fā)送成功或是否消費(fèi)成功。
場(chǎng)景二：查看定時(shí)/延時(shí)消息是否已定時(shí)結(jié)束。
場(chǎng)景三：查看事務(wù)消息是否已提交或回滾。
場(chǎng)景四：查看生產(chǎn)者、消費(fèi)者身份信息和機(jī)器信息，進(jìn)一步排查問題原因。
軌跡參數(shù)說明
云消息隊(duì)列 RocketMQ 版提供的軌跡參數(shù)如下：
屬性分類 | 軌跡參數(shù) | 說明 |
生產(chǎn)者 | 生產(chǎn)者信息 | 生產(chǎn)者發(fā)送消息時(shí)使用的RocketMQ賬號(hào)或Access Key ID。 |
主機(jī)名 | 生產(chǎn)者客戶端所在機(jī)器的主機(jī)名稱。 | |
發(fā)送時(shí)間 | 生產(chǎn)者發(fā)送消息的起始時(shí)間。 | |
到達(dá)Server時(shí)間 | 消息到達(dá)并存儲(chǔ)到云消息隊(duì)列 RocketMQ 版服務(wù)端的時(shí)間。 | |
發(fā)送結(jié)果 | 消息發(fā)送的結(jié)果。取值如下：
| |
消息基礎(chǔ)信息 | 消息類型 | |
消息ID | 消息的全局唯一標(biāo)識(shí)，由云消息隊(duì)列 RocketMQ 版系統(tǒng)自動(dòng)生成。 | |
Topic | 消息所屬的主題名稱。 | |
消息Keys | MessageKey，消息的業(yè)務(wù)標(biāo)識(shí)，由消息生產(chǎn)者設(shè)置，唯一標(biāo)識(shí)某個(gè)業(yè)務(wù)邏輯。 | |
消息Tag | 消息標(biāo)簽，用于區(qū)分指定主題下的消費(fèi)分類。 | |
順序消息 | MessageGroup | 順序消息中，消息所屬的MessageGroup，由生產(chǎn)者設(shè)置。同一MessageGroup的消息將遵循先進(jìn)先出的順序關(guān)系進(jìn)行處理。 |
事務(wù)消息 | Check回調(diào)時(shí)間 | 半事務(wù)消息檢查事務(wù)狀態(tài)的回調(diào)時(shí)間。 |
提交時(shí)間 | 事務(wù)消息被服務(wù)端提交給消費(fèi)者消費(fèi)的時(shí)間。 | |
回滾時(shí)間 | 事務(wù)消息回滾的時(shí)間。 | |
定時(shí)消息 | 預(yù)設(shè)定時(shí)時(shí)間 | 定時(shí)消息的定時(shí)時(shí)間。 |
消費(fèi)者 | 本次消費(fèi)結(jié)果 | 消息某次消費(fèi)的消費(fèi)結(jié)果。取值如下：
|
消費(fèi)者信息 | 消費(fèi)者訂閱消息時(shí)使用的RocketMQ賬號(hào)或AccessKey ID。 | |
主機(jī)名 | 消費(fèi)者客戶端所在機(jī)器的主機(jī)名。 | |
是否順序投遞 | 消費(fèi)者所屬的消費(fèi)者分組是否開啟順序消費(fèi)。 | |
投遞時(shí)間 | 云消息隊(duì)列 RocketMQ 版服務(wù)端將消息投遞給消費(fèi)者的時(shí)間。 | |
應(yīng)答時(shí)間 | 云消息隊(duì)列 RocketMQ 版收到消費(fèi)者返回的消費(fèi)結(jié)果的時(shí)間。 | |
invisibleDuration | SimpleConsumer傳入的消息不可見時(shí)間。更多信息，請(qǐng)參見SimpleConsumer消費(fèi)重試策略。 | |
修改不可見時(shí)間 | SimpleConsumer調(diào)用ChangeInvisibleDuration接口的時(shí)間。 | |
進(jìn)死信時(shí)間 | 消息消費(fèi)失敗被投遞至死信隊(duì)列的時(shí)間。 |
使用限制
RocketMQ 4.x/3.x版本的SDK客戶端默認(rèn)不開啟消息軌跡功能，您需要在消息收發(fā)代碼中開啟消息軌跡功能，才能在控制臺(tái)查詢到消息的軌跡信息。具體配置如下：
生產(chǎn)者
producer.setAccessChannel(AccessChannel.CLOUD);消費(fèi)者
consumer.setAccessChannel(AccessChannel.CLOUD);
計(jì)費(fèi)說明
包年包月和按量付費(fèi)實(shí)例可免費(fèi)使用消息軌跡功能且默認(rèn)支持消息軌跡。
Serverless實(shí)例可選擇手動(dòng)開啟或關(guān)閉消息軌跡功能，具體操作，請(qǐng)參見開啟/關(guān)閉Serverless實(shí)例的消息軌跡功能。
若開啟消息軌跡，則Serverless實(shí)例按照實(shí)際產(chǎn)生的消息軌跡條數(shù)計(jì)算消息軌跡費(fèi)用，具體計(jì)費(fèi)規(guī)則，請(qǐng)參見消息軌跡費(fèi)用。
消息軌跡存儲(chǔ)時(shí)長(zhǎng)
包年包月和按量付費(fèi)實(shí)例的消息軌跡保存時(shí)間為3天。
Serverless實(shí)例的消息軌跡保存時(shí)間為14天。
消息軌跡查詢方式
云消息隊(duì)列 RocketMQ 版支持以下查詢方式：
按Message ID查詢：該方式屬于精確查詢，速度快、精確匹配，推薦使用。
按Message Key查詢：該方式屬于模糊查詢，最多查詢1000條軌跡。僅適用于您沒有記錄Message ID但是設(shè)置了Message Key，同時(shí)Message Key具有區(qū)分度的情況。
按Topic查詢：該方式屬于范圍查詢，適用于沒有上述Message ID和Message Key，而且消息量比較小的場(chǎng)景。因?yàn)闀r(shí)間范圍內(nèi)消息很多，且不具備區(qū)分度，所以不推薦使用。
開啟/關(guān)閉Serverless實(shí)例的消息軌跡功能
關(guān)閉消息軌跡功能，Serverless實(shí)例的消息軌跡數(shù)據(jù)將不支持存儲(chǔ)和查詢，且控制臺(tái)不顯示消息軌跡的查詢?nèi)肟凇?/p>
開啟消息軌跡功能，Serverless實(shí)例將產(chǎn)生消息軌跡費(fèi)用，具體計(jì)費(fèi)項(xiàng)，請(qǐng)參見消息軌跡費(fèi)用。
登錄云消息隊(duì)列 RocketMQ 版控制臺(tái)，在左側(cè)導(dǎo)航欄單擊實(shí)例列表。
在頂部菜單欄選擇地域，如華東1（杭州），然后在實(shí)例列表中，單擊目標(biāo)實(shí)例名稱。
在實(shí)例詳情頁(yè)面單擊基本信息頁(yè)簽，在消息軌跡參數(shù)后單擊開啟或關(guān)閉。
在彈出的對(duì)話框中單擊確定。
查詢消息軌跡
登錄云消息隊(duì)列 RocketMQ 版控制臺(tái)，在左側(cè)導(dǎo)航欄單擊實(shí)例列表。
在頂部菜單欄選擇地域，如華東1（杭州），然后在實(shí)例列表中，單擊目標(biāo)實(shí)例名稱。
在左側(cè)導(dǎo)航欄單擊消息軌跡，然后在消息軌跡頁(yè)面選擇任一查詢方式創(chuàng)建查詢?nèi)蝿?wù)。
根據(jù)任務(wù)結(jié)果查看詳細(xì)消息軌跡信息。