[發明專利]一種分散調度自治的流程引擎負載均衡集群系統及方法

有效

• 申請號: 201110242406.7
• 申請日: 2011-08-23
• 公開（公告）號: CN102394807A
• 公開（公告）日: 2012-03-28
• 發明（設計）人: 孫剛;高昊江
• 申請（專利權）人: 北京京北方信息技術有限公司
• 主分類號: H04L12/56
• 分類號: H04L12/56;H04L29/08
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 陳慧珍

1.一種分散調度自治的流程引擎負載均衡集群系統，其特征在于：所述系統包括：

流程引擎集群，包括多個集群節點組，其中每個所述集群節點組包括多個集群節點，每個所述集群節點又包括多個流程引擎；

請求池，用以存放客戶端發起的流程服務請求；

流程引擎信息布告板，用以通報當前可用的流程引擎的列表信息；

客戶端系統，包括有多個引擎序號輪轉器，采用輪轉引擎序號的方法計算分散調度各個流程引擎；處于工作狀態的流程引擎按固定輪詢周期從請求池取出屬于本引擎的請求，然后進行流程處理。

2.如權利要求1所述的系統，其特征在于：

每個所述集群節點組設置有心跳起搏器，用于記錄該集群節點組的心跳信息，每個所述心跳起搏器對應一個心跳控制鎖，并由取得所述心跳控制鎖的集群節點維護整個集群節點組的心跳信息；

每個所述集群節點組在某個時刻只有一個集群節點處于工作狀態，其它的集群節點處于伺服狀態，處于工作狀態的集群節點負責維護整個集群節點組的心跳信息。

3.如權利要求1或2所述的系統，其特征在于：

每個所述集群節點設置有一個節點控制器，用于啟動時探測集群節點所屬集群節點組的心跳信息，如果發現心跳停止，則搶占所述心跳控制鎖，如果搶占成功，則啟動心跳，并切換到工作狀態；否則，如果未發現心跳停止且心跳節點是其它節點，或者搶占心跳控制鎖失敗，則就切換到伺服狀態；

處于伺服狀態的集群節點會按固定周期來探測集群節點組的心跳信息，如果發現心跳停止，則按上一步驟所述切換到工作狀態；

處于工作狀態的集群節點會按固定周期來探測心跳節點是否被其它集群節點搶占，如果被搶占，則就切換到伺服狀態。

4.如權利要求1至3之一所述的系統，其特征在于：

處于工作狀態的集群節點的每個流程引擎設置一個引擎心跳器，用于記錄該引擎的心跳時間，所述節點控制器定時檢查其內的各個引擎心跳器，如果發現某一個或多個心跳停止，則停止集群節點內的所有引擎，并停止對集群節點組心跳起搏器的占用，切換到伺服狀態。

5.如權利要求1至4之一所述的系統，其特征在于：

同一個集群節點組內的集群節點會按固定周期來探測節點組的心跳信息，一旦發現心跳停止，則按上述步驟代替出問題的節點進行工作。

6.如權利要求1或2所述的系統，其特征在于：

客戶端查閱流程引擎信息布告板，計算可用引擎的總個數；

客戶端初始化所含引擎序號輪轉器，引擎序號輪轉器上的值對應相應的流程引擎，將可用引擎總個數設為引擎序號輪轉器的最大閾值，當超過此值時，引擎序號輪轉器重新歸零；

發起新流程前，采用輪轉引擎序號輪轉器的方法將引擎序號輪轉器的當前值加1，計算請求應該分配給哪個流程引擎，以將客戶端系統的請求平均分配給各個流程引擎。

7.如權利要求1或2所述的系統，其特征在于：

客戶端采用異步消息的方式將流程服務請求發送給請求池，或者客戶端采用同步通信的方式直接調用指定引擎的流程服務。

8.一種分散調度自治的流程引擎負載均衡集群方法，其特征在于：該方法將流程引擎集群分為多個集群節點組，每個所述集群節點組還分為多個集群節點，每個所述集群節點又進一步細分為多個流程引擎，其中所述集群節點是集群服務器，所述方法具體包括如下步驟：

步驟01：啟動各個集群服務器節點；

步驟02：客戶端系統啟動時發現集群服務器節點及其所含引擎服務器列表；

步驟03：客戶端初始化引擎序號輪轉器；

步驟04：客戶端在請求前輪轉引擎序號輪轉器；

步驟05：判斷是否為同步模式，如果是同步模式，則請求直接發往相應的流程引擎；如果不是同步模式，則請求被發往請求池，請求中包含引擎序號信息；

步驟06：如果是異步模式，處于工作狀態的集群服務器節點的流程引擎按固定輪詢周期從請求池取出與自身序號對應的服務請求；

步驟07：流程引擎處理請求。