[發(fā)明專利]一種基于微服務(wù)架構(gòu)的分布式事務(wù)處理方法

有效

• 申請(qǐng)?zhí)枺?/td>: 201710112586.4
• 申請(qǐng)日: 2017-02-28
• 公開（公告）號(hào): CN106909467B
• 公開（公告）日: 2021-06-29
• 發(fā)明（設(shè)計(jì)）人: 付正全
• 申請(qǐng)（專利權(quán)）人: 鄭州云海信息技術(shù)有限公司
• 主分類號(hào): G06F9/54
• 分類號(hào): G06F9/54
• 代理公司: 北京集佳知識(shí)產(chǎn)權(quán)代理有限公司 11227
• 代理人: 羅滿

本發(fā)明公開了一種基于微服務(wù)架構(gòu)的分布式事務(wù)處理方法，包括：在微服務(wù)架構(gòu)中確定服務(wù)調(diào)用節(jié)點(diǎn)和服務(wù)被調(diào)用節(jié)點(diǎn)；控制服務(wù)調(diào)用節(jié)點(diǎn)向服務(wù)被調(diào)用節(jié)點(diǎn)通過(guò)消息隊(duì)列發(fā)送業(yè)務(wù)消息，并存儲(chǔ)業(yè)務(wù)消息的發(fā)送狀態(tài)；控制服務(wù)被調(diào)用節(jié)點(diǎn)解析業(yè)務(wù)消息，并根據(jù)解析的結(jié)果執(zhí)行對(duì)應(yīng)的業(yè)務(wù)；控制服務(wù)被調(diào)用節(jié)點(diǎn)反饋業(yè)務(wù)執(zhí)行結(jié)果至服務(wù)調(diào)用節(jié)點(diǎn)；根據(jù)業(yè)務(wù)執(zhí)行結(jié)果，控制服務(wù)調(diào)用節(jié)點(diǎn)變更自身中存儲(chǔ)的業(yè)務(wù)消息的當(dāng)前狀態(tài)。服務(wù)調(diào)用節(jié)點(diǎn)根據(jù)服務(wù)被調(diào)用節(jié)點(diǎn)的反饋信息變更自身的業(yè)務(wù)消息的狀態(tài)，使用消息隊(duì)列機(jī)制保存消息狀態(tài)，不依賴具體的開發(fā)語(yǔ)言和平臺(tái)，保證了分布式事務(wù)的數(shù)據(jù)一致性，減少了兩個(gè)節(jié)點(diǎn)間的網(wǎng)絡(luò)通信次數(shù)，通信時(shí)間短，系統(tǒng)性能消耗小。

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

本發(fā)明涉及微服務(wù)架構(gòu)領(lǐng)域，特別是涉及一種基于微服務(wù)架構(gòu)的分布式事務(wù)處理方法。

背景技術(shù)

近年來(lái)，隨著云計(jì)算和互聯(lián)網(wǎng)行業(yè)的飛速發(fā)展，傳統(tǒng)的技術(shù)架構(gòu)已經(jīng)不能滿足業(yè)務(wù)量的靈活增長(zhǎng)和彈性應(yīng)用。為了解決這一問(wèn)題，微服務(wù)架構(gòu)應(yīng)運(yùn)而生。

在微服務(wù)架構(gòu)中，系統(tǒng)會(huì)拆分為若干個(gè)相對(duì)獨(dú)立業(yè)務(wù)的服務(wù)，每個(gè)服務(wù)可部署在不同的節(jié)點(diǎn)上。當(dāng)各服務(wù)節(jié)點(diǎn)之間出現(xiàn)調(diào)用時(shí)，如何實(shí)現(xiàn)事務(wù)的一致性成為亟需解決的問(wèn)題。目前，分布式事務(wù)的處理比較常用的是兩階段提交協(xié)議(Two-phase Commit，2pc)方法。即：由客戶端提交請(qǐng)求到事務(wù)協(xié)調(diào)器(TC)，然后由事務(wù)協(xié)調(diào)器來(lái)確認(rèn)各個(gè)事務(wù)執(zhí)行者是否都執(zhí)行完畢。待全部執(zhí)行成功后，才能將整個(gè)事務(wù)提交完成。但是，在使用過(guò)程中，發(fā)現(xiàn)現(xiàn)有的兩階段提交的方法具有以下的缺陷：現(xiàn)有的方法需要事務(wù)協(xié)調(diào)器主動(dòng)確認(rèn)各個(gè)事務(wù)執(zhí)行者的狀態(tài)，因此涉及多次節(jié)點(diǎn)間的網(wǎng)絡(luò)通信，通信時(shí)間長(zhǎng)，系統(tǒng)性能消耗大等。

