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

有效

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

1.一種事務消息的處理方法，包括：

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

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

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

向所述事務協調器發送提交或回滾全局事務的請求，以根據所述事務協調器返回的指示，對所述全局事務所包含的各事務分支和消息分支進行提交或回滾，

其特征在于，所述向事務協調器發送用于開啟全局事務的請求，獲取本次全局事務的事務ID和所包含的消息分支的ID包括：

向事務協調器發送用于開啟本次全局事務的請求，并從所述事務協調器獲取所述本次全局事務對應的事務ID；

根據所述本次全局事務對應的事務ID，向所述事務協調器發送注冊消息分支的請求，并從所述事務協調器獲取本次全局事務所包含的消息分支的分支ID。

2.根據權利要求1所述的方法，其特征在于，所述對所述全局事務所包含的消息分支進行提交或回滾包括：

向所述消息中間件提交或回滾所述預備消息。

3.根據權利要求1所述的方法，其特征在于，所述將從所述消息中間件接收的消息發送結果上報至所述事務協調器，包括：

將從所述消息中間件接收的消息發送結果的信息轉換為json字符串，并上報至所述事務協調器。

4.一種事務消息的處理方法，包括：

根據應用所發送的用于開啟本次全局事務的請求，向所述應用返回所述本次全局事務的事務ID和所包含的消息分支的ID；

響應于所述應用上報的消息發送結果、以及將所述消息發送結果與所述消息分支的分支ID關聯的指示，執行關聯操作；所述消息發送結果為所述應用向消息中間件發送本次全局事務涉及的預備消息后獲得；

接收應用發送的提交或回滾全局事務的請求，以作為后續下發對所述全局事務所包含的各事務分支和消息分支進行相應的提交或回滾的指示的依據，

其特征在于，所述根據應用所發送的用于開啟本次全局事務的請求，向所述應用返回所述本次全局事務的事務ID和所包含的消息分支的ID包括：

根據應用所發送的用于開啟本次全局事務的請求，向所述應用返回所述本次全局事務的事務ID；

響應于所述應用根據所述事務ID發送的注冊消息分支的請求，并向所述應用返回所述本次全局事務所包含的所述消息分支的分支ID。

5.一種事務消息的處理方法，其特征在于，包括：

接收事務協調器發送的消息分支的提交指示，所述提交指示中包含待提交的消息分支的消息發送結果，其中，所述消息分支的提交指示為所述事務協調器在接收到所述消息分支所在的全局事務被請求提交后發出的，所述消息發送結果由所述事務協調器與所述全局事務的消息分支的分支ID關聯；

根據待提交的消息分支的消息發送結果，向消息中間件提交該消息發送結果所對應的預備消息，并將提交成功的消息反饋至所述事務協調器；

接收事務協調器發送的事務分支的提交指示，所述事務分支的提交指示為所述事務協調器在接收到所述事務分支所在的全局事務被請求提交后發出的；

將所述全局事務中包含的各事務分支分別進行提交，并將提交成功的消息反饋至所述事務協調器。

6.根據權利要求5所述的事務消息的處理方法，其特征在于，所述消息發送結果為應用向所述消息中間件發送本次全局事務涉及的預備消息后獲得，并發送至所述事務協調器的。