(19)国家知识产权局 (12)发明 专利 (10)授权公告 号 (45)授权公告日 (21)申请 号 20221013791 1.3 (22)申请日 2022.02.15 (65)同一申请的已公布的文献号 申请公布号 CN 114490691 A (43)申请公布日 2022.05.13 (73)专利权人 北京中电兴发科技有限公司 地址 100095 北京市海淀区地锦路7号院5 号楼 (72)发明人 王华　瞿洪桂　李鹏飞　范斌　 (74)专利代理 机构 北京市盛峰律师事务所 11337 专利代理师 席小东 (51)Int.Cl. G06F 16/23(2019.01) G06F 16/27(2019.01)(56)对比文件 CN 109062592 A,2018.12.21 CN 103036717 A,2013.04.10 CN 110362583 A,2019.10.2 2 CN 112817995 A,2021.0 5.18 US 10860604 B1,2020.12.08 JP 20101287 76 A,2010.0 6.10 US 2014201343 A1,2014.07.17 审查员 叶斯秋 (54)发明名称 一种分布式系统数据一 致性方法 (57)摘要 本发明提供一种分布式系统数据一致性方 法， 包括以下步骤： 步骤S1， 网关维护数据库中配 置记录； 步骤S2， 管理节点启动 初始化过程； 步骤 S3， 数据同步机制； 步骤S4， 管理节点监控机制。 本发明提供一种分布式系统数据一致性方法， 在 提供各管 理节点数据最终一致性方案的同时， 确 保系统响应的及时性， 同时通过数据同步机制以 及管理节点监控机制对各管理节点数据能在预 期时间内达 到最终一 致提供了保障。 权利要求书2页 说明书7页 附图3页 CN 114490691 B 2022.08.16 CN 114490691 B 1.一种分布式系统数据一 致性方法， 其特 征在于， 包括以下步骤： 步骤S1， 网关维护数据库中配置记录： 步骤S1.1： 网关配置有数据库； 所述数据库用于存储所述网关管理的所有管理节点的 配置记录； 其中， 每条所述配置记录包括配置参数Key、 配置参数值Value和配置版本号 Version； 其中， 如果所述配置记录为默认配置记录， 则配置参数值Value为默认配置参数值， 配 置版本号Versi on为默认配置版本号； 所述网关将各 条默认配置记录发送给 各个管理节点； 每当所述配置记录更新一次时， 更新配置参数值Value， 并且， 配置版本号Version增加 1； 步骤S1.2： 客户端通过web界面向网关下发最新的管理节点配置数据D(new)； 其中， 所 述管理节点配置数据D(new)为 二元组， 包括配置参数 Key(new)和配置参数值Value(new)； 步骤S1.3： 网关接收到所述客户端下发的管理节点配置数据D(new)后， 查找数据库， 得 到与配置参数Key(new)对应的配置记录， 从所述配置记录中读取到配置参数Key(old)、 配 置参数值Value(old)和配置版本号Version(old)； 其中， 配置参数Key(old)和配置参数Key (new)相同； 网关判断配置参数值Value(new)是否与配置参数值Value(old)相同， 如果相同， 表明 客户端下发的管理节点配置数据与数据库存储的配置记录相同， 则不更新数据库， 网关向 客户端返回配置成功的通知消息； 然后执 行步骤2； 如果不相同， 网关采用以下方式更新数据库： 采用配置参数值Value(new)更新配置参 数值Value(old)， 并使配置版本号Version(ol d)加1； 然后， 网关向客户端返回配置成功的 通知消息； 执 行步骤2； 步骤S2， 管理节点启动初始化过程： 步骤S2.1： 每个管理节点存储本地配置文件File(original)； 所述本地配置文件File (original)， 用于存储该管理节点的管理节点配置数据； 其中， 每个所述管理节点配置数 据， 包括所述网关下发的默认配置记录； 步骤S2 .2： 每当管理节点重新启动时， 管理节点获取所述本地配置文件File (original)， 采用所述本地配置文件 File(original)， 对本进程配置版本进行设置， 以通过 进程执行所述本地配置文件File(original)； 其中， 所述本地配置文件File(original)， 具 有配置参数Key(original)、 配置参数值Value(original)和配置版本号Version (original)； 然后执 行步骤S2.3； 如果管理节点获取所述本地配置文件失败， 则创建新的本地配置文件File (original)， 在本地配置文件File(original)中， 具有配置参数Key(original)、 配置参数 值Value(original)和配置版本号Version(original)； 其中， 配置参数值Value(original) 采用默认配置参数值设置； 配置版本号Version(or iginal)采用默认配置版本号设置； 然后 执行步骤S2.3； 步骤S2.3： 管理节点在 首次成功连接到网关时， 向网关发送配置参数Key(original)对 应的配置版本号的配置信息获取请求； 步骤S2.4： 网关接收到配置信息获取请求时， 查询所述数据库， 得到对应的配置版本 号， 表示为配置版本号Versi on(query)， 并下发给 管理节点；权　利　要　求　书 1/2 页 2 CN 114490691 B 2步骤S2.5： 管理节点比较网关下发的配置版本号Version(query)是否与本地配置文件 File(original)中的配置版本号Version(original)一致， 如果一致， 则不进行处理； 如果 不一致， 则执行步骤S2.6； 步骤S2.6： 管理节点向网关发送获取配置参数Key(original)对应 的配置参数值的获 取请求； 步骤S2.7： 网关查询所述数据库， 得到对应的配置参数值， 表示为配置参数值Value (query)， 并下发给 管理节点； 步骤S2.8： 管理节点采用以下方法， 更新本地配置文件File(original)： 采用配置参数 值Value(query)更新配置参数值Value(original)； 采用配置版本号Version(query)更新 配置版本号Versi on(original)； 由此实现分布式系统各 管理节点的配置一 致性。 2.根据权利要求1所述的一种分布式系统数据一致性方法， 其特征在于， 还包括： 步骤 S3， 数据同步机制： 步骤S3.1， 网关定时向各个管理节点下发每个配置参数Key的最新配置版本号Version (N_new)； 网关判断是否在设定时间内接收到所述管理节点的同步版本响应消息， 如果没有， 则 网关尝试 连续下发设定数量的最 新配置版本号Versi on(N_new)给对应的管理节点； 步骤S3.2， 每当管理节点接收到所述网关下发的配置参数Key的最新配置版本号 Version(N_new)时， 向所述网关发送同步版本响应消息； 然后， 管 理节点比较最新配置版本 号Version(N_new)与本地配置文件File(original)中的配置版本号Version(original)是 否一致， 如果一致， 则不进 行更新操作； 如果不一致， 则向网关发送配置参数Key的配置参数 值的获取请求； 步骤S3.3， 网关下发最 新配置参数值Value(N_new)到管理节点； 步骤S3.4， 管理节点采用以下 方式更新本地配置文件Fi le(origi nal)： 采用最新配置参数值Value(N_new)更新本地配置文件File(original)中的对应的配 置参数值Value(original)； 采用最新配置版本号Version(N_new)， 更新本地配置文件File (original)中的对应的配置版本号Versi on(original)。 3.根据权利要求1所述的一种分布式系统数据一致性方法， 其特征在于， 还包括： 步骤 S4， 管理节点 监控机制： 步骤S4.1： 网关与各个管理节点建立链路后， 以心跳方式维持链路； 当网关检测到与某 个管理节点之间超过设定时间的心跳消息丢失时， 得出该管理节点发生故障的结论， 生成 管理节点故障告警消息； 步骤S4.2： 将故障的管理节点表示 为： 管理节点 node(fault)； 网关重启管理节点 node(fault)； 管理节点 node(fault)重启后， 执 行步骤S2.2。权　利　要　求　书 2/2 页 3 CN 114490691 B 3