[發(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
• 代理公司: 濟南信達專利事務(wù)所有限公司 37100
• 代理人: 李世喆;姜鵬

1.基于消息隊列的日志信息處理方法，其特征在于，包括：

在發(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)的日志處理類所在的存儲全路徑；

根據(jù)所述存儲全路徑和所述第二配置文件，確定每一個存儲路徑對應(yīng)的日志處理類；

針對每一個日志處理類，通過反射的方式實例化該日志處理類，生成實例化日志處理類，其中，每個所述實例化日志處理類對應(yīng)一個處理接口和處理方法；

控制所述訂閱端通過所述處理接口調(diào)用所述實例化日志處理類，以使該實例化日志處理類根據(jù)所述處理方法對所述日志信息進行處理。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述根據(jù)所述第一連接方案，將所述發(fā)布端產(chǎn)生的日志信息發(fā)送到與該日志信息所屬日志類型名稱相同的所述消息隊列主題中，包括：

利用所述發(fā)布端判斷所述第一連接方案是否為對應(yīng)該日志信息所屬日志類型的自有連接方案；

若是，則將所述日志信息按照該自有連接方案發(fā)送到與所述日志類型名稱相同的消息隊列主題中；

若不是，則將所述日志信息按照第一連接方案發(fā)送到與所述日志類型名稱相同的消息隊列主題中。

3.根據(jù)權(quán)利要求2所述的方法，其特征在于，在所述利用所述發(fā)布端判斷所述第一連接方案是否為對應(yīng)該日志信息所屬日志類型的自有連接方案之后，進一步包括：

利用所述發(fā)布端判斷所述第一連接方案中是否存在與所述日志信息所屬日志類型名稱相同的消息隊列主題；

若沒有，則創(chuàng)建一個與所述日志類型名稱相同的消息隊列主題。