[發(fā)明專利]分布式事務(wù)處理方法、裝置、電子設(shè)備及計算機可讀介質(zhì)

有效

• 申請?zhí)枺?/td>: 201811610401.3
• 申請日: 2018-12-27
• 公開（公告）號: CN109739624B
• 公開（公告）日: 2021-07-16
• 發(fā)明（設(shè)計）人: 普實
• 申請（專利權(quán)）人: 北京三快在線科技有限公司
• 主分類號: G06F9/46
• 分類號: G06F9/46
• 代理公司: 北京律智知識產(chǎn)權(quán)代理有限公司 11438
• 代理人: 袁禮君;闞梓瑄

本公開提供一種分布式事務(wù)處理方法、裝置、電子設(shè)備及計算機可讀介質(zhì)，屬于互聯(lián)網(wǎng)技術(shù)領(lǐng)域。該分布式事務(wù)處理方法包括：根據(jù)本地消息表中的多個消息處理邏輯提取的核心處理邏輯得到公共組件；通過spring AOP的方式將所述公共組件融合到業(yè)務(wù)邏輯中。該方法通過對多個消息處理邏輯進行抽象，提取出公共組件，使得提取的公共組件中的核心處理邏輯得到最大可能的復(fù)用；通過spring AOP的方式將所述公共組件的核心處理邏輯融合到業(yè)務(wù)邏輯中，降低耦合度，降低使用者的難度，使得程序邏輯便于理解，提升研發(fā)效率。

技術(shù)領(lǐng)域

本公開總體涉及互聯(lián)網(wǎng)技術(shù)領(lǐng)域，具體而言，涉及一種分布式事務(wù)處理方法、裝置、電子設(shè)備及計算機可讀介質(zhì)。

背景技術(shù)

微服務(wù)是將復(fù)雜的單體應(yīng)用拆分為若干個功能簡單、松耦合的服務(wù)，這樣可以降低開發(fā)難度、增強擴展性、便于敏捷開發(fā)。單體應(yīng)用拆分為分布式系統(tǒng)后，進程間的通訊機制和故障處理措施變的更加復(fù)雜。系統(tǒng)微服務(wù)化后，一個看似簡單的功能，內(nèi)部可能需要調(diào)用多個服務(wù)并操作多個數(shù)據(jù)庫實現(xiàn)，服務(wù)調(diào)用的分布式事務(wù)問題變的非常突出。

因此，現(xiàn)有技術(shù)中的技術(shù)方案中還存在有待改進之處。

在所述背景技術(shù)部分公開的上述信息僅用于加強對本公開的背景的理解，因此它可以包括不構(gòu)成對本領(lǐng)域普通技術(shù)人員已知的現(xiàn)有技術(shù)的信息。

發(fā)明內(nèi)容

本公開提供一種分布式事務(wù)處理方法、裝置、電子設(shè)備及計算機可讀介質(zhì)，解決上述問題中的至少一個問題。

本公開的其他特性和優(yōu)點將通過下面的詳細描述變得顯然，或部分地通過本公開的實踐而習(xí)得。

根據(jù)本公開的一方面，提供一種分布式事務(wù)處理方法，包括：根據(jù)本地消息表中的多個消息處理邏輯提取的核心處理邏輯得到公共組件；通過spring AOP的方式將所述公共組件融合到業(yè)務(wù)邏輯中。

在本公開的一個實施例中，根據(jù)本地消息表中的多個消息處理邏輯提取的核心處理邏輯得到公共組件之后，通過spring AOP的方式將所述公共組件融合到業(yè)務(wù)邏輯中之前，還包括：

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

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

在本公開的一個實施例中，所述根據(jù)所述公共組件生成通用消息表之前，還包括：

執(zhí)行業(yè)務(wù)邏輯，調(diào)用與所述業(yè)務(wù)邏輯相對應(yīng)的代理服務(wù)。

在本公開的一個實施例中，所述通過spring AOP的方式將所述公共組件融合到業(yè)務(wù)邏輯中包括：

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

在本公開的一個實施例中，采用spring AOP的方式將所述公共組件中的核心處理邏輯實時織入到所述業(yè)務(wù)邏輯中包括：

通過AOP切面針對所述代理服務(wù)進行入?yún)⑿蛄谢玫叫蛄谢矸?wù)；

記錄調(diào)用所述序列化代理服務(wù)的方法名和bean名；

保存所述通用消息表；

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

在本公開的一個實施例中，事務(wù)提交后，還包括：

將所述業(yè)務(wù)處理邏輯加入到線程池；

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

反射調(diào)用所述消息id對應(yīng)的bean名和方法名，并將調(diào)用結(jié)果發(fā)送給消費方對應(yīng)的服務(wù)。

在本公開的一個實施例中，反射調(diào)用所述消息id對應(yīng)的bean名和方法名，并將調(diào)用結(jié)果發(fā)送給消費方對應(yīng)的服務(wù)包括：