[發(fā)明專利]區(qū)塊鏈集群處理系統(tǒng)和方法

有效

• 申請(qǐng)?zhí)枺?/td>: 201710139276.1
• 申請(qǐng)日: 2017-03-09
• 公開（公告）號(hào): CN106685743B
• 公開（公告）日: 2018-02-06
• 發(fā)明（設(shè)計(jì)）人: 劉雄文;陸陳一帆;黃宇翔;司思
• 申請(qǐng)（專利權(quán)）人: 上海億賬通區(qū)塊鏈科技有限公司
• 主分類號(hào): H04L12/24
• 分類號(hào): H04L12/24;H04L29/08
• 代理公司: 廣州華進(jìn)聯(lián)合專利商標(biāo)代理有限公司44224
• 代理人: 王寧

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

本發(fā)明涉及互聯(lián)網(wǎng)技術(shù)領(lǐng)域，特別是涉及一種區(qū)塊鏈集群處理系統(tǒng)和方法。

背景技術(shù)

區(qū)塊鏈一般被理解為一個(gè)分布式的賬本，它實(shí)質(zhì)上也是一個(gè)分布式計(jì)算和存儲(chǔ)系統(tǒng)。區(qū)塊鏈有多個(gè)節(jié)點(diǎn)，不同的節(jié)點(diǎn)通過一定的計(jì)算規(guī)則達(dá)成共識(shí)，并且將共識(shí)后的交易執(zhí)行結(jié)果以區(qū)塊的形式存儲(chǔ)至數(shù)據(jù)庫中，多個(gè)區(qū)塊組成了區(qū)塊鏈，多個(gè)節(jié)點(diǎn)之間可以對(duì)區(qū)塊互為備份。由于區(qū)塊鏈中的每個(gè)節(jié)點(diǎn)是獨(dú)立的，節(jié)點(diǎn)出現(xiàn)故障是不可避免的。當(dāng)出現(xiàn)故障的節(jié)點(diǎn)較多時(shí)，區(qū)塊鏈可能會(huì)無法正常工作，導(dǎo)致區(qū)塊鏈的可用性較低。如何有效提高區(qū)塊鏈的可用性成為目前需要解決的一個(gè)技術(shù)問題。

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

基于此，有必要針對(duì)上述技術(shù)問題，提供一種能夠有效提高區(qū)塊鏈可用性的區(qū)塊鏈集群處理系統(tǒng)和方法。

一種區(qū)塊鏈集群處理系統(tǒng)，所述系統(tǒng)包括計(jì)算集群和存儲(chǔ)集群，所述計(jì)算集群包括多個(gè)計(jì)算節(jié)點(diǎn)，所述存儲(chǔ)集群包括內(nèi)存數(shù)據(jù)庫集群和磁盤數(shù)據(jù)庫集群，所述內(nèi)存數(shù)據(jù)庫集群包括多個(gè)內(nèi)存數(shù)據(jù)庫，所述磁盤數(shù)據(jù)庫集群包括多個(gè)磁盤數(shù)據(jù)庫；所述計(jì)算集群在同一時(shí)刻只有一個(gè)計(jì)算節(jié)點(diǎn)工作，所內(nèi)存數(shù)據(jù)庫集群在同一時(shí)刻只有一個(gè)內(nèi)存數(shù)據(jù)庫工作，所述磁盤數(shù)據(jù)庫在同一時(shí)刻只有一個(gè)磁盤數(shù)據(jù)庫工作；當(dāng)前工作的計(jì)算節(jié)點(diǎn)獲取交易信息，對(duì)所述交易信息進(jìn)行計(jì)算得到對(duì)應(yīng)的區(qū)塊鏈數(shù)據(jù)，將所述區(qū)塊鏈數(shù)據(jù)寫入內(nèi)存數(shù)據(jù)庫集群中當(dāng)前工作的內(nèi)存數(shù)據(jù)庫，并且將所述區(qū)塊鏈數(shù)據(jù)寫入磁盤數(shù)據(jù)庫集群中當(dāng)前工作的磁盤數(shù)據(jù)庫；當(dāng)所述計(jì)算節(jié)點(diǎn)發(fā)生故障時(shí)，切換至所述計(jì)算集群中的其他計(jì)算節(jié)點(diǎn)繼續(xù)工作；當(dāng)所述內(nèi)存數(shù)據(jù)庫發(fā)生故障時(shí)，切換至所述內(nèi)存數(shù)據(jù)庫集群中的其他內(nèi)存數(shù)據(jù)庫繼續(xù)工作；當(dāng)所述磁盤數(shù)據(jù)庫發(fā)生故障時(shí)，切換至所述磁盤數(shù)據(jù)庫集群中的其他磁盤數(shù)據(jù)庫繼續(xù)工作。

在其中一個(gè)實(shí)施例中，所述計(jì)算集群包括多個(gè)，所述計(jì)算集群包括對(duì)應(yīng)的機(jī)構(gòu)標(biāo)識(shí)，其中一個(gè)機(jī)構(gòu)標(biāo)識(shí)對(duì)應(yīng)的計(jì)算集群的計(jì)算節(jié)點(diǎn)將交易信息發(fā)送至其他機(jī)構(gòu)標(biāo)識(shí)對(duì)應(yīng)的計(jì)算集群運(yùn)行中的計(jì)算節(jié)點(diǎn)進(jìn)行共識(shí)，得到其他機(jī)構(gòu)標(biāo)識(shí)對(duì)應(yīng)的計(jì)算集群返回的共識(shí)后的交易信息，所述計(jì)算節(jié)點(diǎn)利用共識(shí)后的交易信息進(jìn)行計(jì)算，得到對(duì)應(yīng)的區(qū)塊鏈數(shù)據(jù)。

