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

在審

• 申請?zhí)枺?/td>: 202011297402.4
• 申請日: 2020-11-18
• 公開（公告）號: CN112527472A
• 公開（公告）日: 2021-03-19
• 發(fā)明（設計）人: 歐中洪;易思紹;閆嘯;宋美娜
• 申請（專利權）人: 北京郵電大學
• 主分類號: G06F9/46
• 分類號: G06F9/46;G06F9/54;G06F16/25
• 代理公司: 北京清亦華知識產權代理事務所(普通合伙) 11201
• 代理人: 韓海花

本申請?zhí)岢鲆环N基于微服務的分布式事務處理系統(tǒng)和方法，涉及數(shù)據(jù)處理技術領域，其中，系統(tǒng)包括：包括：第一系統(tǒng)向消息中間件發(fā)送預設消息，在發(fā)送成功的情況下，第一系統(tǒng)對第一數(shù)據(jù)庫進行操作，并向消息中間件發(fā)送確認消息；第二系統(tǒng)通過消息中間件接收確認信息，第二系統(tǒng)對第二數(shù)據(jù)庫進行操作，并向消息中間件發(fā)送回執(zhí)消息；在第一系統(tǒng)向消息中間件發(fā)送確認消息之后，在分布式應用程序協(xié)調服務建立消息節(jié)點并持續(xù)監(jiān)聽，在獲取第二系統(tǒng)對第二數(shù)據(jù)庫進行操作失敗的情況下，向第一系統(tǒng)發(fā)送執(zhí)行失敗信息，以使第一系統(tǒng)再次發(fā)送確認消息。由此，實現(xiàn)了多個系統(tǒng)分布式事務一致性問題，并且實現(xiàn)了最終一致性和可靠消息傳遞。

技術領域

本申請涉及數(shù)據(jù)處理技術領域，尤其涉及一種基于微服務的分布式事務處理系統(tǒng)和方法。

背景技術

在微服務下，系統(tǒng)會拆分為若干個子系統(tǒng)，當一個實例需要跨過多子系統(tǒng)才能完成時候時，為了保證整個過程的一致性，此時需要使用分布式事務的一種解決方案。比如：典型的購物網站的下單支付流程，至少會涉及交易系統(tǒng)和支付系統(tǒng)，整個過程是必須保證強一致性。由于分布式事務中事務的參與者，支持事務的服務器，資源服務器以及事務管理器分別為了不同的系統(tǒng)的不同節(jié)點上，給分布式事務的實施帶來了巨大的阻礙。

相關技術中，將長事務拆分為多個本地短事務并通過事務協(xié)調器協(xié)調，如果正常結束意味事務提交成功，如果某個步驟失敗，則根據(jù)相反順序依次調用補償操作，然而服務之間存在循環(huán)依賴的故障風險，以及當涉及的步驟較多，服務間關系混亂，難以跟蹤服務鏈路和服務測試。

發(fā)明內容

本申請旨在至少在一定程度上解決相關技術中的技術問題之一。

為此，本申請的第一個目的在于提出一種基于微服務的分布式事務處理系統(tǒng)，通過基于消息中間件實現(xiàn)分布式事務，消息數(shù)據(jù)獨立存儲，降低業(yè)務與消息系統(tǒng)的耦合，并且方案實現(xiàn)簡單。

本申請的第二個目的在于提出一種基于微服務的分布式事務處理方法。

本申請的第三個目的在于提出一種計算機設備。

本申請的第四個目的在于提出一種非臨時性計算機可讀存儲介質。

本申請的第五個目的在于提出一種計算機程序產品。

為達上述目的，本申請第一方面實施例提出了一種基于微服務的分布式事務處理系統(tǒng)，包括：第一系統(tǒng)、第二系統(tǒng)、第一數(shù)據(jù)庫、第二數(shù)據(jù)庫、消息中間件以及分布式應用程序協(xié)調服務；

第一系統(tǒng)向所述消息中間件發(fā)送預設消息，在發(fā)送成功的情況下，所述第一系統(tǒng)對所述第一數(shù)據(jù)庫進行操作，并向所述消息中間件發(fā)送確認消息；

第二系統(tǒng)通過所述消息中間件接收所述確認信息，所述第二系統(tǒng)對所述第二數(shù)據(jù)庫進行操作，并向所述消息中間件發(fā)送回執(zhí)消息；

在所述第一系統(tǒng)向所述消息中間件發(fā)送確認消息之后，在所述分布式應用程序協(xié)調服務建立消息節(jié)點并持續(xù)監(jiān)聽，在獲取所述第二系統(tǒng)對所述第二數(shù)據(jù)庫進行操作失敗的情況下，向所述第一系統(tǒng)發(fā)送執(zhí)行失敗信息，以使所述第一系統(tǒng)再次發(fā)送所述確認消息。

本申請實施例的基于微服務的分布式事務處理系統(tǒng)，通過第一系統(tǒng)向消息中間件發(fā)送預設消息，在發(fā)送成功的情況下，第一系統(tǒng)對第一數(shù)據(jù)庫進行操作，并向消息中間件發(fā)送確認消息；第二系統(tǒng)通過消息中間件接收確認信息，第二系統(tǒng)對第二數(shù)據(jù)庫進行操作，并向消息中間件發(fā)送回執(zhí)消息；在第一系統(tǒng)向消息中間件發(fā)送確認消息之后，在分布式應用程序協(xié)調服務建立消息節(jié)點并持續(xù)監(jiān)聽，在獲取第二系統(tǒng)對第二數(shù)據(jù)庫進行操作失敗的情況下，向第一系統(tǒng)發(fā)送執(zhí)行失敗信息，以使第一系統(tǒng)再次發(fā)送確認消息。由此，通過基于消息中間件實現(xiàn)分布式事務，實現(xiàn)多個系統(tǒng)分布式事務一致性，并且實現(xiàn)了最終一致性和可靠消息傳遞。

在本申請的一個實施例中，所述第一系統(tǒng)向所述消息中間件發(fā)送預設消息，在發(fā)送失敗的情況下，所述第一系統(tǒng)停止對所述第一數(shù)據(jù)庫進行操作。