因此，如何提供一種基于微服務(wù)架構(gòu)的分布式事務(wù)處理方法，以解決以上問(wèn)題，是本領(lǐng)域技術(shù)人員目前需要解決的技術(shù)問(wèn)題。

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

本發(fā)明的目的是提供一種基于微服務(wù)架構(gòu)的分布式事務(wù)處理方法，可以不依賴具體的開發(fā)語(yǔ)言和平臺(tái)，且保證分布式事務(wù)的數(shù)據(jù)一致性。

為解決上述技術(shù)問(wèn)題，本發(fā)明提供了如下技術(shù)方案：

一種基于微服務(wù)架構(gòu)的分布式事務(wù)處理方法，包括：

在微服務(wù)架構(gòu)中確定服務(wù)調(diào)用節(jié)點(diǎn)和服務(wù)被調(diào)用節(jié)點(diǎn)；

控制所述服務(wù)調(diào)用節(jié)點(diǎn)向所述服務(wù)被調(diào)用節(jié)點(diǎn)通過(guò)消息隊(duì)列發(fā)送業(yè)務(wù)消息，并存儲(chǔ)所述業(yè)務(wù)消息的發(fā)送狀態(tài)；

控制所述服務(wù)被調(diào)用節(jié)點(diǎn)解析所述業(yè)務(wù)消息，并根據(jù)解析的結(jié)果執(zhí)行對(duì)應(yīng)的業(yè)務(wù)；

控制所述服務(wù)被調(diào)用節(jié)點(diǎn)反饋業(yè)務(wù)執(zhí)行結(jié)果至所述服務(wù)調(diào)用節(jié)點(diǎn)；

根據(jù)所述業(yè)務(wù)執(zhí)行結(jié)果，控制所述服務(wù)調(diào)用節(jié)點(diǎn)變更自身中存儲(chǔ)的所述業(yè)務(wù)消息的當(dāng)前狀態(tài)。

優(yōu)選地，在所述控制所述服務(wù)調(diào)用節(jié)點(diǎn)向所述服務(wù)被調(diào)用節(jié)點(diǎn)通過(guò)消息隊(duì)列發(fā)送業(yè)務(wù)消息，并存儲(chǔ)所述業(yè)務(wù)消息的發(fā)送狀態(tài)之前還包括：

控制所述服務(wù)調(diào)用節(jié)點(diǎn)進(jìn)行業(yè)務(wù)檢查，判斷所述業(yè)務(wù)消息是否正常且符合預(yù)設(shè)的業(yè)務(wù)提交條件；

若是，則將所述業(yè)務(wù)消息存儲(chǔ)在所述服務(wù)調(diào)用節(jié)點(diǎn)的消息數(shù)據(jù)庫(kù)中，并將所述業(yè)務(wù)消息的狀態(tài)標(biāo)記為請(qǐng)求發(fā)送狀態(tài)。

優(yōu)選地，所述控制所述服務(wù)調(diào)用節(jié)點(diǎn)向所述服務(wù)被調(diào)用節(jié)點(diǎn)通過(guò)消息隊(duì)列發(fā)送業(yè)務(wù)消息，并存儲(chǔ)所述業(yè)務(wù)消息的發(fā)送狀態(tài)，包括：

接收業(yè)務(wù)消息確認(rèn)發(fā)送信息；

在所述消息數(shù)據(jù)庫(kù)中調(diào)取所述業(yè)務(wù)消息，并將所述業(yè)務(wù)消息通過(guò)消息隊(duì)列發(fā)送至所述服務(wù)被調(diào)用節(jié)點(diǎn)；

在所述服務(wù)調(diào)用節(jié)點(diǎn)中將所述業(yè)務(wù)消息的狀態(tài)變更為已發(fā)送狀態(tài)。

優(yōu)選地，所述控制所述服務(wù)被調(diào)用節(jié)點(diǎn)解析所述業(yè)務(wù)消息，并根據(jù)解析的結(jié)果執(zhí)行對(duì)應(yīng)的業(yè)務(wù)，包括：