[發(fā)明專利]一種消息軌跡數(shù)據(jù)的處理方法、裝置及電子設(shè)備

在審

• 申請(qǐng)?zhí)枺?/td>: 201911045244.0
• 申請(qǐng)日: 2019-10-30
• 公開(kāi)（公告）號(hào): CN112751893A
• 公開(kāi)（公告）日: 2021-05-04
• 發(fā)明（設(shè)計(jì)）人: 胡宗棠
• 申請(qǐng)（專利權(quán)）人: 中移(蘇州)軟件技術(shù)有限公司;中國(guó)移動(dòng)通信集團(tuán)有限公司
• 主分類號(hào): H04L29/08
• 分類號(hào): H04L29/08
• 代理公司: 北京派特恩知識(shí)產(chǎn)權(quán)代理有限公司 11270
• 代理人: 劉戀;張穎玲

本申請(qǐng)公開(kāi)了一種消息軌跡數(shù)據(jù)的處理方法、裝置及電子設(shè)備，所述消息軌跡數(shù)據(jù)的處理方法包括：通過(guò)客戶端中的攔截器獲取消息軌跡數(shù)據(jù)；確定所述消息軌跡數(shù)據(jù)對(duì)應(yīng)的消息代理服務(wù)節(jié)點(diǎn)；將所述消息軌跡數(shù)據(jù)發(fā)送給所述消息代理服務(wù)節(jié)點(diǎn)，以通過(guò)所述消息代理服務(wù)節(jié)點(diǎn)將所述消息軌跡數(shù)據(jù)保存至目標(biāo)存儲(chǔ)區(qū)域。本申請(qǐng)通過(guò)客戶端中的攔截器獲取消息軌跡數(shù)據(jù)，使消息代理服務(wù)節(jié)點(diǎn)不用因?yàn)樾枰獧z索、解析和計(jì)算消息軌跡的相關(guān)數(shù)據(jù)而額外損耗服務(wù)器的性能。

技術(shù)領(lǐng)域

本申請(qǐng)涉及通信技術(shù)領(lǐng)域，尤其涉及一種消息軌跡數(shù)據(jù)的處理方法、裝置及電子設(shè)備。

背景技術(shù)

消息隊(duì)列(MQ，Message Queue)就是消息在傳輸過(guò)程中用于保存消息的容器，在一次發(fā)送接收的通信過(guò)程中，其主要充當(dāng)了“中轉(zhuǎn)站”的角色，內(nèi)部提供通信路由并保證消息的可靠傳遞。一條消息從生產(chǎn)者發(fā)出后，消息是否發(fā)送成功，是否正常被消費(fèi)，被保存在哪個(gè)消息服務(wù)代理(broker)節(jié)點(diǎn)都是用戶在使用消息隊(duì)列中間件時(shí)所需重點(diǎn)考慮和關(guān)注的點(diǎn)。如果沒(méi)有其他更為方便和快捷的手段，用戶基本上很難在一個(gè)大規(guī)模消息隊(duì)列集群中搜索一條消息的當(dāng)前處理狀態(tài)。因此，使用消息隊(duì)列的用戶需要有一種機(jī)制來(lái)記錄并查詢集群環(huán)境中消息的當(dāng)前狀態(tài)(是否被生產(chǎn)者發(fā)送成功、是否被消費(fèi)者正常消費(fèi)、被保存的具體位置)的消息軌跡數(shù)據(jù)。

發(fā)明內(nèi)容

為解決上述技術(shù)問(wèn)題，本申請(qǐng)實(shí)施例提供了一種消息軌跡數(shù)據(jù)處理方法、裝置、電子設(shè)備及存儲(chǔ)介質(zhì)。

本申請(qǐng)實(shí)施例提供的消息軌跡數(shù)據(jù)處理方法，包括：

通過(guò)客戶端中的攔截器獲取消息軌跡數(shù)據(jù)；

確定所述消息軌跡數(shù)據(jù)對(duì)應(yīng)的消息代理服務(wù)節(jié)點(diǎn)；

將所述消息軌跡數(shù)據(jù)發(fā)送給所述消息代理服務(wù)節(jié)點(diǎn)，以通過(guò)所述消息代理服務(wù)節(jié)點(diǎn)將所述消息軌跡數(shù)據(jù)保存至目標(biāo)存儲(chǔ)區(qū)域。

在本申請(qǐng)一可選實(shí)施方式中，所述將所述消息軌跡數(shù)據(jù)發(fā)送給所述消息代理服務(wù)節(jié)點(diǎn)，包括：

將所述消息軌跡數(shù)據(jù)投遞至阻塞隊(duì)列；

從所述阻塞隊(duì)列中獲取所述消息軌跡數(shù)據(jù)，并基于所述消息軌跡數(shù)據(jù)生成異步請(qǐng)求任務(wù)，將所述異步請(qǐng)求任務(wù)提交至線程池；

通過(guò)所述線程池采用異步線程方式對(duì)所述異步請(qǐng)求任務(wù)進(jìn)行處理，以將所述消息軌跡數(shù)據(jù)發(fā)送給所述消息代理服務(wù)節(jié)點(diǎn)。

在本申請(qǐng)一可選實(shí)施方式中，所述將所述消息軌跡數(shù)據(jù)發(fā)送給所述消息代理服務(wù)節(jié)點(diǎn)，包括：

將所述消息軌跡數(shù)據(jù)封裝成目標(biāo)消息格式，將具有所述目標(biāo)消息格式的所述消息軌跡數(shù)據(jù)發(fā)送至所述消息代理服務(wù)節(jié)點(diǎn)。

在本申請(qǐng)一可選實(shí)施方式中，所述通過(guò)客戶端中的攔截器獲取消息軌跡數(shù)據(jù)，包括：

通過(guò)生產(chǎn)者側(cè)的客戶端中的攔截器獲取消息軌跡數(shù)據(jù)；和/或，

通過(guò)消費(fèi)者側(cè)的客戶端中的攔截器獲取消息軌跡數(shù)據(jù)。

在本申請(qǐng)一可選實(shí)施方式中，所述確定所述消息軌跡數(shù)據(jù)對(duì)應(yīng)的消息代理服務(wù)節(jié)點(diǎn)，包括：

通過(guò)負(fù)載均衡算法從多個(gè)消息代理服務(wù)節(jié)點(diǎn)中確定出所述消息軌跡數(shù)據(jù)對(duì)應(yīng)的第一消息代理服務(wù)節(jié)點(diǎn)，其中，所述多個(gè)消息代理服務(wù)節(jié)點(diǎn)均支持對(duì)所述消息軌跡數(shù)據(jù)以及普通消息的存儲(chǔ)。

在本申請(qǐng)一可選實(shí)施方式中，所述多個(gè)消息代理服務(wù)節(jié)點(diǎn)中的每個(gè)消息代理服務(wù)節(jié)點(diǎn)均創(chuàng)建有所述目標(biāo)存儲(chǔ)區(qū)域，所述目標(biāo)存儲(chǔ)區(qū)域的主題屬性為軌跡主題。

在本申請(qǐng)一可選實(shí)施方式中，所述確定所述消息軌跡數(shù)據(jù)對(duì)應(yīng)的消息代理服務(wù)節(jié)點(diǎn)，包括：

確定所述消息軌跡數(shù)據(jù)對(duì)應(yīng)的消息代理服務(wù)節(jié)點(diǎn)為第二消息代理服務(wù)節(jié)點(diǎn)，其中，所述第二消息代理服務(wù)節(jié)點(diǎn)僅支持對(duì)所述消息軌跡數(shù)據(jù)的存儲(chǔ)。