一种分布式数据库数据同步方法

摘要

本发明涉及分布式数据库，其公开了一种分布式数据库数据同步方法，以实现嵌入式设备板卡之间的数据同步，同时保证板卡数据的一致性，提高数据同步的效率。其实现步骤包括：a.源板卡对分布式数据库中的操作进行下发；b.各目的板卡的分布式数据库接收到源板卡下发的操作后，对其进行缓存，并向源板卡的分布式数据库返回确认消息；c.源板卡的分布式数据库接收到所有目的板卡的确认消息后，向目的板卡的分布式数据库发送执行消息；d.各目的板卡的分布式数据库接收到执行消息后，执行其缓存的操作，并将将执行结果返回给源板卡的分布式数据库。本发明适用于嵌入式设备板卡之间的数据同步。

主权项

一种分布式数据库数据同步方法，其特征在于，包括以下步骤：a.源板卡对其分布式数据库中的操作进行下发：源板卡首先对其分布式数据库的数据库表执行所述操作，如果操作成功，则对所述源板卡的分布式数据库中的操作进行下发，每一个被下发的所述操作都分配有唯一的序列号；如果操作失败，则不进行操作下发；b.各目的板卡的分布式数据库接收到源板卡下发的操作后，对该操作进行缓存，并向源板卡的分布式数据库返回确认消息；c.源板卡的分布式数据库接收到所有目的板卡的确认消息后，向目的板卡的分布式数据库发送执行消息；d.各目的板卡的分布式数据库接收到执行消息后，执行其缓存的操作，并将执行结果返回给源板卡的分布式数据库；所述源板卡是指主用主控卡，所述目的板卡包括业务线卡和备用主控卡；源板卡如果发生了主备切换，则切换后，备用主控卡作为切换后的源板卡执行如下操作：（1）如果切换后的源板卡中无切换前的源板卡下发的操作，则切换后的源板卡向目的板卡发送切换通知消息，并携带最新操作序列号；各个目的板卡接收到切换通知消息后，将所述最新操作序列号与本地最新操作序列号相比较，丢弃本地缓存中比切换通知消息中操作序列号新的操作；（2）如果切换后的源板卡接收有切换前的源板卡下发的操作但是还未执行，则切换后的源板卡需要重发操作，目的板卡判断本地缓存中是否有对应操作，如否，则目的板卡缓存该操作并向切换后的源板卡的分布式数据库返回确认消息，否则，不管是否执行，则向切换后的源板卡的分布式数据库直接返回确认消息；（3）如果切换后的源板卡已经执行切换前的源板卡下发的操作但未将执行结果返回给源板卡的分布式数据库，则切换后的源板卡向目的板卡发送执行消息，如果目的板卡判断本地缓存的对应操作还未执行，则目的板卡执行操作并发送执行结果消息；若目的板卡判断本地缓存的对应操作已经执行但未将执行结果返回给源板卡的分布式数据库，则目的板卡发送缓存中的执行结果；（4）如果切换后的源板卡判断目的板卡的执行结果出现错误，则切换后的源板卡发送错误消息，目的板卡向切换后的源板卡发送错误确认消息；（5）如果切换后的源板卡缓存的操作已经终结，则切换后的源板卡在切换之初，下发本地缓存中最小的操作序列号和最大的操作序列号对应的操作到目的板卡，目的板卡接收到操作后，丢弃序列号小于切换后的源板卡发送的最小序列号的操作和序列号大于切换后的源板卡发送的最大序列号的操作。