[發(fā)明專利]一種數(shù)據(jù)的同步方法和裝置

有效

• 申請?zhí)枺?/td>: 201610179749.6
• 申請日: 2016-03-25
• 公開（公告）號: CN107231400B
• 公開（公告）日: 2020-07-03
• 發(fā)明（設(shè)計）人: 周遙
• 申請（專利權(quán)）人: 阿里巴巴集團控股有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京匯思誠業(yè)知識產(chǎn)權(quán)代理有限公司 11444
• 代理人: 王剛;龔敏

本發(fā)明提供了一種數(shù)據(jù)的同步方法，所述方法包括：當?shù)谝唤K端設(shè)備接收到數(shù)據(jù)時，所述第一終端設(shè)備將接收到所述數(shù)據(jù)的時間戳添加到所述數(shù)據(jù)中；所述第一終端設(shè)備將添加有所述時間戳的所述數(shù)據(jù)發(fā)送給所述第二終端設(shè)備，并保存添加有所述時間戳的所述數(shù)據(jù)；所述第一終端設(shè)備接收所述第二終端設(shè)備根據(jù)添加有所述時間戳的所述數(shù)據(jù)反饋的數(shù)據(jù)，以使所述第一終端設(shè)備根據(jù)自身保存的添加有所述時間戳的所述數(shù)據(jù)和所述反饋的數(shù)據(jù)進行數(shù)據(jù)同步。本發(fā)明在不借助第三方設(shè)備和選舉發(fā)送數(shù)據(jù)設(shè)備的情況下實現(xiàn)了終端設(shè)備集群的數(shù)據(jù)同步，降低了數(shù)據(jù)同步時的成本，并且集群中的終端設(shè)備是根據(jù)自身得到的數(shù)據(jù)來進行同步，保證了數(shù)據(jù)同步時的可靠性。

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

本發(fā)明涉及網(wǎng)絡(luò)技術(shù)領(lǐng)域，尤其涉及一種數(shù)據(jù)的同步方法和裝置。

背景技術(shù)

在現(xiàn)有技術(shù)中，為了實現(xiàn)服務(wù)器集群中數(shù)據(jù)的一致性，提出了以下兩種解決方案：

如圖1所示的方案一：在服務(wù)器集群中增加一個配置中心，當其中一個服務(wù)器(發(fā)布者)獲取到數(shù)據(jù)并要將所述數(shù)據(jù)同步到其他服務(wù)器(訂閱者)中時，所述服務(wù)器將所述數(shù)據(jù)發(fā)送到所述配置中心，有所述配置中心向其他服務(wù)器發(fā)送所述數(shù)據(jù)，進而使其他服務(wù)器根據(jù)所述數(shù)據(jù)進行同步。

如圖2所示的方案二：所述服務(wù)器集群通過選舉算法選舉出一個發(fā)布者Master，其他服務(wù)器為訂閱者，選擇成功后，當需要讓所述服務(wù)器集群同步一個數(shù)據(jù)時，由所述Master獲取所述數(shù)據(jù)，再由所述Master向訂閱者發(fā)送需要同步的數(shù)據(jù)，以使所述訂閱者進行數(shù)據(jù)同步，在訂閱者同步成功后向Master返回同步成功的消息，當所述Master宕機后，所述服務(wù)器集群需要重進選舉Master。

在實現(xiàn)本發(fā)明的過程中，發(fā)明人發(fā)現(xiàn)現(xiàn)有技術(shù)至少存在如下問題：

方案一在同步數(shù)據(jù)時依賴第三方設(shè)備，部署麻煩，可靠性不高，而方案二中如果集群中的服務(wù)器數(shù)量較大時，訂閱者返回的同步成功的消息數(shù)量也就會越多，進而使得數(shù)據(jù)同步時的成本大大增加，并且在Master宕機后，重新選舉時也會增加數(shù)據(jù)同步時的成本。

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

本發(fā)明提供一種數(shù)據(jù)的同步方法和裝置，用于解決現(xiàn)有技術(shù)中依賴第三方設(shè)備，部署麻煩，可靠性不高的問題；

本發(fā)明提供一種數(shù)據(jù)的同步方法和裝置，還用于解決現(xiàn)有技術(shù)中數(shù)據(jù)同步成本較高的問題。

本發(fā)明提供一種數(shù)據(jù)的同步方法，所述方法應(yīng)用于包括第一終端設(shè)備和第二終端設(shè)備的系統(tǒng)中，其中，所述第一終端設(shè)備和所述第二終端設(shè)備的時間是同步的，所述第二終端設(shè)備為多個，所述方法包括：

當?shù)谝唤K端設(shè)備接收到數(shù)據(jù)時，所述第一終端設(shè)備將接收到所述數(shù)據(jù)的時間戳添加到所述數(shù)據(jù)中；

所述第一終端設(shè)備將添加有所述時間戳的所述數(shù)據(jù)發(fā)送給所述第二終端設(shè)備，并保存添加有所述時間戳的所述數(shù)據(jù)；

所述第一終端設(shè)備接收所述第二終端設(shè)備根據(jù)添加有所述時間戳的所述數(shù)據(jù)反饋的數(shù)據(jù)，以使所述第一終端設(shè)備根據(jù)自身保存的添加有所述時間戳的所述數(shù)據(jù)和所述反饋的數(shù)據(jù)進行數(shù)據(jù)同步。

所述第一終端設(shè)備和所述第二終端中相同的數(shù)據(jù)具有相同的數(shù)據(jù)標識；

所述反饋的數(shù)據(jù)是所述第二終端設(shè)備根據(jù)具有相同所述數(shù)據(jù)標識的數(shù)據(jù)確定的時間戳最大的數(shù)據(jù)。

所述第一終端設(shè)備根據(jù)自身保存的添加有所述時間戳的所述數(shù)據(jù)和所述反饋的數(shù)據(jù)進行數(shù)據(jù)同步，具體為：

所述第一終端設(shè)備判斷具有相同所述數(shù)據(jù)標識的數(shù)據(jù)的數(shù)目之和是否大于閾值；

當大于所述閾值時，所述第一終端設(shè)備確定出具有相同所述數(shù)據(jù)標識的數(shù)據(jù)中最大時間戳對應(yīng)的數(shù)據(jù)；

所述第一終端設(shè)備根據(jù)最大時間戳對應(yīng)的數(shù)據(jù)進行數(shù)據(jù)同步。