[發(fā)明專利]一種基于端到端業(yè)務(wù)監(jiān)控的實(shí)現(xiàn)方法和裝置

在審

• 申請(qǐng)?zhí)枺?/td>: 201610232346.3
• 申請(qǐng)日: 2016-04-14
• 公開(kāi)（公告）號(hào): CN105763382A
• 公開(kāi)（公告）日: 2016-07-13
• 發(fā)明（設(shè)計(jì)）人: 張清鎖
• 申請(qǐng)（專利權(quán)）人: 北京思特奇信息技術(shù)股份有限公司
• 主分類號(hào): H04L12/24
• 分類號(hào): H04L12/24;H04L12/801
• 代理公司: 北京輕創(chuàng)知識(shí)產(chǎn)權(quán)代理有限公司 11212
• 代理人: 楊立

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

本發(fā)明涉及計(jì)算機(jī)領(lǐng)域，特別是涉及一種基于端到端業(yè)務(wù)監(jiān)控的實(shí)現(xiàn)方法和裝置。

背景技術(shù)

一個(gè)強(qiáng)大的、完整的支撐系統(tǒng)是一個(gè)由很多個(gè)應(yīng)用集群組成的非常復(fù)雜的分布式系統(tǒng)。這些應(yīng)用里面主要有處理用戶請(qǐng)求的前端系統(tǒng)和提供服務(wù)的后端系統(tǒng)等，各個(gè)應(yīng)用之間一般有遠(yuǎn)程過(guò)程調(diào)用協(xié)議(RemoteProcedureCallProtocol，RPC)調(diào)用和異步消息通訊兩種手段，調(diào)用會(huì)產(chǎn)生一層調(diào)一層的嵌套，一個(gè)消息發(fā)布出來(lái)更會(huì)被多個(gè)應(yīng)用消費(fèi)。另外，應(yīng)用還會(huì)訪問(wèn)數(shù)據(jù)庫(kù)、緩存、存儲(chǔ)等后端，以及調(diào)用其他外部系統(tǒng)等。

這些調(diào)用中有哪些出問(wèn)題會(huì)影響這次調(diào)用，有哪些步驟會(huì)拖慢整個(gè)處理流程。由于調(diào)用環(huán)境的復(fù)雜度，很難用人力去做準(zhǔn)確的分析和評(píng)估了。

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

本發(fā)明所要解決的技術(shù)問(wèn)題是提供一種基于端到端業(yè)務(wù)監(jiān)控的實(shí)現(xiàn)方法和裝置。

本發(fā)明解決上述技術(shù)問(wèn)題的技術(shù)方案如下：一種基于端到端業(yè)務(wù)監(jiān)控的實(shí)現(xiàn)方法，包括：

從應(yīng)用集群中獲取日志粒度；

對(duì)所述日志粒度分別進(jìn)行實(shí)時(shí)采集和非實(shí)時(shí)采集得到實(shí)時(shí)日志和非實(shí)時(shí)日志；

從所述實(shí)時(shí)日志和所述非實(shí)時(shí)日志中獲取全量日志和增量日志；

將所述全量日志和所述增量日志分別進(jìn)行調(diào)用鏈生成處理、調(diào)用統(tǒng)計(jì)分析處理、調(diào)用來(lái)源處理和依賴度量處理，從而獲取相應(yīng)數(shù)據(jù)；

顯示所述相應(yīng)數(shù)據(jù)。

本發(fā)明的有益效果是：通過(guò)日志粒度獲取應(yīng)用集群中各個(gè)系統(tǒng)之間的調(diào)用情況，從而在某一系統(tǒng)出現(xiàn)瓶頸時(shí)，定位錯(cuò)誤異常的根源位置。

在上述技術(shù)方案的基礎(chǔ)上，本發(fā)明還可以做如下改進(jìn)。

進(jìn)一步，所述應(yīng)用集群包括上一級(jí)服務(wù)端、能力開(kāi)放平臺(tái)和下一級(jí)服務(wù)端，所述從應(yīng)用集群中獲取日志粒度包括：

所述上一級(jí)服務(wù)端生成統(tǒng)一流水標(biāo)識(shí)符ID；

