[發明專利]事件分發方法及系統

有效

• 申請號: 201410183080.9
• 申請日: 2014-04-30
• 公開（公告）號: CN103927218B
• 公開（公告）日: 2017-07-04
• 發明（設計）人: 陸海鵬;陳敏;蘇青章
• 申請（專利權）人: 廣州唯品會網絡技術有限公司
• 主分類號: G06F9/455
• 分類號: G06F9/455
• 代理公司: 廣州市越秀區哲力專利商標事務所(普通合伙)44288
• 代理人: 湯喜友

1.事件分發方法，其特征在于，包括以下步驟：

步驟1、消息隊列集群接收來自管理服務器的注冊的事件和因用戶的訂閱操作而產生的訂閱配置信息，所述事件與消息隊列集群中的一個消息隊列服務器進行對應綁定，所述訂閱配置信息包括訂閱的事件、事件處理并發數和事件處理地址；

步驟2、代理服務器主動拉取消息隊列集群中全部的事件信息并進行保存；

步驟3、執行服務器主動拉取消息隊列集群中全部的訂閱配置信息并進行保存；

步驟4、代理服務器接收用戶發起的事件消息，并根據事件與消息隊列服務器的綁定信息，將所述事件消息推送至對應的消息隊列服務器；

步驟5、執行服務器在消息隊列集群中拉取所述事件消息，并根據訂閱配置信息，對所述事件消息進行并發控制和發送至事件處理地址；

其中，步驟2和步驟3的執行順序不受限制；

不同機房的消息隊列集群的事件和訂閱配置信息主動進行實時同步操作。

2.如權利要求1所述的事件分發方法，其特征在于，在步驟1中，注冊的事件具有重要度標記，所述重要度標記包括持久化標記和非持久化標記。

3.如權利要求2所述的事件分發方法，其特征在于，在步驟4中，若所述事件消息推送失敗，則進一步判斷與所述事件消息對應的事件重要度標記，若所述重要度標記為持久化標記，則將所述事件消息暫存至其數據庫中并進行再次推送，若所述重要度標記為非持久化標記，則丟棄所述事件消息。

4.事件分發系統，其特征在于，包括以下裝置：

消息中間件，其設于消息隊列集群，用于接收來自管理服務器的注冊的事件和因用戶的訂閱操作而產生的訂閱配置信息，所述事件與消息隊列集群中的一個消息隊列服務器進行對應綁定，所述訂閱配置信息包括訂閱的事件、事件處理并發數和事件處理地址；

第一拉取模塊，其設于代理服務器，用于主動拉取消息隊列集群中全部的事件信息并進行保存；

第二拉取模塊，其設于執行服務器，用于主動拉取消息隊列集群中全部的訂閱配置信息并進行保存；

推送模塊，其設于代理服務器，用于接收用戶發起的事件消息，并根據事件與消息隊列服務器的綁定信息，將所述事件消息推送至對應的消息隊列服務器；

執行模塊，其設于執行服務器，用于在消息隊列集群中拉取所述事件消息，并根據訂閱配置信息，對所述事件消息進行并發控制和發送至事件處理地址；

其中，第一拉取模塊和第二拉取模塊的執行順序不受限制；不同機房的消息隊列集群的事件和訂閱配置信息主動進行實時同步操作。

5.如權利要求4所述的事件分發系統，其特征在于，在消息中間件中，注冊的事件具有重要度標記，所述重要度標記包括持久化標記和非持久化標記。

6.如權利要求5所述的事件分發系統，其特征在于，在推送模塊中，若所述事件消息推送失敗，則進一步判斷與所述事件消息對應的事件重要度標記，若所述重要度標記為持久化標記，則將所述事件消息暫存至其數據庫中并進行再次推送，若所述重要度標記為非持久化標記，則丟棄所述事件消息。