[發(fā)明專利]基于pinpoint日志的鏈路構(gòu)建方法

有效

• 申請(qǐng)?zhí)枺?/td>: 201911082453.2
• 申請(qǐng)日: 2019-11-07
• 公開(kāi)（公告）號(hào): CN110569399B
• 公開(kāi)（公告）日: 2020-03-06
• 發(fā)明（設(shè)計(jì)）人: 胡榮德;陳思成;李開(kāi)宇;蔡亮;喻川
• 申請(qǐng)（專利權(quán)）人: 四川新網(wǎng)銀行股份有限公司
• 主分類號(hào): G06F16/901
• 分類號(hào): G06F16/901
• 代理公司: 成都智言知識(shí)產(chǎn)權(quán)代理有限公司 51282
• 代理人: 濮云杉

1.基于pinpoint日志的鏈路構(gòu)建方法，其特征包括：

A.將pinpoint日志的數(shù)據(jù)寫(xiě)入kafka集群系統(tǒng)中，并通過(guò)kafka集群系統(tǒng)將所述的pinpoint日志解析為Span信息；

B.在kafka集群系統(tǒng)中每次讀取一條Span信息，并根據(jù)該Span信息的事務(wù)ID和LRU算法，添加或更新雙向鏈表中的結(jié)點(diǎn)，具體為：

當(dāng)通過(guò)kafka集群系統(tǒng)讀取了一條Span信息后，如果在雙向鏈表中沒(méi)有與該Span信息中的事務(wù)ID相同的事務(wù)ID，則將該Span信息的內(nèi)容構(gòu)建為雙向鏈表的一個(gè)新結(jié)點(diǎn)；反之，則將該Span信息的內(nèi)容添加到與該Span信息具有相同事務(wù)ID的結(jié)點(diǎn)中，并認(rèn)為所述具有相同事務(wù)ID的結(jié)點(diǎn)為活躍的結(jié)點(diǎn)；

將Span信息的內(nèi)容添加到雙向鏈表的對(duì)應(yīng)結(jié)點(diǎn)后，將所述對(duì)應(yīng)結(jié)點(diǎn)的位置更新至雙向鏈表的鏈?zhǔn)祝?/p>

C.執(zhí)行步驟B，直到當(dāng)雙向鏈表中的結(jié)點(diǎn)數(shù)量達(dá)到預(yù)設(shè)的閾值N后，將雙向鏈表中鏈尾的M個(gè)結(jié)點(diǎn)移出雙向鏈表，各Span信息根據(jù)各自屬性中的上游Span信息的ID與上游Span信息進(jìn)行關(guān)聯(lián)后，將所述M個(gè)結(jié)點(diǎn)構(gòu)建出Span信息的跟蹤樹(shù)，并通過(guò)DFS算法，在跟蹤樹(shù)中遍歷出具有相同事務(wù)ID的所有Span信息的集合，形成調(diào)用鏈路，將調(diào)用鏈路的數(shù)據(jù)寫(xiě)入數(shù)據(jù)庫(kù)。

2.如權(quán)利要求1所述的基于pinpoint日志的鏈路構(gòu)建方法，其特征為：步驟A所述將pinpoint日志解析為Span信息時(shí)，先通過(guò)代碼從pinpoint日志中過(guò)濾出含有Span數(shù)據(jù)的日志，然后對(duì)過(guò)濾出的含有Span數(shù)據(jù)的日志通過(guò)正則匹配，組裝為所述的Span信息。

3.如權(quán)利要求1所述的基于pinpoint日志的鏈路構(gòu)建方法，其特征為：步驟C在根據(jù)同一個(gè)事務(wù)ID遍歷Span信息時(shí)，從跟蹤樹(shù)的頂點(diǎn)開(kāi)始，向跟蹤樹(shù)中未被訪問(wèn)的頂點(diǎn)的鄰接點(diǎn)進(jìn)行DFS算法的遍歷，直至跟蹤樹(shù)中和頂點(diǎn)有路徑相通的子頂點(diǎn)都被訪問(wèn)。

4.如權(quán)利要求3所述的基于pinpoint日志的鏈路構(gòu)建方法，其特征為：如果從一個(gè)頂點(diǎn)遍歷完一個(gè)跟蹤樹(shù)后，還有未被遍歷的跟蹤樹(shù)，則從未被遍歷的跟蹤樹(shù)的頂點(diǎn)開(kāi)始，再次進(jìn)行DFS算法的遍歷，直至所有的跟蹤樹(shù)均被遍歷。

5.如權(quán)利要求1所述的基于pinpoint日志的鏈路構(gòu)建方法，其特征為：步驟C在形成調(diào)用鏈路后，分別統(tǒng)計(jì)每條調(diào)用鏈路的各項(xiàng)基本統(tǒng)計(jì)值，包括鏈路名稱、調(diào)用次數(shù)、調(diào)用時(shí)間、平均響應(yīng)時(shí)間、鏈上各個(gè)結(jié)點(diǎn)響應(yīng)時(shí)間、鏈路調(diào)用啟動(dòng)時(shí)間和數(shù)據(jù)入庫(kù)時(shí)間，并對(duì)同一個(gè)時(shí)間段內(nèi)出現(xiàn)多于一次的鏈路，對(duì)該鏈路的基本統(tǒng)計(jì)值進(jìn)行合并操作。