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

在審

• 申請號: 201610519778.2
• 申請日: 2016-07-04
• 公開（公告）號: CN106909599A
• 公開（公告）日: 2017-06-30
• 發明（設計）人: 趙振林
• 申請（專利權）人: 阿里巴巴集團控股有限公司
• 主分類號: G06F17/30
• 分類號: G06F17/30;H04L29/08
• 代理公司: 北京同達信恒知識產權代理有限公司11291
• 代理人: 郭潤湘

1.一種集群系統，其特征在于，該集群系統包括：多臺主機；其中：

所述多臺主機，用于競爭獲取互斥鎖；所述互斥鎖在同一時刻只能被集群系統中的一臺主機占用；

所述多臺主機中的第一主機，用于在獲取到所述互斥鎖后，啟動所述第一主機的數據增量引擎；其中，所述數據增量引擎用于接收集群系統外的服務器發送的待處理消息，并將所述待處理消息寫入集群系統的消息隊列中。

2.如權利要求1所述的集群系統，其特征在于，所述第一主機還用于：

在獲取到所述互斥鎖后，按照預設的第一時間間隔更新所述互斥鎖中的第一關鍵key值；所述第一key值用于判斷所述數據增量引擎是否工作正常。

3.如權利要求2所述的集群系統，其特征在于，所述第一key值為心跳時間戳。

4.如權利要求2或3所述的集群系統，其特征在于，所述多臺主機中的任一主機具體用于：

檢測所述互斥鎖中的第一key值，在確定所述第一key值沒有被正常更新后，獲取所述互斥鎖。

5.如權利要求4所述的集群系統，其特征在于，所述多臺主機中的任一主機具體用于：

在所述第一key值在預設時長內沒有被更新時，確定所述第一key值沒有被正常更新；或者，

在所述第一key值為空時，確定所述第一key值沒有被正常更新。

6.如權利要求1所述的集群系統，其特征在于，所述第一主機還用于：

在啟動所述第一主機的數據增量引擎后，更新所述互斥鎖中的第二關鍵key值；所述第二key值用于標識當前獲取互斥鎖并啟動數據增量引擎的主機。

7.如權利要求6所述的集群系統，其特征在于，所述多臺主機中的任一主機還用于：

按照預設的第二時間間隔，檢測所述互斥鎖中的第二key值；

判斷檢測到的所述第二key值所標識的主機是否為所述任一主機；

若不是，且所述任一主機的數據增量引擎當前處于工作狀態，則關閉所述任一主機的數據增量引擎。

8.一種集群系統，其特征在于，該集群系統包括：多臺主機，其中：

所述多臺主機，用于競爭獲取分布式鎖；所述分布式鎖在同一時刻只能被集群系統中的一臺主機占用；

所述多臺主機中的第一主機，用于在獲取到所述分布式鎖后，啟動所述第一主機的數據增量引擎；其中，所述數據增量引擎用于接收集群系統外的服務器發送的待處理消息，并將所述待處理消息寫入集群系統的消息隊列中。

9.一種消息處理方法，其特征在于，該方法包括：

第一主機與集群系統中的其它主機競爭獲取互斥鎖；所述互斥鎖在同一時刻只能被集群系統中的一臺主機占用；

在獲取到所述互斥鎖后，啟動所述第一主機的數據增量引擎；

其中，所述數據增量引擎用于接收集群外的服務器發送的待處理消息，并將所述待處理消息寫入集群的消息隊列中。

10.如權利要求9所述的方法，其特征在于，第一主機與集群系統中的其它主機競爭獲取互斥鎖，包括：

檢測集群系統的互斥鎖中的第一key值；在確定所述第一key值沒有被正常更新后，獲取所述互斥鎖；所述第一key值用于判斷所述數據增量引擎是否工作正常。

11.如權利要求10所述的方法，其特征在于，所述確定所述第一key值沒有被正常更新，包括：

在所述第一key值在預設時長內沒有被更新時，確定所述第一key值沒有被正常更新；或者，

在所述第一key值為空時，確定所述第一key值沒有被正常更新。

12.如權利要求10所述的方法，其特征在于，所述方法還包括：

在獲取到所述互斥鎖后，按照預設的第一時間間隔更新所述互斥鎖中的第一關鍵key值。

13.如權利要求9所述的方法，其特征在于，所述方法還包括：

在啟動所述第一主機的數據增量引擎后，更新所述互斥鎖中的第二關鍵key值；所述第二key值用于標識當前獲取互斥鎖并啟動數據增量引擎的主機。