[發明專利]一種多線程事件分發方法和系統

在審

• 申請號: 201710295744.4
• 申請日: 2017-04-28
• 公開（公告）號: CN107122239A
• 公開（公告）日: 2017-09-01
• 發明（設計）人: 方敏
• 申請（專利權）人: 武漢票據交易中心有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/54
• 代理公司: 北京輕創知識產權代理有限公司11212
• 代理人: 楊立,朱毅

技術領域

本發明涉及數據處理領域，特別涉及一種多線程事件分發方法和系統。

背景技術

事件分發機制是基于Java的開發的系統中比較重要的一塊。事件類型有很多種，但現有技術的事件分發機制沒有對事件進行分類，也不能采用獨立的線程對事件進行處理，因此處理速度慢、處理效率也不高。

發明內容

本發明提供了一種多線程事件分發方法和系統，解決了現有技術的事件分發機制處理速度慢、效率低的技術問題。

本發明解決上述技術問題的技術方案如下：一種多線程事件分發方法，包括以下步驟：

步驟1、客戶端向連接服務器發送客戶端事件；

步驟2、所述連接服務器獲取所述客戶端事件，當所述客戶端事件為遠程調用類事件，且所述連接服務器中沒有所述客戶端事件對應的遠程調用類處理器時，將所述客戶端事件發送給消息服務器；

步驟3、當應用服務器從所述消息服務器中獲取所述客戶端事件，處理所述客戶端事件并得到對應的服務器事件時，所述連接服務器獲取所述服務器事件，并按照所述服務器事件的優先級順序對所述服務器事件進行處理，并向客戶端返回處理結果。

本發明的有益效果是：本發明對服務器事件進行優先級分類，并按照優先級從高到低的順序，依次處理，且每次處理均采用獨立的線程，極大地提高了事件處理的速度。

在上述技術方案的基礎上，本發明還可以做如下改進。

進一步，所述步驟3包括：

步驟3.1、當應用服務器從所述消息服務器中獲取所述客戶端事件，處理所述客戶端事件并得到對應的服務器事件時，所述連接服務器中的緩存引擎從所述消息服務器中監聽并獲取所述服務器事件；

步驟3.2、根據預注冊的服務器事件優先處理消息主題，所述緩存引擎將所述服務器事件存儲到不同的優先級消息隊列中，所述優先級消息隊列包括低優先級消息隊列、普通級消息隊列和高優先級消息隊列；

步驟3.3、緩存引擎依次對所述高優先級消息隊列、所述普通級消息隊列和所述低優先級消息隊列中的所述服務器事件進行處理，并向所述連接服務器中的每個會話控制模型返回緩存引擎處理結果，其中，所述會話控制模型有多個，且與客戶端一一對應；

步驟3.4、所述會話控制模型處理所述緩存引擎處理結果，并向客戶端返回最終處理結果。

本發明的進一步有益效果是：按照高優先級、普通級和低優先級的順序，緩存引擎依次對所述高優先級消息隊列、所述普通級消息隊列和所述低優先級消息隊列中的所述服務器事件進行處理，提高了服務器事件的處理效率。

進一步，所述步驟3.3包括：

步驟3.3.1、緩存引擎中的高優先級事件線程從所述高優先級消息隊列中依次取出高優先級服務器事件，并將所述高優先級服務器事件依次放入每個所述會話控制模型中的優先事件隊列中，所述高優先級服務器事件為直接消息事件；

則所述步驟3.4包括：

步驟3.4.1、每個所述會話控制模型中的優先更新線程從所述優先事件隊列中依次取出所述高優先級服務器事件，并將所有的所述高優先級服務器事件封裝為直接事件處理器，并發送所述直接事件處理器至所述會話控制模型對應的客戶端。

本發明的進一步有益效果是：對于高優先級的服務器事件，緩存引擎通過使用高優先級事件線程獲取高優先級服務器事件，并依次將高優先級服務器事件發送至會話控制模型，會話控制模型通過優先更新線程將所有高優先級服務器事件封裝為直接事件處理器，并直接發送給客戶端，由每個客戶端自行去處理直接事件處理器，極大地提高了服務器事件高優先級服務器事件的處理效率，相應的，也提高了緩存引擎和會話控制模型其他服務器事件的處理效率。

進一步，所述步驟3.3還包括：

步驟3.3.2、緩存引擎中的事件線程從所述普通級消息隊列中依次取出普通級服務器事件，依次將所述普通級服務器事件存儲到會話控制模型事件隊列中；

步驟3.3.3、所述緩存引擎中的第一會話控制模型發送線程依次將所述普通級服務器事件從所述會話控制模型事件隊列中取出，并依次將所述普通級服務器事件發送至每個會話控制模型；

則步驟3.4還包括：

步驟3.4.2、每個所述會話控制模型調用其內的事件處理方法依次將所述普通級服務器事件放入到所述會話控制模型中的事件隊列中；