[發明專利]一種基于長連接的消息處理方法和消息處理裝置

在審

• 申請號: 201310425410.6
• 申請日: 2013-09-17
• 公開（公告）號: CN103457841A
• 公開（公告）日: 2013-12-18
• 發明（設計）人: 李睿
• 申請（專利權）人: 北京京東尚科信息技術有限公司
• 主分類號: H04L12/58
• 分類號: H04L12/58;H04L29/08;G06F17/30
• 代理公司: 中原信達知識產權代理有限責任公司 11219
• 代理人: 劉光明;陸錦華

1.一種基于長連接的消息處理方法，其特征在于，包括：

對于服務器集群中的各個服務器，該服務器使用一個或多個線程管理與自身與客戶端的長連接，每個所述線程用于維持預設數目個所述長連接；

所述服務器獲取來自于消息源的消息，然后將該消息提供給訂閱該消息的客戶端。

2.根據權利要求1所述的消息處理方法，其特征在于，所述將該消息提供給訂閱該消息的客戶端的步驟包括：

所述服務器從自身連接的消息源獲取消息，確認訂閱該消息的客戶端與所述服務器連接，然后將該消息發送給該客戶端。

3.根據權利要求1所述的消息處理方法，其特征在于，所述將該消息提供給訂閱該消息的客戶端的步驟包括：

所述服務器從自身連接的消息源獲取消息，確認訂閱該消息的客戶端與所述服務器集群中的另一服務器連接，然后將該消息發送給該另一服務器，以供該另一服務器將該消息發送給訂閱該消息的客戶端。

4.根據權利要求1，2或3所述的消息處理方法，其特征在于，所述將該消息提供給訂閱該消息的客戶端的步驟之前，還包括：所述服務器根據所述客戶端的配置信息對該客戶端訂閱的消息進行過濾。

5.根據權利要求1，2或3所述的消息處理方法，其特征在于，所述將該消息提供給訂閱該消息的客戶端的步驟之后，還包括：

所述服務器確認該消息發送失敗，然后記錄發送失敗的時間；

所述服務器確認與該客戶端的長連接恢復，然后向該客戶端發送包含所述發送失敗的時間的丟包消息，以供所述客戶端根據所述丟包消息查詢所述發送失敗的消息。

6.一種基于長連接的消息處理裝置，設置在服務器集群中的各個服務器中，其特征在于，所述消息處理裝置包括：

長連接管理模塊，用于使用一個或多個線程管理所述服務器與客戶端的長連接，每個所述線程用于維持預設數目個所述長連接；

獲取發送模塊，用于獲取來自于消息源的消息，然后將該消息提供給訂閱該消息的客戶端。

7.根據權利要求6所述的消息處理裝置，其特征在于，所述獲取發送模塊還用于：

從所述服務器連接的消息源獲取消息，確認訂閱該消息的客戶端與所述服務器連接，然后將該消息發送給該客戶端。

8.根據權利要求6所述的消息處理裝置，其特征在于，所述獲取發送模塊還用于：

所述服務器從自身連接的消息源獲取消息，確認訂閱該消息的客戶端與所述服務器集群中的另一服務器連接，然后將該消息發送給該另一服務器；以及，

接收另一服務器發送的消息，然后將該消息發送給自身連接的訂閱該消息的客戶端。

9.根據權利要求6，7或8所述的消息處理裝置，其特征在于，所述獲取發送模塊還用于對獲取的所述客戶端訂閱的消息根據所述客戶端的配置信息對該客戶端訂閱的消息進行過濾。

10.根據權利要求6，7或8所述的消息處理裝置，其特征在于，還包括失敗處理模塊，用于在所述獲取發送模塊將客戶端訂閱的消息發送給該客戶端之后，確認該消息發送失敗，然后記錄發送失敗的時間，以及確認與該客戶端的長連接恢復，然后向該客戶端發送包含所述發送失敗的時間的丟包消息，以供所述客戶端根據所述丟包消息查詢所述發送失敗的消息。