[發(fā)明專利]一種基于云平臺的分布式流程處理解決方法及系統(tǒng)

有效

• 申請?zhí)枺?/td>: 202110588986.9
• 申請日: 2021-05-28
• 公開（公告）號: CN113204575B
• 公開（公告）日: 2023-08-01
• 發(fā)明（設(shè)計）人: 胡建德
• 申請（專利權(quán)）人: 西藏寧算科技集團有限公司
• 主分類號: G06F16/2455
• 分類號: G06F16/2455;G06F16/23
• 代理公司: 南京蘇高專利商標事務(wù)所(普通合伙) 32204
• 代理人: 柏尚春

1.一種基于云平臺的分布式流程處理解決方法，其特征在于：包括以下步驟：

S1：程序啟動時啟動主流程入口，具體包括以下步驟：

S1.1：程序從數(shù)據(jù)庫中查詢數(shù)據(jù)，查詢條件為業(yè)務(wù)條件；

S1.2：數(shù)據(jù)查詢完畢后，開始組裝Step需要的數(shù)據(jù)格式；

S1.3：數(shù)據(jù)組裝完畢后，發(fā)送至MQ；

S2：將java的業(yè)務(wù)功能分為Step1、Step2、...、StepN，其中N為大于1的正整數(shù)，多個Step監(jiān)聽同一個MQ；

S3：在需要處理的業(yè)務(wù)數(shù)據(jù)來臨時，多個Step同時監(jiān)聽到該條數(shù)據(jù)，但該條數(shù)據(jù)僅會被全局中的一個Step所處理；

S4：Step處理業(yè)務(wù)數(shù)據(jù)，具體包括以下步驟：

S4.1：Step判斷業(yè)務(wù)數(shù)據(jù)的Step是否為當前態(tài)，若不是當前態(tài)則將數(shù)據(jù)重新發(fā)回MQ，若是當前態(tài)進入下一步；

S4.2：連接redis，對業(yè)務(wù)數(shù)據(jù)中唯一性ID進行加鎖，若加鎖成功，則處理當前業(yè)務(wù)，若加鎖失敗，結(jié)束當前任務(wù)；

S4.3：業(yè)務(wù)數(shù)據(jù)處理完畢后，將業(yè)務(wù)數(shù)據(jù)的當前狀態(tài)更新為下一個Step所需要的狀態(tài)，更新完畢后將業(yè)務(wù)數(shù)據(jù)推送至MQ，當前任務(wù)結(jié)束；

S4.4：若出現(xiàn)異常情況，將不同異常情況推送至補償隊列中，特殊處理。

2.根據(jù)權(quán)利要求1所述的一種基于云平臺的分布式流程處理解決方法，其特征在于：所述Step為多服務(wù)多副本模塊。

3.根據(jù)權(quán)利要求1所述的一種基于云平臺的分布式流程處理解決方法，其特征在于：所述MQ為集群環(huán)境。

4.根據(jù)權(quán)利要求1所述的一種基于云平臺的分布式流程處理解決方法，其特征在于：所述S2中的每個Step在集群環(huán)境中，每有一個服務(wù)對應(yīng)有一個Step副本。

5.根據(jù)權(quán)利要求1所述的一種基于云平臺的分布式流程處理解決方法，其特征在于：所述業(yè)務(wù)數(shù)據(jù)在被處理一次后必定會被消費。

6.根據(jù)權(quán)利要求1所述的一種基于云平臺的分布式流程處理解決方法，其特征在于：所述S4.2中對業(yè)務(wù)數(shù)據(jù)唯一性ID進行加鎖采用的是分布式鎖redisson。

7.一種基于云平臺的分布式流程處理解決系統(tǒng)，其特征在于：包括有核心控制模塊、消息模塊、事務(wù)模塊、網(wǎng)絡(luò)接口、存儲器和處理器，其中：

所述核心控制模塊用于數(shù)據(jù)的接入和組裝；

所述消息模塊用于每個Step之前的消息接入；

所述事務(wù)模塊用于分布式事務(wù)組件，為處理異常情況的數(shù)據(jù)庫；

所述所述網(wǎng)絡(luò)接口，用于在與其他外部網(wǎng)元之間進行收發(fā)信息過程中，實現(xiàn)信號的接收和發(fā)送；

所述存儲器，用于存儲能夠在所述處理器上運行的計算機程序指令；

所述處理器，用于在運行所述計算機程序指令時，執(zhí)行權(quán)利要求1-6中任一項所述的一種基于云平臺的分布式流程處理解決方法的步驟。

8.一種計算機存儲介質(zhì)，其特征在于：所述計算機存儲介質(zhì)存儲有一種基于云平臺的分布式流程處理解決方法的程序，所述一種基于云平臺的分布式流程處理解決方法的程序被至少一個處理器執(zhí)行時實現(xiàn)權(quán)利要求1～6中任一項所述的一種基于云平臺的分布式流程處理解決方法的步驟。