[發(fā)明專利]事務(wù)處理方法及相關(guān)產(chǎn)品

有效

• 申請(qǐng)?zhí)枺?/td>: 202110726140.7
• 申請(qǐng)日: 2021-06-29
• 公開（公告）號(hào): CN113360299B
• 公開（公告）日: 2022-11-29
• 發(fā)明（設(shè)計(jì)）人: 李海兵
• 申請(qǐng)（專利權(quán)）人: 深圳市商湯科技有限公司
• 主分類號(hào): G06F9/54
• 分類號(hào): G06F9/54;G06Q30/06
• 代理公司: 廣州三環(huán)專利商標(biāo)代理有限公司 44202
• 代理人: 熊永強(qiáng);董文俊

本申請(qǐng)實(shí)施例提供一種事務(wù)處理方法及相關(guān)產(chǎn)品，該事務(wù)處理方法包括：服務(wù)端創(chuàng)建第一微服務(wù)；若所述第一微服務(wù)對(duì)應(yīng)至少兩個(gè)事務(wù)，所述至少兩個(gè)事務(wù)包括第一事務(wù)和第二事務(wù)，并且所述第一事務(wù)對(duì)應(yīng)的第一數(shù)據(jù)源和所述第二事務(wù)對(duì)應(yīng)的第二數(shù)據(jù)源不同，則創(chuàng)建鏈?zhǔn)绞聞?wù)管理器；通過(guò)所述鏈?zhǔn)绞聞?wù)管理器對(duì)所述第一數(shù)據(jù)源對(duì)應(yīng)的事務(wù)和所述第二數(shù)據(jù)源對(duì)應(yīng)的事務(wù)進(jìn)行處理。本申請(qǐng)實(shí)施例可以保證微服務(wù)涉及的事務(wù)的數(shù)據(jù)一致性。

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

本申請(qǐng)涉及互聯(lián)網(wǎng)技術(shù)領(lǐng)域，具體涉及一種事務(wù)處理方法及相關(guān)產(chǎn)品。

背景技術(shù)

在微服務(wù)化開發(fā)的電商平臺(tái)以及其他微服務(wù)化開發(fā)的產(chǎn)品中，業(yè)務(wù)拆分使得各個(gè)微服務(wù)獨(dú)立部署和運(yùn)行，同一個(gè)微服務(wù)涉及的事務(wù)可能對(duì)應(yīng)不同的數(shù)據(jù)源的數(shù)據(jù)更新操作。如何保證微服務(wù)涉及的事務(wù)的數(shù)據(jù)一致性是亟需解決的問(wèn)題。

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

本申請(qǐng)實(shí)施例提供一種事務(wù)處理方法及相關(guān)產(chǎn)品。

本申請(qǐng)實(shí)施例的第一方面提供了一種事務(wù)處理方法，包括：

創(chuàng)建第一微服務(wù)；

若所述第一微服務(wù)對(duì)應(yīng)至少兩個(gè)事務(wù)，所述至少兩個(gè)事務(wù)包括第一事務(wù)和第二事務(wù)，并且所述第一事務(wù)對(duì)應(yīng)的第一數(shù)據(jù)源和所述第二事務(wù)對(duì)應(yīng)的第二數(shù)據(jù)源不同，則創(chuàng)建鏈?zhǔn)绞聞?wù)管理器；

通過(guò)所述鏈?zhǔn)绞聞?wù)管理器對(duì)所述第一數(shù)據(jù)源對(duì)應(yīng)的事務(wù)和所述第二數(shù)據(jù)源對(duì)應(yīng)的事務(wù)進(jìn)行處理。

可選的，所述方法還包括：

若所述第一微服務(wù)對(duì)應(yīng)至少一個(gè)事務(wù)，并且所述至少一個(gè)事務(wù)對(duì)應(yīng)相同的目標(biāo)數(shù)據(jù)源，則創(chuàng)建單數(shù)據(jù)源事務(wù)管理器；

通過(guò)所述單數(shù)據(jù)源事務(wù)管理器對(duì)所述至少一個(gè)事務(wù)進(jìn)行處理。

可選的，所述創(chuàng)建單數(shù)據(jù)源事務(wù)管理器，包括：

若所述目標(biāo)數(shù)據(jù)源是默認(rèn)數(shù)據(jù)源，通過(guò)注解的方式配置默認(rèn)事務(wù)管理器，所述默認(rèn)事務(wù)管理器實(shí)現(xiàn)所述默認(rèn)數(shù)據(jù)源的事務(wù)支持，所述單數(shù)據(jù)源事務(wù)管理器包括所述默認(rèn)事務(wù)管理器。

可選的，所述創(chuàng)建鏈?zhǔn)绞聞?wù)管理器，包括：

創(chuàng)建事務(wù)管理器，通過(guò)注解的方式設(shè)置所述事務(wù)管理器的屬性為鏈?zhǔn)绞聞?wù)管理器。

可選的，所述創(chuàng)建第一微服務(wù)之前，所述方法還包括：

接收用戶端發(fā)起的業(yè)務(wù)請(qǐng)求；

確定所述業(yè)務(wù)請(qǐng)求涉及的至少一個(gè)微服務(wù)，所述至少一個(gè)微服務(wù)包括所述第一微服務(wù)。

可選的，所述至少一個(gè)微服務(wù)還包括第二微服務(wù)，所述方法還包括：

創(chuàng)建所述第二微服務(wù)，創(chuàng)建第一消息表或第一消息集合；

將與所述業(yè)務(wù)請(qǐng)求相關(guān)的第一消息投遞到第一消息隊(duì)列，所述第二微服務(wù)用于從所述第一消息隊(duì)列獲得所述第一消息；

根據(jù)所述第一消息的標(biāo)識(shí)符判斷所述第一消息表或第一消息集合中是否存在與所述第一消息的標(biāo)識(shí)符相同的消息；

若不存在，通過(guò)所述第二微服務(wù)處理所述第一消息；

可選的，所述處理所述第一消息之后，所述方法還包括：

若所述第一消息隊(duì)列沒(méi)有接收到所述第二微服務(wù)返回的針對(duì)所述第一消息的消息處理成功確認(rèn)消息，則通過(guò)所述第一消息隊(duì)列采用最大努力通知策略通知所述第二微服務(wù)。

可選的，所述處理所述第一消息之后，所述方法還包括：

在所述第一消息處理成功后，將所述第一消息持久化到所述第一消息表或第一消息集合中。

可選的，若所述第一消息表或第一消息集合中存在與所述第一消息的標(biāo)識(shí)符相同的消息，丟棄所述第一消息。