[發明專利]一種基于事件的流程處理方法及裝置和服務器

在審

• 申請號: 201611218388.8
• 申請日: 2016-12-26
• 公開（公告）號: CN107659547A
• 公開（公告）日: 2018-02-02
• 發明（設計）人: 方敏
• 申請（專利權）人: 武漢票據交易中心有限公司
• 主分類號: H04L29/06
• 分類號: H04L29/06;G06Q40/00;G06Q40/04
• 代理公司: 北京匯澤知識產權代理有限公司11228
• 代理人: 程殿軍,張瑾

1.一種基于事件的流程處理方法，其特征在于，包括：

當連接服務器接收到客戶端發送的服務器事件時，確定所述事件是否為自身需要處理的服務器事件；當確定為是時，將所述服務器事件發送給所述連接服務器本地預設的處理該服務器事件的事件處理類進行處理；當確定為否時，將所述服務器事件發送給消息服務器，以便其他應用服務器從所述消息服務器讀取并處理；

當連接服務器監聽到應用服務器處理完成后轉發至客戶端的交易處理結果的服務器事件時，根據所述交易處理結果對應的優先級級別，分配對應級別的事件處理線程分別進行處理；根據處理結果更新緩存的數據，并將服務器事件轉換成客戶端事件，根據該服務器事件的分發列表，發送給對應的客戶端。

2.如權利要求1所述的方法，其特征在于，所述確定所述事件是否為自身需要處理的服務器事件，包括：

所述連接服務器判斷所述服務器事件的類型是否與自身預先注冊的事件類型一致，若一致，則確定所述服務器事件屬于自身需要處理的服務器事件；否則，確定所述服務器事件不屬于自身需要處理的服務器事件。

3.如權利要求1所述的方法，其特征在于，根據所述交易處理結果對應的優先級級別，分配對應級別的事件處理線程分別進行處理，包括：

將各個服務器事件按照預設的優先級級別，分別緩存于對應級別的隊列中，每個隊列中服務器事件按照接收的時間先后排列；

按照優先級的高低順序，依次從不同級別的隊列中取出該隊列中的服務器事件，并將所述服務器事件分發至對應級別的事件處理線程；

通過所述事件處理線程調用服務器事件對應的事件處理類，對所述服務器事件進行處理。

4.如權利要求1所述的方法，其特征在于，所述客戶端在所述連接服務器側分配有對應的會話模型對象；所述會話模型對象記錄有客戶端的標識、客戶端與連接服務器之間socket連接的標識；

所述根據該服務器事件的分發列表，發送給對應的客戶端，包括：

所述會話模型對象根據所述分發列表，確定是否需要將所述事件轉發給對應的客戶端；若需要，則根據所述客戶端的socket連接的標識，將所述事件發送給對應的客戶端。

5.如權利要求1-4任一項所述的方法，其特征在于，所述事件處理線程的處理性能與所處理的服務器事件的優先級級別正相關。

6.一種基于事件的流程處理裝置，其特征在于，包括：

確定模塊，用于當接收到客戶端發送的服務器事件時，判斷所述事件是否為自身需要處理的服務器事件；

第一事件處理模塊，用于當判斷模塊判斷為是時，將所述服務器事件發送給所述連接服務器本地預設的處理該服務器事件的事件處理類進行處理；

發送模塊，用于當判斷模塊判斷為否時，將所述服務器事件發送給消息服務器，以便其他應用服務器從所述消息服務器讀取并處理；

第二事件處理模塊，用于監聽到需轉發至客戶端的交易處理結果的服務器事件時，根據所述交易處理結果對應的優先級級別，分配對應級別的事件處理線程分別進行處理；

緩存更新模塊，用于根據處理結果更新緩存的數據；

轉換模塊，用于將服務器事件轉換成客戶端事件；

分發模塊，用于根據該服務器事件的分發列表，發送給對應的客戶端。

7.如權利要求6所述的裝置，其特征在于，所述確定模塊，具體用于判斷所述服務器事件的類型是否與自身預先注冊的事件類型一致，若一致，則確定所述服務器事件屬于自身需要處理的服務器事件；否則，確定所述服務器事件不屬于自身需要處理的服務器事件。

8.如權利要求6所述的裝置，其特征在于，所述第二事件處理模塊，包括：

隊列緩存子模塊，用于將各個服務器事件按照預設的優先級級別，分別緩存于對應級別的隊列中，每個隊列中服務器事件按照接收的時間先后排列；

分發子模塊，用于按照優先級的高低順序，依次從不同級別的隊列中取出該隊列中的服務器事件，并將所述服務器事件分發至對應級別的事件處理線程；

處理子模塊，用于通過所述事件處理線程調用服務器事件對應的事件處理類，對所述服務器事件進行處理。