[發明專利]一種分布式事物處理的方法、裝置及系統

在審

• 申請號: 201610036871.8
• 申請日: 2016-01-20
• 公開（公告）號: CN106991087A
• 公開（公告）日: 2017-07-28
• 發明（設計）人: 傅玉寶
• 申請（專利權）人: 阿里巴巴集團控股有限公司
• 主分類號: G06F17/30
• 分類號: G06F17/30;G06F9/54
• 代理公司: 北京三友知識產權代理有限公司11127
• 代理人: 黨曉林,李輝

技術領域

本申請涉及通信技術領域，特別涉及一種分布式事物處理的方法、裝置及系統。

背景技術

為了完成網商銀行的一項業務，往往需要調用多個子系統，因此子系統間的依賴關系比較復雜，而子系統之間的依賴越多，每個子系統的可用性就越重要，如果整個系統中涉及的某一個子系統無法提供服務，則可能導致整個業務無法完成，降低了整個系統的可用性。

可以參見圖1所示為現有技術的上游子系統和下游子系統之間發送消息的示意圖，在該圖中上游子系統例如可以為支付系統，下游子系統例如可以為發貨系統，當用戶在支付系統完成支付后，由支付系統通過中間的消息系統通知發貨系統進行發貨，如果中間的消息系統出現問題，或者發貨系統出現問題，則可能導致該發貨業務無法完成，整個系統的可用性較低。

發明內容

為了解決現有技術中由于某個子系統出現問題不能提供服務，導致整個系統可用性低的問題，提供了一種分布式事物處理的方法、裝置及系統，通過將通知消息存儲于上游子系統的數據庫中，通過中間件定時將數據庫中新的通知消息發送給下游子系統，從而避免了現有技術中對每個子系統可用性要求過高的問題。

本申請實施例提供了一種分布式事物處理方法，包括：

根據上游子系統的業務處理結果，生成通知消息；

將所述通知消息存儲于數據庫中。

本申請實施例還提供了一種分布式事物處理方法，包括：

定時掃描存儲有上游子系統生成的通知消息的數據庫；

將所述數據庫中新加入的通知消息發送給相應的下游子系統；

接收所述下游子系統返回的對所述通知消息的處理結果；

根據所述處理結果對所述數據庫中相應的通知消息進行處理。

本申請實施例還提供了一種上游子系統，包括，

生成單元，用于根據上游子系統的業務處理結果，生成通知消息；

存儲單元，用于將所述通知消息存儲于數據庫中。

本申請實施例還提供了一種同步裝置，包括：

掃描單元，用于定時掃描存儲有上游子系統生成的通知消息的數據庫；

發送單元，用于將所述數據庫中新加入的通知消息發送給相應的下游子系統；

接收單元，用于接收所述下游子系統返回的對所述通知消息的處理結果；

處理單元，用于根據所述處理結果對所述數據庫中相應的通知消息進行處理。

本申請實施例還提供了一種分布式事物處理系統，包括：

上游子系統，用于根據上游子系統的業務處理結果，生成通知消息，并將所述通知消息存儲于數據庫中；

同步裝置，用于定時掃描存儲有上游子系統生成的通知消息的數據庫，將所述數據庫中新加入的通知消息發送給相應的下游子系統，接收所述下游子系統返回的對所述通知消息的處理結果，并根據所述處理結果對所述數據庫中相應的通知消息進行處理。

由以上本申請實施例提供的技術方案可見，將通知消息存儲在上游子系統中，令同步裝置定時獲取通知消息，并將該通知消息發送給下游子系統，實現了上游子系統和下游子系統之間的隔離，提高了整個分布式事務處理系統的可用性，即便下游子系統不能工作，也可以在恢復正常后通過同步裝置自動查詢通知消息，并進行同步，還可以減少對每個上游子系統和下游子系統之間通信的編碼成本。

當然實施本申請的任一產品或者方法必不一定需要同時達到以上所述的所有優點。

附圖說明

為了更清楚地說明本申請實施例或現有技術中的技術方案，下面將對實施例或現有技術描述中所需要使用的附圖作簡單地介紹，顯而易見地，下面描述中的附圖僅僅是本申請中記載的一些實施例，對于本領域普通技術人員來講，在不付出創造性勞動性的前提下，還可以根據這些附圖獲得其他的附圖。

圖1所示為本申請實施例一種分布式事物處理方法的流程圖；

圖2所示為本申請實施例一種分布式事物處理方法的流程圖；

圖3所示為本申請實施例一種上游子系統結構示意圖；

圖4所示為本申請實施例一種同步裝置結構示意圖；

圖5所示為本申請實施例一種分布式事物處理系統的結構示意圖；

圖6所示為本申請實施例一種分布式事物處理系統的具體數據流圖。

具體實施方式

本申請實施例提供一種分布式事物處理的方法、裝置及系統。