[發明專利]分布式異步事件的處理方法及系統

有效

• 申請號: 201310476116.8
• 申請日: 2013-10-12
• 公開（公告）號: CN103530255B
• 公開（公告）日: 2017-01-11
• 發明（設計）人: 左文建;王東洋
• 申請（專利權）人: 北京奇虎科技有限公司;奇智軟件（北京）有限公司
• 主分類號: G06F13/38
• 分類號: G06F13/38;G06F9/44
• 代理公司: 北京市浩天知識產權代理事務所(普通合伙)11276
• 代理人: 宋菲,劉云貴

1.一種分布式異步事件的處理方法，包括：

以日志方式對每一應用服務器中的要處理的事件進行處理，為每個要處理的事件創建第一日志消息，并且傳輸第一日志消息，所述第一日志消息至少包括消息類別和消息內容；

將接收的所述第一日志消息存儲到中心服務器中的消息隊列中；

根據各個訂閱服務器向所述中心服務器登記的要處理的消息的消息類別，將所述中心服務器的消息隊列中的與所登記的消息類別相對應的消息分別傳送至相應的訂閱服務器；

所述訂閱服務器對所述消息進行處理，并向所述中心服務器返回消息處理結果；以及

將接收的第一日志消息和消息處理結果進行對比，補償處理失敗或丟失的事件。

2.根據權利要求1所述的處理方法，其中，所述訂閱服務器對所述消息進行處理，并向所述中心服務器返回消息處理結果，包括：

所述訂閱服務器以日志方式對消息處理結果進行處理以生成第二日志消息，并將所述第二日志消息傳輸到所述中心服務器。

3.根據權利要求1或2所述的處理方法，其中，所述第一日志消息和所述第二日志消息包括下列中的一個或多個：事件生成的時間、生成事件的主機信息、事件類別、事件名、事件標識和事件內容。

4.根據權利要求1所述的處理方法，所述將接收的第一日志消息和消息處理結果進行對比，補償處理失敗或丟失的事件，包括：

從所述中心服務器讀取N個時間單位內所接收的第一日志消息中包含的數據，N為正整數；

將讀取到的所述數據存儲在數據庫中；

讀取N+M個時間單位內訂閱服務器返回的消息處理結果，并將消息處理結果與所述數據庫中存儲的數據進行對比，如果所述數據庫中存在消息處理結果中未包含的事件，則將該事件記錄為處理失敗或丟失的事件，將所述事件進行處理以生成第一日志消息，并將第一日志消息存儲到中心服務器中的消息隊列中，其中，M為正整數。

5.根據權利要求4所述的處理方法，其中，所述時間單位為小時，M的值為1。

6.根據權利要求1或4或5所述的處理方法，其中，將所述第一日志消息存儲到中心服務器中的消息隊列中，包括：

從所述第一日志消息中提取出要處理的事件；

根據事件配置原則對與提取出的事件對應的第一日志消息進行打包和/或消重處理，然后存儲到消息隊列中。

7.根據權利要求6所述的處理方法，其中，所述對與提取出的事件對應的第一日志消息進行消重處理，包括：

將要處理的日志消息存儲于第一緩存器；

查找所述第一緩存器中是否存儲有第一日志消息，如果不存在，則將所述第一日志消息緩存于所述第一緩存器中，并輸出至所述消息隊列中，如果存在，則不將所述第一日志消息存儲于所述第一緩存器中，也不將其傳輸至所述消息隊列中；

其中，所述對與提取出的事件對應的第一日志消息進行打包處理，包括：緩存要處理的日志消息，當所緩存的要處理的日志消息數量達到預設的最大值后，將所緩存的日志消息合成一條日志消息，并輸出到所述消息隊列中。

8.根據權利要求7所述的處理方法，該方法還包括：

定時觸發而清除所述第一緩存器中的數據；和/或

在緩存的日志消息數量沒有達到所述預設的最大值的情況下，定時觸發而將緩存的日志消息合成一條日志消息，并輸出到所述消息隊列中。

9.一種分布式異步事件的處理系統，包括：

一個或多個應用服務器，每個應用服務器適于以日志方式對要處理的事件進行處理，為每個要處理的事件創建第一日志消息，并且傳輸第一日志消息，所述第一日志消息至少包括消息類別和消息內容；

中心服務器，適于接收第一日志消息，將所述第一日志消息存儲到所述中心服務器的消息隊列中；接收來自每個訂閱服務器的消息處理結果，將第一日志消息和消息處理結果進行對比，補償處理失敗或丟失的事件；以及

一個或多個訂閱服務器，每個訂閱服務器適于向所述中心服務器登記要處理的消息的消息類別，接收所述中心服務器所傳輸的、所述消息隊列中與所登記的消息類別相對應的消息，對所述消息進行處理，并且向所述中心服務器返回消息處理結果。

10.根據權利要求9所述的處理系統，其中，所述一個或者多個應用服務器中的每個應用服務器包括：

事件生成器，適于以日志方式生成與要處理的事件相對應的第一日志消息；

第一日志傳輸單元，適于在所述事件生成器生成第一日志消息時，將所生成的第一日志消息傳輸至所述中心服務器。