[發(fā)明專利]鏈路聚合調(diào)用信息的處理方法及裝置

有效

• 申請?zhí)枺?/td>: 202010540922.7
• 申請日: 2020-06-15
• 公開（公告）號: CN111737297B
• 公開（公告）日: 2023-08-25
• 發(fā)明（設(shè)計）人: 王澤洋;曹輝健;劉慕雨;黃鏡澄
• 申請（專利權(quán)）人: 中國工商銀行股份有限公司
• 主分類號: G06F16/2455
• 分類號: G06F16/2455;G06F16/2458;G06Q40/04;H04L45/24;H04L67/568
• 代理公司: 北京三友知識產(chǎn)權(quán)代理有限公司 11127
• 代理人: 孫乳筍;王濤

本發(fā)明提供了鏈路聚合調(diào)用信息的處理方法及裝置，方法包括：獲取調(diào)用信息的鍵值和明細信息；將調(diào)用信息的鍵值緩存至caffeine緩存；將調(diào)用信息的鍵值和明細信息緩存至redis緩存；基于時間策略確定從caffeine緩存中驅(qū)逐的鍵值；根據(jù)確定的驅(qū)逐的鍵值從所述redis緩存中獲取該鍵值對應(yīng)的明細信息進行調(diào)用信息的鏈路聚合處理。本發(fā)明利用caffeine緩存、redis緩存提供基于多級緩存的分布式鏈路聚合的實現(xiàn)方式，從海量無序調(diào)用信息中獲取單筆交易的相對完整調(diào)用信息，還可根據(jù)內(nèi)存容量調(diào)整過期時間。無需對單臺高配置服務(wù)器便可對海量調(diào)用日志進行并行分析，降低了鏈路聚合的成本和難度。

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

本發(fā)明涉及數(shù)據(jù)處理技術(shù)，具體的講是一種鏈路聚合調(diào)用信息的處理方法及裝置。

背景技術(shù)

微服務(wù)時代，業(yè)務(wù)場景按照領(lǐng)域模型進行了拆分，往往一個完整的業(yè)務(wù)流程需要經(jīng)過多個服務(wù)間消息通信才最終閉環(huán)。

大規(guī)模分布式集群雖然承載了更大規(guī)模的并發(fā)量，但是調(diào)用鏈路更加錯綜復(fù)雜。特別是大中臺的建設(shè)，服務(wù)的復(fù)用與組合構(gòu)成了各式各樣的業(yè)務(wù)交易。單筆交易可能流經(jīng)多臺服務(wù)器的多個服務(wù)，服務(wù)調(diào)用信息上報到消息中間件的時間可能不同，消息中間件的分區(qū)規(guī)則更會導(dǎo)致調(diào)用信息亂序。擁有完整的調(diào)用信息才可以進行鏈路的拓撲聚合，需要對調(diào)用信息進行處理以便更好的進行鏈路聚合處理。

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

為了在海量無序的調(diào)用日志下，收集單筆交易過去一段時間的調(diào)用信息，提高后續(xù)鏈路聚合拓撲聚合的成功率，本發(fā)明實施例提供了一種鏈路聚合調(diào)用信息的處理方法，包括：

獲取調(diào)用信息的鍵值和明細信息；

將所述調(diào)用信息的鍵值緩存至caffeine緩存；

將所述調(diào)用信息的鍵值和明細信息緩存至redis緩存；

基于時間策略確定從caffeine緩存中驅(qū)逐的鍵值；

根據(jù)確定的驅(qū)逐的鍵值從所述redis緩存中獲取該鍵值對應(yīng)的明細信息進行調(diào)用信息的鏈路聚合處理。

本發(fā)明實施例中，所述的調(diào)用信息的鍵值包括：調(diào)用信息的交易特征值；

所述的明細信息包括：調(diào)用的節(jié)點信息、耗時信息及結(jié)果信息。

本發(fā)明實施例中，所述的獲取調(diào)用信息的鍵值和明細信息包括：

確定調(diào)用信息的交易特征值的哈希值；

將相同哈希值的調(diào)用信息存儲至同一路由節(jié)點；

從同一路由節(jié)點中獲取調(diào)用信息的鍵值和明細信息。

本發(fā)明實施例中，所述的從同一路由節(jié)點中獲取調(diào)用信息的鍵值和明細信息包括：

利用kafka消息傳遞系統(tǒng)從節(jié)點獲取調(diào)用信息的鍵值和明細信息。

本發(fā)明實施例中，所述的基于時間策略確定從caffeine緩存中驅(qū)逐的鍵值包括：

獲取caffeine緩存中的調(diào)用信息的鍵值中的時間戳；

根據(jù)所述時間戳確定存儲時長；

確定所述存儲時長不小于預(yù)設(shè)時長則將調(diào)用信息的鍵值從caffeine緩存中驅(qū)逐。

同時，本發(fā)明還提供一種鏈路聚合調(diào)用信息的處理裝置，包括：

獲取模塊，用于獲取調(diào)用信息的鍵值和明細信息；

caffeine緩存模塊，用于將所述調(diào)用信息的鍵值緩存至caffeine緩存；

redis緩存模塊，用于將所述調(diào)用信息的鍵值和明細信息緩存至redis緩存；