如果開(kāi)關(guān)為閉合狀態(tài)，則所述上一級(jí)服務(wù)端將所述統(tǒng)一流水ID和調(diào)用標(biāo)識(shí)符ID發(fā)送給所述下一級(jí)服務(wù)端；

記錄所述上一級(jí)服務(wù)端通過(guò)所述能力開(kāi)放平臺(tái)與所述下一級(jí)服務(wù)端的日志信息；

將所述統(tǒng)一流水ID、所述調(diào)用ID和所述日志信息構(gòu)成所述日志粒度。

進(jìn)一步，還包括：

如果所述開(kāi)關(guān)為斷開(kāi)狀態(tài)，則所述上一級(jí)服務(wù)端與所述下一級(jí)服務(wù)端之間不生成所述日志信息。

進(jìn)一步，所述從所述實(shí)時(shí)日志和所述非實(shí)時(shí)日志中獲取全量日志和增量日志包括：在閾值時(shí)間內(nèi)從所述實(shí)時(shí)日志和所述非實(shí)時(shí)日志中抓取的日志為所述全量日志。

進(jìn)一步，所述從所述實(shí)時(shí)日志和所述非實(shí)時(shí)日志中獲取全量日志和增量日志還包括：

在各時(shí)間段內(nèi)從所述實(shí)時(shí)日志和所述非實(shí)時(shí)日志中獲取所述各時(shí)間段對(duì)應(yīng)的日志；

將所述各時(shí)間段對(duì)應(yīng)的日志依次進(jìn)行疊加，從而得到所述增量日志。

本發(fā)明解決上述技術(shù)問(wèn)題的技術(shù)方案如下：一種基于端到端業(yè)務(wù)監(jiān)控的實(shí)現(xiàn)裝置，包括：

日志粒度獲取單元，用于從應(yīng)用集群中獲取日志粒度；

采集單元，用于對(duì)所述日志粒度分別進(jìn)行實(shí)時(shí)采集和非實(shí)時(shí)采集得到實(shí)時(shí)日志和非實(shí)時(shí)日志；

日志獲取單元，用于從所述實(shí)時(shí)日志和所述非實(shí)時(shí)日志中獲取全量日志和增量日志；

處理單元，用于將所述全量日志和所述增量日志分別進(jìn)行調(diào)用鏈生成處理、調(diào)用統(tǒng)計(jì)分析處理、調(diào)用來(lái)源處理和依賴度量處理，從而獲取相應(yīng)數(shù)據(jù)；

顯示單元，用于顯示所述相應(yīng)數(shù)據(jù)。

本發(fā)明的有益效果是：通過(guò)日志粒度獲取應(yīng)用集群中各個(gè)系統(tǒng)之間的調(diào)用情況，從而在某一系統(tǒng)出現(xiàn)瓶頸時(shí)，定位錯(cuò)誤異常的根源位置。

在上述技術(shù)方案的基礎(chǔ)上，本發(fā)明還可以做如下改進(jìn)。

進(jìn)一步，所述應(yīng)用集群包括上一級(jí)服務(wù)端、能力開(kāi)放平臺(tái)和下一級(jí)服務(wù)端，所述日志粒度獲取單元包括：

生成單元，用于所述上一級(jí)服務(wù)端生成統(tǒng)一流水標(biāo)識(shí)符ID；

發(fā)送單元，用于在開(kāi)關(guān)為閉合狀態(tài)的情況下，所述上一級(jí)服務(wù)端將所述統(tǒng)一流水ID和調(diào)用標(biāo)識(shí)符ID發(fā)送給所述下一級(jí)服務(wù)端；

記錄單元，用于記錄所述上一級(jí)服務(wù)端通過(guò)所述能力開(kāi)放平臺(tái)與所述下一級(jí)服務(wù)端的日志信息；

構(gòu)成單元，用于將所述統(tǒng)一流水ID、所述調(diào)用ID和所述日志信息構(gòu)成所述日志粒度。

進(jìn)一步，還包括：

交互單元，用于在所述開(kāi)關(guān)為斷開(kāi)狀態(tài)的情況下，所述上一級(jí)服務(wù)端與所述下一級(jí)服務(wù)端之間不生成所述日志信息。

進(jìn)一步，所述日志獲取單元包括：在閾值時(shí)間內(nèi)從所述實(shí)時(shí)日志和所述非實(shí)時(shí)日志中抓取的日志為所述全量日志。