[發(fā)明專利]一種面向多數(shù)據(jù)源的分布式事務(wù)處理方法及系統(tǒng)

有效

• 申請(qǐng)?zhí)枺?/td>: 201710542537.4
• 申請(qǐng)日: 2017-07-05
• 公開(kāi)（公告）號(hào): CN107329809B
• 公開(kāi)（公告）日: 2020-11-27
• 發(fā)明（設(shè)計(jì)）人: 李曉珍;劉迪;崔蔚;趙俊峰;夏飛;章名尚;何金陵;孫琦;丁學(xué)英;李春陽(yáng);李春岐;程華沈;邱鎮(zhèn);王佳新;張攀;張蜜蜜;陳文康
• 申請(qǐng)（專利權(quán)）人: 國(guó)網(wǎng)信息通信產(chǎn)業(yè)集團(tuán)有限公司;國(guó)網(wǎng)江蘇省電力公司信息通信分公司;天津市普迅電力信息技術(shù)有限公司;國(guó)家電網(wǎng)公司
• 主分類號(hào): G06F9/46
• 分類號(hào): G06F9/46
• 代理公司: 北京集佳知識(shí)產(chǎn)權(quán)代理有限公司 11227
• 代理人: 王寶筠

本發(fā)明提供的面向多數(shù)據(jù)源的分布式事務(wù)處理方法及系統(tǒng)，在事務(wù)定義模塊基于SG?UAP擴(kuò)展模塊的規(guī)范，且符合OSGI框架，實(shí)現(xiàn)對(duì)不同數(shù)據(jù)源的分布式事務(wù)的定義，供事務(wù)開(kāi)發(fā)人員調(diào)用和配置，從而實(shí)現(xiàn)了分布式事務(wù)開(kāi)發(fā)的統(tǒng)一、可配置；事務(wù)協(xié)調(diào)器通過(guò)對(duì)事務(wù)定義模塊定義的分布式事務(wù)的配置文件進(jìn)行解析，實(shí)現(xiàn)對(duì)整個(gè)業(yè)務(wù)系統(tǒng)內(nèi)所有分布式事務(wù)的統(tǒng)一協(xié)調(diào)，將指定數(shù)據(jù)源的事務(wù)處理任務(wù)進(jìn)行統(tǒng)一協(xié)調(diào)，并分發(fā)到不同的事務(wù)管理器中；所述事務(wù)管理器將接收到的多個(gè)所述分布式事務(wù)分別發(fā)送到相應(yīng)的資源管理器；所述資源管理器根據(jù)接收到的所述分布式事務(wù)的配置文件對(duì)所述分布式事務(wù)進(jìn)行相應(yīng)的處理。

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

本發(fā)明涉及數(shù)據(jù)處理技術(shù)領(lǐng)域，更具體的，涉及一種面向多數(shù)據(jù)源的分布式事務(wù)處理方法及系統(tǒng)。

背景技術(shù)

隨著電網(wǎng)業(yè)務(wù)的不斷增長(zhǎng)，數(shù)據(jù)量不斷增大，比如電表數(shù)據(jù)，電網(wǎng)目前接入上億電表，每個(gè)電表按照15分鐘一個(gè)點(diǎn)采集數(shù)據(jù)，數(shù)據(jù)量的激增對(duì)數(shù)據(jù)庫(kù)的要求越來(lái)越高。為了提高數(shù)據(jù)庫(kù)中數(shù)據(jù)訪問(wèn)的并發(fā)性能，目前的一般做法是將數(shù)據(jù)源進(jìn)行拆分，從單一數(shù)據(jù)源拆分為多數(shù)據(jù)源。根據(jù)不同的業(yè)務(wù)特性，我們采用分庫(kù)分表和讀寫分離兩種數(shù)據(jù)庫(kù)拆分策略。

分庫(kù)分表和讀寫分離實(shí)現(xiàn)了多數(shù)據(jù)源的數(shù)據(jù)存儲(chǔ)和訪問(wèn)，但是，隨之而來(lái)是對(duì)事務(wù)處理的要求，如何滿足多數(shù)據(jù)源條件下在分庫(kù)存儲(chǔ)和讀寫分離兩種策略下的事務(wù)處理的ACID要求，即，原子性(Atomicity)，一致性(Consistency)，隔離性(Isolation)和持久性(Durability)，并且提供給不同的開(kāi)發(fā)團(tuán)隊(duì)統(tǒng)一的分布式事務(wù)處理的開(kāi)發(fā)能力，成為了較為突出的問(wèn)題。

