[發(fā)明專利]一種數(shù)據(jù)庫集群節(jié)點間數(shù)據(jù)同步系統(tǒng)

在審

• 申請?zhí)枺?/td>: 201810011460.2
• 申請日: 2018-01-05
• 公開（公告）號: CN108090222A
• 公開（公告）日: 2018-05-29
• 發(fā)明（設計）人: 程學旗;羅遠浩;鄭天祺;何文婷;余智華;許洪波;曹雷
• 申請（專利權(quán)）人: 中國科學院計算技術(shù)研究所;中科天璣數(shù)據(jù)科技股份有限公司
• 主分類號: G06F17/30
• 分類號: G06F17/30
• 代理公司: 北京市盛峰律師事務所 11337
• 代理人: 于國富

1.一種數(shù)據(jù)庫集群節(jié)點間數(shù)據(jù)同步系統(tǒng)，其特征在于，所述系統(tǒng)包括：

配置單元：負責將數(shù)據(jù)庫集群中需要實現(xiàn)數(shù)據(jù)同步的多個節(jié)點和/或多個表組建成同一個分組；

元數(shù)據(jù)存儲單元：存儲節(jié)點所屬分組的信息、任意一個分組中包含的節(jié)點信息和/或表信息；

元數(shù)據(jù)判斷單元：遍歷SQL語句中涉及的所有表，根據(jù)元數(shù)據(jù)存儲單元中的表信息判斷該SQL語句是否涉及同步表，如果否，則正常執(zhí)行SQL語句；如果是，則將該同步表信息和SQL語句發(fā)送給讀寫判斷單元；

讀寫判斷單元：判斷接收到的SQL語句是同步表的寫操作還是讀操作，如果是寫操作，則將該同步表信息發(fā)送給Paxos同步單元；如果是讀操作，則將該同步表信息發(fā)送給日志重現(xiàn)單元；

Paxos同步單元：根據(jù)接收到的同步表信息，進行該同步表所屬分組中多個節(jié)點之間的日志同步并執(zhí)行寫操作，同時，將寫操作日志保存在各個節(jié)點的日志存儲單元；

日志存儲單元：存儲同步表的寫操作日志；

日志重現(xiàn)單元：依據(jù)同步表信息從日志存儲單元中獲取該同步表的寫操作日志，通過日志重做使該同步表達到最新的一致狀態(tài)，然后再進行讀操作；

所述Paxos同步單元實現(xiàn)信息同步，具體為：

S1，將客戶端連接，以對同步表進行寫操作的集群節(jié)點作為提議者，提議者選擇一個提議序號n，所述提議序號n采用高位時間戳和低位服務器id的方式生成；

S2，提議者向數(shù)據(jù)庫集群的所有接受者發(fā)送準備請求，所述準備請求中攜帶提議編號n；

S3，任意一個接受者收到所述準備請求后，進行如下：

所述準備請求中攜帶提議編號n比該接受者之前響應過的其他請求攜帶的提議編號都大，則該接受者響應所述準備請求，并承諾不會響應之后接收到的其它任何提議編號小于等于n的請求；如果在接受所述準備請求前還響應過其他請求，則將最大提議編號及其對應的內(nèi)容反饋給提議者；如果在接受所述準備請求前未響應過其他請求，則反饋給提議者空值；

S4，當提議者接收到大多數(shù)接受者的響應后，檢查所有響應中是否有已被接受的提議返回；

如果任意一個響應中返回值不為空，則有已被接受的提議返回，將序號最高的提議對應的值替代該提議的初始值作為計算值，進入S5；

如果所有響應中返回值都是空，將提議的初始值作為計算值，進入S5；

S5，提議者向集群中的所有接受者廣播接受請求，所述接受請求中包括提議序號n和S4中的計算值；

S6，接受者收到所述接受請求后，將接受請求中的提議序號和當前minProposal進行比較，如果接收到的提議序號小于當前minProposal，則拒絕該接受請求，并將當前minProposal作為返回值反饋給提議者；如果接收到的提議序號大于等于當前minProposal，則接受該接受請求，然后保存該接受請求中的提議序號及計算值，同時，將minProposal更新為接受請求中的提議序號，然后將最新minProposal作為返回值反饋給提議者；

S7，當提議者接收到大多數(shù)接受者的響應后，提議者將收到的返回值與所述接受請求的提議編號n進行比較，判斷是否存在任意一個返回值大于提議者的提議編號，如果是，則返回S1，進行下一輪信息同步，下一輪信息同步的提議者選取的提議編號為所有返回值中提議編號最大的下一個值；如果否，則所有接受者都接受所述接受請求，所述接受請求中的提議值被選定，達到一致性狀態(tài)，信息同步結(jié)束執(zhí)行。