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

有效

• 申請號: 201610709666.3
• 申請日: 2016-08-23
• 公開（公告）號: CN107766080B
• 公開（公告）日: 2021-11-09
• 發明（設計）人: 姜宇
• 申請（專利權）人: 阿里巴巴集團控股有限公司
• 主分類號: G06F9/38
• 分類號: G06F9/38
• 代理公司: 北京同立鈞成知識產權代理有限公司 11205
• 代理人: 宋揚;劉芳

1.一種事務消息處理系統，其特征在于，包括：客戶端設備和事務協調器所在節點設備；所述客戶端設備與所述事務協調器所在節點設備連接；

所述客戶端設備，用于確定業務消息對應的事務消息；解析所述事務消息的SQL語句，確定所述解析后的事務消息中是否包括回滾指示信息對應的字符串，若所述解析后的事務消息中包括所述回滾指示信息對應的字符串，則確定所述事務消息包括回滾指示信息，并記錄所述回滾指示信息；所述回滾指示信息用以對所述事務消息對應的事務進行回滾；

所述事務協調器所在節點設備，用于接收所述客戶端設備發送的事務消息對應的事務的處理結果；所述事務包括數據插入或數據更新；根據所述處理結果確定所述事務消息對應的事務是否處理成功；若所述事務消息對應的事務存在未處理成功的事務，則向所述客戶端設備發送事務回滾請求消息；

所述客戶端設備，還用于根據記錄的所述回滾指示信息對所述事務消息對應的事務進行回滾。

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

確定業務消息對應的事務消息；

解析所述事務消息的SQL語句，確定所述解析后的事務消息中是否包括回滾指示信息對應的字符串，若所述解析后的事務消息中包括所述回滾指示信息對應的字符串，則確定所述事務消息包括回滾指示信息，并記錄所述回滾指示信息；所述回滾指示信息用以對所述事務消息對應的事務進行回滾。

3.根據權利要求2所述的方法，其特征在于，所述記錄所述回滾指示信息之后，所述方法還包括：

對所述事務消息對應的事務進行處理；

將所述事務消息對應的事務的處理結果發送至事務協調器所在節點設備。

4.根據權利要求3所述的方法，其特征在于，所述方法還包括：

接收所述事務協調器所在節點設備發送的事務提交請求消息；所述事務提交請求消息為所述事務協調器所在節點設備在確定所述事務消息對應的事務處理成功后發送的；

對所述事務消息對應的事務進行提交。

5.根據權利要求4所述的方法，其特征在于，所述方法還包括：

刪除記錄的所述回滾指示信息。

6.根據權利要求3所述的方法，其特征在于，所述方法還包括：

接收所述事務協調器所在節點設備發送的事務回滾請求消息；所述事務回滾請求消息為所述事務協調器所在節點設備在確定所述事務消息對應的事務存在未處理成功的事務后發送的；

根據所述回滾指示信息對所述事務消息對應的事務進行回滾。

7.根據權利要求6所述的方法，其特征在于，所述方法還包括：

刪除記錄的所述回滾指示信息。

8.根據權利要求2-7中任一項所述的方法，其特征在于，所述解析所述事務消息的SQL語句，確定所述解析后的事務消息中是否包括回滾指示信息對應的字符串之前，所述方法還包括：

將所述事務消息發送至事務協調器所在節點設備；

接收所述事務協調器所在節點設備發送的所述事務消息對應的事務標識；

記錄所述事務消息對應的事務標識。

9.根據權利要求8所述的方法，其特征在于，所述記錄所述回滾指示信息，包括：

記錄所述回滾指示信息，和，所述回滾指示信息與所述事務消息對應的事務標識之間的對應關系。

10.根據權利要求2-7中任一項所述的方法，其特征在于，所述方法還包括：

若所述事務消息不包括所述回滾指示信息，生成所述事務消息對應事務的回滾數據；

對所述事務消息對應的事務進行處理；

生成所述事務消息對應事務的重做數據；

記錄所述回滾數據和所述重做數據。

11.根據權利要求2-7中任一項所述的方法，其特征在于，所述事務消息對應的事務包括如下任一：

數據插入、數據更新及數據刪除。