[發(fā)明專利]分布式事務(wù)的處理方法和分布式系統(tǒng)

在審

• 申請(qǐng)?zhí)枺?/td>: 201811344537.4
• 申請(qǐng)日: 2018-11-13
• 公開(kāi)（公告）號(hào): CN109491767A
• 公開(kāi)（公告）日: 2019-03-19
• 發(fā)明（設(shè)計(jì)）人: 王天才;李京賢
• 申請(qǐng)（專利權(quán)）人: 上海聯(lián)寓智能科技有限公司
• 主分類號(hào): G06F9/46
• 分類號(hào): G06F9/46;G06F9/54
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 孟金喆

1.一種分布式事務(wù)的處理方法，其特征在于，包括：

被調(diào)用參與節(jié)點(diǎn)在接收到調(diào)用參與節(jié)點(diǎn)發(fā)送的調(diào)用請(qǐng)求后，根據(jù)所述調(diào)用請(qǐng)求中的調(diào)用信息執(zhí)行相應(yīng)的調(diào)用操作，并在所述調(diào)用操作執(zhí)行完成后，向發(fā)送所述調(diào)用請(qǐng)求的調(diào)用參與節(jié)點(diǎn)返回調(diào)用完成信息；

被調(diào)用參與節(jié)點(diǎn)根據(jù)所述調(diào)用請(qǐng)求中的本地事務(wù)信息處理相應(yīng)的本地事務(wù)，生成處理結(jié)果，并將所述處理結(jié)果返回給發(fā)送所述調(diào)用請(qǐng)求的調(diào)用參與節(jié)點(diǎn)。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，還包括：

事務(wù)流程引擎獲取所述處理結(jié)果；

事務(wù)流程引擎根據(jù)所述處理結(jié)果判斷是否存在本地事務(wù)處理失敗的被調(diào)用參與節(jié)點(diǎn)，若存在，則通過(guò)分布式系統(tǒng)中的事務(wù)協(xié)調(diào)者控制當(dāng)前分布式事務(wù)的全部被調(diào)用參與節(jié)點(diǎn)回滾自身執(zhí)行的本地事務(wù)；若不存在，則通過(guò)分布式系統(tǒng)中的事務(wù)協(xié)調(diào)者控制各被調(diào)用參與節(jié)點(diǎn)提交自身執(zhí)行的本地事務(wù)的處理結(jié)果。

3.根據(jù)權(quán)利要求2所述的方法，其特征在于，還包括：

事務(wù)流程引擎獲取當(dāng)前分布式事務(wù)的全部被調(diào)用參與節(jié)點(diǎn)執(zhí)行相應(yīng)操作的執(zhí)行結(jié)果，其中，所述相應(yīng)操作包括回滾自身執(zhí)行的本地事務(wù)的回滾操作或提交自身執(zhí)行的本地事務(wù)的處理結(jié)果的提交操作；

事務(wù)流程引擎在根據(jù)所述執(zhí)行結(jié)果確定存在所述相應(yīng)操作執(zhí)行失敗的目標(biāo)節(jié)點(diǎn)時(shí)，控制所述目標(biāo)節(jié)點(diǎn)重復(fù)執(zhí)行所述相應(yīng)操作，直至當(dāng)前條件滿足所述相應(yīng)操作的停止執(zhí)行條件為止。

4.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述事務(wù)流程引擎獲取所述處理結(jié)果，包括：

事務(wù)流程引擎接收分布式系統(tǒng)中的事務(wù)協(xié)調(diào)者發(fā)送的各處理結(jié)果；

相應(yīng)的，被調(diào)用參與節(jié)點(diǎn)通過(guò)嵌入的事務(wù)切面獲取相應(yīng)被調(diào)用參與節(jié)點(diǎn)的處理結(jié)果，并將所述處理結(jié)果發(fā)送給分布式系統(tǒng)中的事務(wù)協(xié)調(diào)者；

事務(wù)協(xié)調(diào)者將接收到的所述處理結(jié)果發(fā)送給所述事務(wù)流程引擎。

5.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述根據(jù)所述調(diào)用請(qǐng)求中的調(diào)用信息執(zhí)行相應(yīng)的調(diào)用操作，包括：

將自身注冊(cè)至分布式系統(tǒng)的事務(wù)管理器中；以及，

