[發明專利]基于消息隊列和數據庫的分布式事務處理方法及系統

有效

• 申請號: 202010840396.6
• 申請日: 2020-08-20
• 公開（公告）號: CN111708619B
• 公開（公告）日: 2020-11-06
• 發明（設計）人: 顧凌云;郭志攀;王偉;劉暢
• 申請（專利權）人: 上海冰鑒信息科技有限公司
• 主分類號: G06F9/46
• 分類號: G06F9/46;G06F9/48;G06F16/174
• 代理公司: 成都頂峰專利事務所(普通合伙) 51224
• 代理人: 匡睿

本發明提供了一種基于消息隊列和數據庫的分布式事務處理方法及系統。在該方法中，組件封裝服務器根據獲取到的業務請求服務器的第一配置信息以及業務執行服務器的第二配置信息生成目標壓縮包，并將目標壓縮包分別發送至業務請求服務器和業務執行服務器，能夠使得業務請求服務器和業務執行服務器基于目標壓縮包進行解壓配置，從而實現對事務處理組件和消息傳輸路徑的部署。這樣能夠使得不同的業務請求服務器和業務執行服務器基于消息隊列進行分布式事務的處理，從而提高基于消息隊列和數據庫的分布式事務處理方案的易用性以及方案部署效率。

技術領域

本發明涉及事務處理技術領域，具體而言，涉及一種基于消息隊列和數據庫的分布式事務處理方法及系統。

背景技術

事務是數據庫操作的最小工作單元，是作為單個邏輯工作單元執行的一系列操作。分布式事務指事務的參與者、支持事務的服務器、資源服務器以及事務管理器分別位于不同的分布式系統的不同節點之上。但是由于Java數據庫連接（Java DatabaseConnectivity，JDBC）只能保證同一個數據庫在同一個系統的代碼中事務有效，不能保證不同數據庫或不同系統之間的事務一致性。

相關技術如XA二階段提交方案、TCC方案、最大努力通知方案和可靠消息最終一致性方案雖然能夠解決上述的事務一致性問題，然是這些技術會存在一定的問題：XA二階段提交方案的性能差；TCC方案的代碼邏輯實現繁雜；最大努力通知方案的使用場景單一，只能適用于對最終一致性時間敏感度低的業務；可靠消息最終一致性方案需要使用RocketMq這種特定的消息隊列，會限制消息隊列的選擇。

因此，基于消息隊列的最終一致性方案廣泛用于解決事務一致性問題，但是基于消息隊列的最終一致性方案易用性差，難以快速地部署到不同的分布式系統中。

發明內容

為了改善上述問題，本發明提供了一種基于消息隊列和數據庫的分布式事務處理方法及系統，能夠根據不同的業務請求服務器和業務執行服務器的配置信息生成用于對分布式事務處理組件進行部署的目標壓縮包，這樣能夠使得業務請求服務器和業務執行服務器分別基于目標壓縮包進行分布式事務處理組件和相關功能的部署，從而提高基于消息隊列和數據庫的分布式事務處理方案的易用性以及方案部署效率。

本發明實施例的第一方面，提供了一種基于消息隊列和數據庫的分布式事務處理方法，應用于分布式事務處理系統，所述分布式事務處理系統包括組件封裝服務器、業務請求服務器以及業務執行服務器，所述業務請求服務器和所述業務執行服務器通過消息隊列通信，所述組件封裝服務器分別與所述業務請求服務器以及所述業務執行服務器通信，所述方法包括：

所述組件封裝服務器獲取所述業務請求服務器的第一配置信息以及所述業務執行服務器的第二配置信息；其中，所述第一配置信息包括所述業務請求服務器的數據源信息以及所述業務請求服務器中的事務管理器的第一參數信息，所述第二配置信息包括所述業務執行服務器中的事務處理器的第二參數信息；

所述組件封裝服務器根據所述第一配置信息和所述第二配置信息生成目標壓縮包，將所述目標壓縮包分別發送至所述業務請求服務器和所述業務執行服務器；

所述業務請求服務器對所述目標壓縮包進行解壓配置，生成事務處理組件，將預存的用戶信息導入所述事務處理組件中；

所述業務執行服務器對所述目標壓縮包進行解壓配置，建立所述事務處理器與所述消息隊列的消息傳輸路徑；

所述業務請求服務器根據接收到的用戶請求在所述事務處理組件中創建用戶記錄，并根據所述用戶記錄生成事務消息，將所述事務消息發送給所述消息隊列；其中，所述事務處理組件中包括用于存儲用戶記錄的數據庫；

所述業務執行服務器通過所述消息傳輸路徑從所述消息隊列中抽取所述事務消息并通過所述事務管理器對所述事務消息進行處理。

可選地，所述組件封裝服務器根據所述第一配置信息和所述第二配置信息生成目標壓縮包，包括：