[發明專利]一種分布式環境下的業務處理方法及裝置

在審

• 申請號: 201710934314.2
• 申請日: 2017-10-10
• 公開（公告）號: CN107832125A
• 公開（公告）日: 2018-03-23
• 發明（設計）人: 李麗
• 申請（專利權）人: 中國銀聯股份有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;H04L29/06;H04L29/08
• 代理公司: 北京同達信恒知識產權代理有限公司11291
• 代理人: 黃志華

技術領域

本發明涉及通信技術領域，尤其涉及一種分布式環境下的業務處理方法及裝置。

背景技術

分布式系統就是將各個組件(MySQL、PHP、Apache…)分布在網絡上的各臺主機上，把多臺主機有機的組合、連接起來，讓其協同完成一件任務，可以是計算任務，也可以是存儲任務，各組件之間僅通過消息傳遞來通信并協調工作。

目前分布式環境中，各個任務的執行分布在各個系統上，通過配置觸發時間來粗略的控制任務執行的先后順序，任務布置分散，需要多個技術架構實現。因此，現有技術中的分布式環境中，各任務無法協調執行，缺少統一管理監控機制，難以實現跨系統任務的有效調度。

發明內容

本申請提供一種分布式環境下的業務處理方法及，用以對分布式環境中的任務實現統一管理和監控。

本發明實施例提供一種分布式環境下的業務處理方法，包括以下步驟：

任務處理服務器從注冊中心數據庫中獲取待處理業務的任務執行規劃圖，所述任務執行規劃圖為根據處理所述待處理業務的多個任務執行單元生成；

所述任務處理服務器根據所述任務執行規劃圖依次調用所述多個任務執行單元，并獲取每個任務執行單元的執行結果；

所述任務處理服務器根據所述執行結果確定所述待處理業務的處理結果，并反饋所述待處理業務的處理結果。

可選的，所述任務處理服務器從注冊中心數據庫中獲取待處理業務的任務執行規劃圖之前，還包括：

所述任務處理服務器向所述注冊中心數據庫進行注冊；

所述依次調用所述多個任務執行單元，包括：

所述任務處理服務器從所述注冊中心數據庫獲取每個任務執行單元的調用信息，并根據所述調用信息依次調用對應的任務執行單元；所述任務執行單元的調用信息為所述任務執行單元在所述注冊中心數據庫注冊時，在所述注冊中心數據庫存儲。

可選的，所述任務執行規劃圖中包括每個任務執行單元的執行順序以及所述每個任務執行單元之間的依賴關系，所述每個任務執行單元之間的依賴關系包括串行執行和并行執行；

所述任務處理服務器根據所述任務執行規劃圖，依次調用所述多個任務執行單元，包括：

所述任務處理服務器根據每個任務執行單元的執行順序以及所述每個任務執行單元之間的依賴關系，依次調用所述多個任務執行單元。

可選的，所述多個任務執行單元分為主體任務執行單元和輔助任務執行單元；

所述任務處理服務器根據所述執行結果確定所述待處理業務的處理結果，包括：

若所述任務處理服務器獲取所述主體任務執行單元的執行結果失敗或超過時間閾值，則反饋所述待處理業務的處理結果為失敗；

若所述任務處理服務器獲取所述輔助任務執行單元的執行結果失敗或超過所述時間閾值，則跳過所述輔助任務執行單元，繼續依次調用所述輔助任務執行單元后續的任務執行單元。

可選的，所述注冊中心數據庫中還存儲有每個任務執行規劃圖的執行開始時間；

所述任務處理服務器從注冊中心數據庫中獲取待處理業務的任務執行規劃圖之前，還包括：

所述任務處理服務器接收所述注冊中心數據庫發送的所述任務執行規劃圖的啟動指令，所述任務執行規劃圖的啟動指令為所述注冊中心數據庫遍歷存儲的任務執行規劃圖，確定已到所述任務執行規劃圖的執行開始時間后發送的。

一種分布式環境下的業務處理裝置，包括：

獲取模塊，用于從注冊中心數據庫中獲取待處理業務的任務執行規劃圖，所述任務執行規劃圖為根據處理所述待處理業務的多個任務執行單元生成；

調用模塊，用于根據所述任務執行規劃圖依次調用所述多個任務執行單元，并獲取每個任務執行單元的執行結果；

結果模塊，用于根據所述執行結果確定所述待處理業務的處理結果，并反饋所述待處理業務的處理結果。

可選的，還包括注冊模塊，用于向所述注冊中心數據庫進行注冊；

所述調用模塊，具體用于從所述注冊中心數據庫獲取每個任務執行單元的調用信息，并根據所述調用信息依次調用對應的任務執行單元；所述任務執行單元的調用信息為所述任務執行單元在所述注冊中心數據庫注冊時，在所述注冊中心數據庫存儲。

可選的，所述任務執行規劃圖中包括每個任務執行單元的執行順序以及所述每個任務執行單元之間的依賴關系，所述每個任務執行單元之間的依賴關系包括串行執行和并行執行；