[發明專利]分布式事務處理方法、裝置、電子設備及計算機可讀介質

有效

• 申請號: 201811610401.3
• 申請日: 2018-12-27
• 公開（公告）號: CN109739624B
• 公開（公告）日: 2021-07-16
• 發明（設計）人: 普實
• 申請（專利權）人: 北京三快在線科技有限公司
• 主分類號: G06F9/46
• 分類號: G06F9/46
• 代理公司: 北京律智知識產權代理有限公司 11438
• 代理人: 袁禮君;闞梓瑄

1.一種分布式事務處理方法，其特征在于，包括：

根據本地消息表中的多個消息處理邏輯提取的核心處理邏輯得到公共組件，其中，所述公共組件為封裝所述多個消息處理邏輯中公共的部分得到的；

通過spring AOP的方式將所述公共組件融合到業務邏輯中；

在根據本地消息表中的多個消息處理邏輯提取的核心處理邏輯得到公共組件之后，通過spring AOP的方式將所述公共組件融合到業務邏輯中之前，所述方法還包括：

根據所述公共組件生成通用消息表；

在所述通用消息表中針對每個消息配置一個消息id；

事務提交后，還包括：

將所述業務邏輯加入到線程池；

根據所述通用消息表中的消息id獲取消息上下文；

反射調用所述消息id對應的bean名和方法名，并將調用結果發送給消費方對應的服務。

2.根據權利要求1所述的分布式事務處理方法，其特征在于，所述根據所述公共組件生成通用消息表之前，還包括：

調用與所述業務邏輯相對應的代理服務。

3.根據權利要求2所述的分布式事務處理方法，其特征在于，所述通過spring AOP的方式將所述公共組件融合到業務邏輯中包括：

采用spring AOP的方式將所述公共組件中的核心處理邏輯實時織入到所述業務邏輯中。

4.根據權利要求3所述的分布式事務處理方法，其特征在于，采用spring AOP的方式將所述公共組件中的核心處理邏輯實時織入到所述業務邏輯中包括：

通過AOP切面針對所述代理服務進行入參序列化，得到序列化代理服務；

記錄調用所述序列化代理服務的方法名和bean名；

保存所述通用消息表；

事務提交后通過鉤子返回到所述AOP切面。

5.根據權利要求1所述的分布式事務處理方法，其特征在于，反射調用所述消息id對應的bean名和方法名，并將調用結果發送給消費方對應的服務包括：

如果調用成功，則將調用結果發送給消費方對應的服務；如果調用不成功，則等待重試，直到調用成功。

6.一種分布式事務處理裝置，其特征在于，包括：

提取模塊，配置為根據本地消息表中的多個消息處理邏輯的核心處理邏輯提取得到公共組件，其中，所述公共組件為封裝所述多個消息處理邏輯中公共的部分得到的；

織入模塊，配置為通過spring AOP的方式將所述公共組件融合到業務邏輯中；

在根據本地消息表中的多個消息處理邏輯提取的核心處理邏輯得到公共組件之后，通過spring AOP的方式將所述公共組件融合到業務邏輯中之前，所述裝置還配置為根據所述公共組件生成通用消息表；在所述通用消息表中針對每個消息配置一個消息id；以及

將所述業務邏輯加入到線程池；

根據所述通用消息表中的消息id獲取消息上下文；

反射調用所述消息id對應的bean名和方法名，并將調用結果發送給消費方對應的服務。

7.一種電子設備，其特征在于，包括：

處理器；

存儲器，存儲用于所述處理器控制如權利要求1-5任一項所述的方法步驟的指令。

8.一種計算機可讀介質，其上存儲有計算機可執行指令，其特征在于，所述可執行指令被處理器執行時實現如權利要求1-5任一項所述的方法步驟。