在其中一個(gè)實(shí)施例中，當(dāng)所述計(jì)算節(jié)點(diǎn)將區(qū)塊鏈數(shù)據(jù)寫入內(nèi)存數(shù)據(jù)庫集群失敗時(shí)，所述計(jì)算節(jié)點(diǎn)對(duì)區(qū)塊鏈數(shù)據(jù)建立本地?cái)?shù)據(jù)緩存，在內(nèi)存數(shù)據(jù)庫集群將寫入失敗的內(nèi)存數(shù)據(jù)庫切換至其他內(nèi)存數(shù)據(jù)庫后，所述計(jì)算節(jié)點(diǎn)將本地緩存的區(qū)塊鏈數(shù)據(jù)寫入切換后的內(nèi)存數(shù)據(jù)庫。

在其中一個(gè)實(shí)施例中，當(dāng)所述計(jì)算節(jié)點(diǎn)將區(qū)塊鏈數(shù)據(jù)寫入磁盤數(shù)據(jù)庫集群失敗時(shí)，所述計(jì)算節(jié)點(diǎn)對(duì)區(qū)塊鏈數(shù)據(jù)建立本地?cái)?shù)據(jù)緩存，在磁盤數(shù)據(jù)庫集群將寫入失敗的磁盤數(shù)據(jù)庫切換至其他磁盤數(shù)據(jù)庫后，所述計(jì)算節(jié)點(diǎn)將本地緩存的區(qū)塊鏈數(shù)據(jù)寫入切換后的磁盤數(shù)據(jù)庫。

在其中一個(gè)實(shí)施例中，所述磁盤數(shù)據(jù)庫集群包括寫數(shù)據(jù)庫集群和讀數(shù)據(jù)庫集群，所述寫數(shù)據(jù)庫集群接收計(jì)算節(jié)點(diǎn)寫入的區(qū)塊鏈數(shù)據(jù)并且進(jìn)行存儲(chǔ)，所述讀數(shù)據(jù)庫集群與所述寫數(shù)據(jù)庫集群保存區(qū)塊鏈數(shù)據(jù)同步；當(dāng)計(jì)算節(jié)點(diǎn)讀取區(qū)塊鏈數(shù)據(jù)時(shí)，在所述度數(shù)據(jù)庫集群中進(jìn)行讀取。

在其中一個(gè)實(shí)施例中，所述系統(tǒng)還包括安全集群，所述安全集群包括多個(gè)安全節(jié)點(diǎn)，所述安全集群在同一時(shí)刻只運(yùn)行一個(gè)安全節(jié)點(diǎn)；所述安全節(jié)點(diǎn)用于接收計(jì)算節(jié)點(diǎn)上傳的驗(yàn)證信息，根據(jù)驗(yàn)證信息對(duì)區(qū)塊鏈?zhǔn)褂谜叩暮戏ㄐ赃M(jìn)行驗(yàn)證；當(dāng)所述安全節(jié)點(diǎn)發(fā)生故障時(shí)，切換至所述安全集群中的其他安全節(jié)點(diǎn)繼續(xù)運(yùn)行。

一種區(qū)塊鏈集群處理方法，所述方法應(yīng)用于計(jì)算集群，在同一時(shí)刻所述計(jì)算集群中只有一個(gè)計(jì)算節(jié)點(diǎn)工作，具體包括以下步驟：

獲取交易信息，對(duì)所述交易信息進(jìn)行計(jì)算，得到對(duì)應(yīng)的區(qū)塊鏈數(shù)據(jù)；

將所述區(qū)塊鏈數(shù)據(jù)寫入內(nèi)存數(shù)據(jù)庫集群，以使得所述內(nèi)存數(shù)據(jù)庫集群當(dāng)前工作的一個(gè)內(nèi)存數(shù)據(jù)庫接收所述區(qū)塊鏈數(shù)據(jù)并且進(jìn)行存儲(chǔ)；

將所述區(qū)塊鏈數(shù)據(jù)寫入磁盤數(shù)據(jù)庫集群，以使得所述磁盤數(shù)據(jù)庫集群當(dāng)前工作的一個(gè)磁盤數(shù)據(jù)庫接收所述區(qū)塊鏈數(shù)據(jù)并且進(jìn)行存儲(chǔ)；

當(dāng)所述計(jì)算節(jié)點(diǎn)發(fā)生故障時(shí)，切換至所述計(jì)算集群中的其他計(jì)算節(jié)點(diǎn)繼續(xù)工作。

在其中一個(gè)實(shí)施例中，所述計(jì)算集群包括多個(gè)，所述計(jì)算集群包括對(duì)應(yīng)的機(jī)構(gòu)標(biāo)識(shí)；在所述獲取交易信息的步驟之后，還包括：

將所述交易信息發(fā)送至其他機(jī)構(gòu)標(biāo)識(shí)對(duì)應(yīng)的計(jì)算集群運(yùn)行中的計(jì)算節(jié)點(diǎn)，以使得其他計(jì)算集群對(duì)所述交易信息進(jìn)行共識(shí)；

接收其他機(jī)構(gòu)標(biāo)識(shí)對(duì)應(yīng)的計(jì)算集群返回的共識(shí)后的交易信息；

利用共識(shí)后的交易信息進(jìn)行計(jì)算，得到對(duì)應(yīng)的區(qū)塊鏈數(shù)據(jù)。

在其中一個(gè)實(shí)施例中，所述方法還包括：

當(dāng)區(qū)塊鏈數(shù)據(jù)寫入內(nèi)存數(shù)據(jù)庫集群失敗時(shí)，對(duì)區(qū)塊鏈數(shù)據(jù)建立本地?cái)?shù)據(jù)緩存；