[發明專利]事務消息的處理方法、裝置及電子設備

有效

• 申請號: 201710972967.X
• 申請日: 2017-10-18
• 公開（公告）號: CN109684045B
• 公開（公告）日: 2023-04-28
• 發明（設計）人: 姜宇
• 申請（專利權）人: 阿里巴巴集團控股有限公司
• 主分類號: G06F9/46
• 分類號: G06F9/46;G06F9/54
• 代理公司: 廣州鑄智知識產權代理有限公司 44886
• 代理人: 徐瑞紅

本發明實施例提供一種事務消息的處理方法、裝置及電子設備，其中，方法包括：向事務協調器發送用于開啟全局事務的請求，獲取本次全局事務的事務ID和所包含的消息分支的ID；向消息中間件發送本次全局事務涉及的預備消息，并將從所述消息中間件接收的消息發送結果上報至所述事務協調器，以指示將所述消息發送結果與所述消息分支的分支ID關聯；執行所述全局事務包含的各事務分支；向所述事務協調器發送提交或回滾全局事務的請求，以根據所述事務協調器返回的指示，對所述全局事務所包含的各事務分支和消息分支進行提交或回滾。本發明實施例的方案能夠摒棄在應用中額外設置回查接口所帶來的麻煩，并且能夠保證事務和消息處理上的一致性。

技術領域

本申請涉及計算機技術領域，尤其涉及一種事務消息的處理方法、裝置及電子設備。

背景技術

分布式事務系統通常包含客戶端、資源管理器、事務協調器幾個角色?？蛻舳伺c資源管理器部署在應用側；事務協調器獨立部署，負責協調一個分布式事務從開始到完成的所有相關處理流程，是系統核心角色。

現有技術實現事務消息，通常是基于消息中間件的類似X/Open?XA的兩階段提交，把數據庫本地事務和消息發送放在了一個分布式事務里，保證要么本地事務成功并且對外發消息成功，要么兩者都失敗。消息中間件提供的事務消息功能，需要用戶在應用中寫回查接口，并加一些業務邏輯來保存本地事務的執行狀態和相應的清理邏輯。如圖1所示，為事務消息的典型流程。圖1中，應用發送預備消息到消息中間件，消息中間件保存預備消息，但是這個消息目前不可消費，也就是說別的應用或系統無法接收到這個消息；消息發送成功后，應用執行本地事務；待本地事務成功提交后，提交剛才發送的那個預備消息，此時消息可消費，其他接收者收到該消息后其業務繼續推進。

如果上面某一步失敗，應用可以回滾預備消息，邏輯比較簡單，不在此詳細分析。比較麻煩的是，應用在提交消息或回滾消息前宕機，消息中間件收到一個預備消息后，在超時前沒收到應用發送的提交或回滾消息的指令。這時，消息中間件就需要用到應用提供的回查接口，在超時后調用該回查接口，得到應用本地的事務狀態，如果事務執行成功則提交消息讓消息可消費，如果事務執行失敗則回滾預備消息。如圖2所示，為相應的消息流程圖。

現有技術缺陷總結：

1，現有技術實現事務消息比較復雜，用戶需要在應用中增加業務邏輯，實現回查接口?；夭榻涌谝瓿傻墓ぷ魇?，當消息中間件輸入一個消息ID時，應用可返回消息ID相應的數據庫本地事務是否成功的狀態消息。消息中間件以此為依據進行消息提交或回滾。

2，為了實現這樣一個回查接口，需要應用持久化本地事務狀態，以及事務與消息之間的對應關系，需要保證接口冪等，允許多次調用，不影響業務邏輯。在實際操作中，持久化的狀態信息肯定不能堆積下去，需要清理，多長時間清理也是一個問題，因為需要確定消息中間件在此之后一定不會再回查這些事務狀態。

3，一個應用中通常有多處事務消息，這就需要實現很多回查接口，給應用開發、維護、升級都帶來很多復雜性。

發明內容

本發明提供了一種事務消息的處理方法、裝置及電子設備，能夠摒棄在應用中額外設置回查接口所帶來的麻煩，并且能夠保證事務和消息處理上的一致性。

為達到上述目的，本發明的實施例采用如下技術方案：

第一方面，提供了一種事務消息的處理方法，包括：

向事務協調器發送用于開啟全局事務的請求，獲取本次全局事務的事務ID和所包含的消息分支的ID；

向消息中間件發送本次全局事務涉及的預備消息，并將從所述消息中間件接收的消息發送結果上報至所述事務協調器，以指示將所述消息發送結果與所述消息分支的分支ID關聯；

執行所述全局事務包含的各事務分支；