根據(jù)所述調(diào)用請(qǐng)求中的調(diào)用信息確定是否存在需調(diào)用的下一被調(diào)用參與節(jié)點(diǎn)；如果存在，則生成對(duì)所述下一被調(diào)用參與節(jié)點(diǎn)進(jìn)行調(diào)用的調(diào)用請(qǐng)求，將生成的調(diào)用請(qǐng)求發(fā)送給所述下一被調(diào)用參與節(jié)點(diǎn)，并接收所述下一被調(diào)用參與節(jié)點(diǎn)返回的調(diào)用完成信息。

6.根據(jù)權(quán)利要求5所述的方法，其特征在于，所述將自身注冊(cè)至分布式系統(tǒng)的事務(wù)管理器中，包括：

通過(guò)嵌入的事務(wù)切面將自身的節(jié)點(diǎn)信息發(fā)送給分布式系統(tǒng)的事務(wù)管理器，以使所述事務(wù)管理器記錄所述節(jié)點(diǎn)信息，所述節(jié)點(diǎn)信息包括所述被調(diào)用參與節(jié)點(diǎn)的IP地址。

7.根據(jù)權(quán)利要求要求1所述的方法，其特征在于，在所述根據(jù)所述調(diào)用請(qǐng)求中的調(diào)用信息執(zhí)行相應(yīng)的調(diào)用操作之前，還包括：

確定所述調(diào)用請(qǐng)求為尚未執(zhí)行的調(diào)用請(qǐng)求。

8.一種分布式系統(tǒng)，其特征在于，包括至少一個(gè)被調(diào)用參與節(jié)點(diǎn)和至少一個(gè)調(diào)用參與節(jié)點(diǎn)，其中，

被調(diào)用參與節(jié)點(diǎn)，用于在接收到調(diào)用參與節(jié)點(diǎn)發(fā)送的調(diào)用請(qǐng)求后，根據(jù)所述調(diào)用請(qǐng)求中的調(diào)用信息執(zhí)行相應(yīng)的調(diào)用操作，并在所述調(diào)用操作執(zhí)行完成后，向發(fā)送所述調(diào)用請(qǐng)求的調(diào)用參與節(jié)點(diǎn)返回調(diào)用完成信息；以及，根據(jù)所述調(diào)用請(qǐng)求中的本地事務(wù)信息處理相應(yīng)的本地事務(wù)，生成處理結(jié)果，并將所述處理結(jié)果返回給發(fā)送所述調(diào)用請(qǐng)求的調(diào)用參與節(jié)點(diǎn)。

9.根據(jù)權(quán)利要求8所述的系統(tǒng)，其特征在于，還包括事務(wù)流程引擎和事務(wù)協(xié)調(diào)者，其中，

事務(wù)流程引擎，用于獲取所述處理結(jié)果，并根據(jù)所述處理結(jié)果判斷是否存在本地事務(wù)處理失敗的被調(diào)用參與節(jié)點(diǎn)，若存在，則通過(guò)事務(wù)協(xié)調(diào)者控制當(dāng)前分布式事務(wù)的全部被調(diào)用參與節(jié)點(diǎn)回滾自身執(zhí)行的本地事務(wù)；若不存在，則通過(guò)事務(wù)協(xié)調(diào)者控制各被調(diào)用參與節(jié)點(diǎn)提交自身執(zhí)行的本地事務(wù)的處理結(jié)果。

10.根據(jù)權(quán)利要求9所述的系統(tǒng)，其特征在于，事務(wù)流程引擎還用于：

獲取當(dāng)前分布式事務(wù)的全部被調(diào)用參與節(jié)點(diǎn)執(zhí)行相應(yīng)操作的執(zhí)行結(jié)果，其中，所述相應(yīng)操作包括回滾自身執(zhí)行的本地事務(wù)的回滾操作或提交自身執(zhí)行的本地事務(wù)的處理結(jié)果的提交操作；

在根據(jù)所述執(zhí)行結(jié)果確定存在所述相應(yīng)操作執(zhí)行失敗的目標(biāo)節(jié)點(diǎn)時(shí)，控制相應(yīng)所述目標(biāo)節(jié)點(diǎn)重復(fù)執(zhí)行所述相應(yīng)操作，直至當(dāng)前條件滿足所述相應(yīng)操作的停止執(zhí)行條件為止。