一种集群间跨机房同步的方法和装置.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN108228397A(43)申请公布日2018.06.29(21)申请号201611200103.8(22)申请日2016.12.22(71)申请人深圳市优朋普乐传媒发展有限公司地址518000广东省深圳市罗湖区翠竹街道2058号旭飞华达园裙楼3楼309－3Q(72)发明人张宏涛(51)Int.Cl.G06F11/20(2006.01)G06F11/16(2006.01)G06F9/44(2018.01)G06F9/54(2006.01)权利要求书4页说明书12页附图6页(54)发明名称一种集群间跨机房同步的方法和装置(57)摘要本发明公开了一种集群间跨机房同步的方法和装置，以解决目前集群跨机房同步时延较长且同步可靠性较差的问题。该方法为，位于第一机房的第一同步系统在实时同步状态下，实时向位于第二机房的第二同步系统发送增量数据；在发送所述增量数据失败时，所述第一同步系统进入延时同步状态，以及将所述增量数据写入到增量同步队列中。这样能够基于同步状态实现跨机房同步，实时同步状态下使得同步时延较小，延时同步状态下保证数据同步的可靠性，使同步数据达到最终一致。CN108228397ACN108228397A权利要求书1/4页1.一种集群间跨机房同步的方法，其特征在于，包括：位于第一机房的第一同步系统在实时同步状态下，实时向位于第二机房的第二同步系统发送增量数据；在发送所述增量数据失败时，所述第一同步系统进入延时同步状态，以及将所述增量数据写入到增量同步队列中。2.如权利要求1所述的方法，其特征在于，所述方法还包括：所述第一同步系统从所述增量同步队列中读取数据同步到所述第二同步系统；所述第一同步系统将所述增量数据写入到增量同步队列中，包括：所述第一同步系统确定所述增量同步队列所处的状态；所述第一同步系统基于所述增量同步队列所处的状态，将所述增量数据写入到所述增量同步队列中；所述第一同步系统从所述增量同步队列中读取数据同步到所述第二同步系统，包括：所述第一同步系统确定所述增量同步队列所处的状态；所述第一同步系统基于所述增量同步队列所处的状态，从所述增量同步队列中读取数据同步到所述第二同步系统。3.如权利要求2所述的方法，其特征在于，所述增量同步队列包括普通队列和后备队列；所述第一同步系统确定所述增量同步队列所处的状态，包括：若所述后备队列中没有存储任何数据且所述第一机房与所述第二机房间心跳失败次数小于预设阈值时，确定所述增量同步队列所处的状态为正常状态；若所述第一机房与所述第二机房间心跳失败次数达到所述预设阈值时，确定所述增量同步队列所处的状态为后备状态；所述第一同步系统基于所述增量同步队列所处的状态，将所述增量数据写入到所述增量同步队列中，包括：在所述增量同步队列所处的状态为正常状态时，将所述增量数据写入到所述普通队列中；在所述增量同步队列所处的状态为后备状态时，将所述增量数据写入到所述后备队列中。4.如权利要求3所述的方法，其特征在于，所述增量同步队列还包括前沿队列；所述第一同步系统确定所述增量同步队列所处的状态，还包括：若从所述增量同步队列中读取数据发送到所述第二同步系统的操作失败时，将同步的所述增量数据写入到所述第一机房的前沿队列中，确定所述增量同步队列所处的状态为前沿状态；若从所述前沿队列中获取数据发送到所述第二同步系统的操作成功且所述前沿队列中无数据时，确定所述增量同步队列所处的状态为非前沿状态；所述第一同步系统基于所述增量同步队列所处的状态，从所述增量同步队列中读取数据同步到所述第二同步系统，包括：在所述增量同步队列所处的状态为前沿状态时，从所述前沿队列中读取数据同步到所述第二同步系统；2CN108228397A权利要求书2/4页在所述增量同步队列所处的状态为非前沿状态时，先从所述普通队列中读取数据同步到所述第二同步系统，在所述普通队列中无数据时，再从所述后备队列中读取数据同步到所述第二同步系统。5.如权利要求3或4所述的方法，其特征在于，在所述增量同步队列所处的状态为后备状态时，所述方法还包括：从所述后备队列中读取设定数量的数据执行合并操作，并写入所述普通队列；和/或，对所述普通队列中设定数量的数据执行合并操作。6.如权利要求1所述的方法，其特征在于，所述第一同步系统将所述增量数据写入到增量同步队列中，包括：所述第一同步系统将所述增量数据对应的更改动作和对应的索引键值和数据键值写入到所述增量同步队列中。7.如权利要求1所述的方法，其特征在于，所述方法还包括：所述第一同步系统从所述增量同步队列中读取数据同步到所述第二同步系统；在所述增量同步队列中无数据时，所述第一同步系统进入实时同步状态。8.如权利要求1所述的方法，其特征在于，所述方法还包括：从所