X/open DTP是一種分布式事務(wù)處理參考模型，由x/open公司制定了分布式事務(wù)處理參考模型DTP和一系列API規(guī)范作為分布式事務(wù)處理系統(tǒng)的標(biāo)準(zhǔn)。該模型有三個(gè)基本的組成部分：事務(wù)管理器(Transaciotn Manage)、資源管理器(Resource)和應(yīng)用程序(Application program)。事務(wù)管理器監(jiān)視所在的分布式事務(wù)域內(nèi)所有應(yīng)用程序與資源管理器的行為，控制事務(wù)提交、回滾和恢復(fù)等過(guò)程，保證事務(wù)正常處理。

基于X/OPEN DTP雖然可實(shí)現(xiàn)分布式事務(wù)處理，但是僅能解決在單一數(shù)據(jù)源拆分后的多數(shù)據(jù)源內(nèi)部實(shí)現(xiàn)分布式事務(wù)處理，無(wú)法解決當(dāng)不同的多數(shù)據(jù)源分別拆分為多數(shù)據(jù)源時(shí)的分布式事務(wù)處理問(wèn)題。

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

有鑒于此，本發(fā)明提供了一種面向多數(shù)據(jù)源的分布式事務(wù)處理方法及系統(tǒng)，在事務(wù)開(kāi)發(fā)層統(tǒng)一對(duì)分布式事務(wù)的進(jìn)行開(kāi)發(fā)和定義，滿足分庫(kù)分表和讀寫分離兩種多數(shù)據(jù)源情況下的分布式事務(wù)處理。

為實(shí)現(xiàn)上述發(fā)明目的，本發(fā)明提供的具體技術(shù)方案如下：

一種面向多數(shù)據(jù)源的分布式事務(wù)處理方法，所述方法包括：

事務(wù)定義模塊根據(jù)SG-UAP擴(kuò)展模塊的規(guī)范，對(duì)面向多數(shù)據(jù)源的多個(gè)分布式事務(wù)進(jìn)行聲明、定義、引入和控制，得到每個(gè)所述分布式事務(wù)的配置文件；

事務(wù)協(xié)調(diào)器對(duì)每個(gè)所述分布式事務(wù)的配置文件進(jìn)行解析，得到每個(gè)所述分布式事務(wù)對(duì)應(yīng)的事務(wù)管理器和資源管理器，并將每個(gè)所述分布式事務(wù)分發(fā)到相應(yīng)的事務(wù)管理器；

所述事務(wù)管理器將接收到的多個(gè)所述分布式事務(wù)分別發(fā)送到相應(yīng)的資源管理器；

所述資源管理器根據(jù)接收到的所述分布式事務(wù)的配置文件對(duì)所述分布式事務(wù)進(jìn)行相應(yīng)的處理。

優(yōu)選的，所述事務(wù)定義模塊根據(jù)SG-UAP擴(kuò)展模塊的規(guī)范，對(duì)面向多數(shù)據(jù)源的多個(gè)分布式事務(wù)進(jìn)行聲明、定義、引入和控制，得到每個(gè)所述分布式事務(wù)的配置文件，包括：

在UAP項(xiàng)目中，對(duì)多個(gè)數(shù)據(jù)源的預(yù)設(shè)參數(shù)進(jìn)行配置，并對(duì)外發(fā)布分別與各個(gè)所述數(shù)據(jù)源相對(duì)應(yīng)的各個(gè)數(shù)據(jù)源服務(wù)，所述UAP項(xiàng)目包括多個(gè)業(yè)務(wù)模塊；

在擴(kuò)展模塊項(xiàng)目中，引入各個(gè)所述數(shù)據(jù)源服務(wù)，并配置每個(gè)所述數(shù)據(jù)源的Dao對(duì)象和分布式事務(wù)處理對(duì)象；