[發(fā)明專利]基于消息隊列的日志信息處理方法、裝置及可讀介質(zhì)

有效

• 申請?zhí)枺?/td>: 202011186103.3
• 申請日: 2020-10-30
• 公開（公告）號: CN112306979B
• 公開（公告）日: 2022-11-01
• 發(fā)明（設(shè)計）人: 韓曉辰
• 申請（專利權(quán)）人: 浪潮通用軟件有限公司
• 主分類號: G06F16/18
• 分類號: G06F16/18;H04L47/50;H04L67/30
• 代理公司: 濟南信達(dá)專利事務(wù)所有限公司 37100
• 代理人: 李世喆;姜鵬

本發(fā)明提供的基于消息隊列的日志信息處理方法、裝置及可讀介質(zhì)，通過在發(fā)布端創(chuàng)建第一配置文件和在訂閱端創(chuàng)建第二配置文件，以及讀取第二配置文件中的第二連接方案，以使訂閱端訂閱消息隊列中每一個消息隊列主題。根據(jù)第一配置文件，將發(fā)布端產(chǎn)生的日志信息發(fā)送到與該日志信息所屬日志類型名稱相同的消息隊列主題，根據(jù)第二連接方案，控制與消息隊列連接的訂閱端對每一個消息隊列主題進行監(jiān)聽。當(dāng)訂閱端監(jiān)聽到消息隊列主題中有日志信息傳入時，確定該日志信息對應(yīng)的日志處理類，并利用每一個日志處理類對日志信息進行處理。本發(fā)明基于消息隊列將網(wǎng)絡(luò)系統(tǒng)產(chǎn)生的日志信息發(fā)送到日志信息處理服務(wù)端進行處理，能夠減小網(wǎng)絡(luò)系統(tǒng)處理日志信息的壓力。

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

本發(fā)明涉及信息處理領(lǐng)域，特別涉及基于消息隊列的日志信息處理方法、裝置及可讀介質(zhì)。

背景技術(shù)

隨著互聯(lián)網(wǎng)技術(shù)的不斷發(fā)展，企業(yè)的互聯(lián)網(wǎng)業(yè)務(wù)種類增多，網(wǎng)絡(luò)系統(tǒng)架構(gòu)也隨之越來越復(fù)雜，網(wǎng)絡(luò)系統(tǒng)在運行過程中會產(chǎn)生大量的日志信息。這些日志通常會記錄下系統(tǒng)中硬件、軟件、應(yīng)用的問題信息和事件信息，用戶可以通過日志來檢查網(wǎng)絡(luò)系統(tǒng)中發(fā)生的事件，進而迅速的查找到網(wǎng)絡(luò)系統(tǒng)運行過程中的問題。

現(xiàn)有的記錄系統(tǒng)日志的方法通常是在本地打開一個日志文件，然后各個進程把系統(tǒng)產(chǎn)生的日志記錄下來，通過直接查看可讀的日志文件瀏覽系統(tǒng)的日志信息。然而隨著系統(tǒng)管理設(shè)備的增多和互聯(lián)網(wǎng)業(yè)務(wù)的增加，整個系統(tǒng)在運行過程中產(chǎn)生大量的日志信息，若仍采用本地文件記錄日志和網(wǎng)絡(luò)系統(tǒng)處理日志的方式，會嚴(yán)重影響網(wǎng)絡(luò)系統(tǒng)的正常運行。

針對網(wǎng)絡(luò)系統(tǒng)中逐漸增加的日志信息，通常采用異步的日志處理方式達(dá)到滿足異步、低耦合、安全的日志處理要求。但在日志處理過程中可能出現(xiàn)的中斷操作會導(dǎo)致日志信息的丟失，同時隨著日志記錄的增加會導(dǎo)致網(wǎng)絡(luò)系統(tǒng)日志處理壓力大。

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

本發(fā)明實施例提供了基于消息隊列的日志信息處理方法、裝置及可讀介質(zhì)，能夠減小網(wǎng)絡(luò)系統(tǒng)處理日志信息的壓力。

第一方面，本發(fā)明實施例提供了基于消息隊列的日志信息處理方法，包括：

在發(fā)布端創(chuàng)建第一配置文件，其中，所述第一配置文件保存有所述發(fā)布端與消息隊列的第一連接方案，所述消息隊列為在日志信息的傳輸過程中保存所述日志信息的容器，所述消息隊列中包括至少一個消息隊列主題，每個所述消息隊列主題與日志信息所屬日志類型的名稱相同；

在訂閱端創(chuàng)建第二配置文件，其中，所述第二配置文件保存有所述訂閱端與所述消息隊列的第二連接方案及所述日志類型與至少一個日志處理類的對應(yīng)關(guān)系，每個所述日志處理類用于處理對應(yīng)日志類型的日志信息；

讀取所述第二連接方案，以使所述訂閱端完成所述消息隊列中每一個消息隊列主題的訂閱服務(wù)；

根據(jù)所述第一連接方案，將所述發(fā)布端產(chǎn)生的日志信息發(fā)送到與該日志信息所屬日志類型名稱相同的所述消息隊列主題中；

根據(jù)所述第二連接方案，使所述訂閱端與所述消息隊列連接，并控制所述訂閱端對消息隊列中的每一個消息隊列主題進行監(jiān)聽；

當(dāng)所述訂閱端監(jiān)聽到所述消息隊列主題中有日志信息傳入時，根據(jù)所述對應(yīng)關(guān)系確定該日志信息對應(yīng)的至少一個日志處理類，并利用每一個所述日志處理類對所述日志信息進行處理。

可選地，所述當(dāng)所述訂閱端監(jiān)聽到所述消息隊列主題中有日志信息傳入時，根據(jù)所述對應(yīng)關(guān)系確定該日志信息對應(yīng)的至少一個日志處理類，并利用每一個所述日志處理類對所述日志信息進行處理，包括：

當(dāng)所述訂閱端監(jiān)聽到所述消息隊列主題中有日志信息傳入時，控制所述訂閱端與所述消息隊列通過回調(diào)接口連接；

控制所述訂閱端通過回調(diào)接口獲取該日志信息和該日志信息所在的消息隊列主題；

根據(jù)該消息隊列主題和所述第二配置文件中的所述對應(yīng)關(guān)系，確定該日志信息的日志類型和該日志類型對應(yīng)的日志處理類所在的存儲全路徑；