[發明專利]一種消息處理方法、服務器集群及系統

有效

• 申請號: 201710262421.5
• 申請日: 2017-04-20
• 公開（公告）號: CN106878473B
• 公開（公告）日: 2021-03-30
• 發明（設計）人: 張曉宇;周維躍;莊秋濤;謝家提
• 申請（專利權）人: 騰訊科技（深圳）有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 深圳市深佳知識產權代理事務所(普通合伙) 44285
• 代理人: 王仲凱

1.一種消息處理方法，其特征在于，應用于服務器集群，所述服務器集群包括多個隊列服務器，所述方法包括：

目標隊列服務器獲得第一客戶端發送的請求消息，所述目標隊列服務器是所述多個隊列服務器中的任意一個隊列服務器，將所述多個隊列服務器中的其他隊列服務器作為備份隊列服務器；

所述目標隊列服務器通過一致性算法按照請求順序將所述請求消息寫入目標日志文件，并將所得的最新日志文件按照預設順序，通過網絡依次發送至各備份隊列服務器進行同步處理；

所述備份隊列服務器將同步的所述請求消息推送至對應的備份消息隊列存儲，并向所述目標隊列服務器反饋備份完成信息；

所述目標隊列服務器接收到第一預設數量的所述備份隊列服務器反饋的所述備份完成信息，將所述請求消息提交至所述目標隊列服務器的消息隊列MQ狀態機，再由所述MQ狀態機將所述請求消息寫入目標消息隊列存儲，并向所述第一客戶端反饋針對所述請求消息的成功響應信息，所述目標消息隊列中的請求消息具備被多次重復讀取的特性。

2.根據權利要求1所述的方法，其特征在于，所述方法還包括：

檢測到所述目標隊列服務器工作異常，按照預設算法，重新選擇所述服務器集群的目標隊列服務器。

3.根據權利要求2所述的方法，其特征在于，所述檢測到所述目標隊列服務器工作異常，按照預設算法，重新選擇所述服務器集群的目標隊列服務器，包括：

所述備份隊列服務器判斷第一預設時間內是否接收到所述目標隊列服務器發送的續期信息；

如果否，所述備份隊列服務器轉變為候選隊列服務器，并向所述服務器集群中的其他隊列服務器發送選舉請求；

所述候選隊列服務器判斷接收到的針對所述選舉請求的響應信息數量是否達到第二預設數量；

如果達到，所述候選隊列服務器轉變為新的目標隊列服務器，并向所述服務器集群中的其他隊列服務器發送所述續期信息；

如果未達到，所述候選隊列服務器經第二預設時間向所述服務器集群中的其他隊列服務器再次發送所述選舉請求，直至接收到的所述響應信息數量達到所述第二預設數量，或者接收到新的目標隊列服務器發送的續期信息。

4.根據權利要求1所述的方法，其特征在于，所述方法還包括：

所述目標隊列服務器檢測所述目標消息隊列存儲的請求消息的存儲時間是否達到預設閾值；

基于檢測結果，刪除達到所述預設閾值的存儲時間對應的請求消息，并觸發所述備份隊列服務器同步所述目標隊列服務器的刪除操作。

5.根據權利要求1所述的方法，其特征在于，所述方法還包括：

所述目標隊列服務器接收第二客戶端發送的消息讀取請求；

所述目標隊列服務器響應所述消息讀取請求，確定目標請求消息；

所述目標隊列服務器將所述目標請求消息發送至所述第二客戶端；

所述目標隊列服務器接收到所述第二客戶端發送的消息讀取完成信息，刪除目標消息隊列存儲的所述目標請求消息。

6.根據權利要求1所述的方法，其特征在于，所述方法還包括：

所述目標隊列服務器將目標消息隊列存儲的請求消息推送至相應的第二客戶端。

7.一種服務器集群，其特征在于，包括：一個目標隊列服務器以及多個備份隊列服務器，其中：

所述目標隊列服務器，用于獲得第一客戶端發送的請求消息，并通過一致性算法按照請求順序將所述請求消息寫入目標日志文件，將所得的最新日志文件按照預設順序，通過網絡依次發送至各備份隊列服務器進行同步處理；

所述備份隊列服務器，用于將同步的所述請求消息推送至對應的備份消息隊列存儲，并向所述目標隊列服務器反饋備份完成信息，以使所述目標隊列服務器接收到第一預設數量的所述備份隊列服務器反饋的所述備份完成信息，將所述請求消息提交至所述目標隊列服務器的MQ狀態機，再由所述MQ狀態機將所述請求消息寫入目標消息隊列存儲，并向所述第一客戶端反饋針對所述請求消息的成功響應信息，所述目標消息隊列中的請求消息具備被多次重復讀取的特性。