一种数据同步方法、装置、设备和存储介质
摘要文本
本申请涉及一种数据同步方法、装置、设备和存储介质。主要技术方案包括:响应于心跳集群中至少一个节点心跳检测异常,将心跳检测异常节点的运行状态由正常状态切换为延迟状态,响应于心跳检测异常节点在预设次数心跳检测内恢复正常,将心跳检测异常节点的运行状态由延迟状态切换为正常状态,获取心跳集群中的正常节点在心跳检测异常节点处于延迟状态中的节点数据和心跳检测异常节点的原始数据,根据节点数据和原始数据,同步心跳检测异常节点的数据,通过添加节点的延迟状态,保证集群中各个节点的运行状态被正常查询,准确快速地判断各个节点的异常状态并处理异常情况,并同步延迟状态期间的数据保证集群中各个节点的数据一致性。
申请人信息
- 申请人:苏州元脑智能科技有限公司
- 申请人地址:215000 江苏省苏州市吴中经济开发区郭巷街道官浦路1号9幢
- 发明人: 苏州元脑智能科技有限公司
专利详细信息
| 项目 | 内容 |
|---|---|
| 专利名称 | 一种数据同步方法、装置、设备和存储介质 |
| 专利类型 | 发明授权 |
| 申请号 | CN202311697060.9 |
| 申请日 | 2023/12/12 |
| 公告号 | CN117395263B |
| 公开日 | 2024/3/12 |
| IPC主分类号 | H04L67/1095 |
| 权利人 | 苏州元脑智能科技有限公司 |
| 发明人 | 袁东海; 胡玉鹏; 李红卫 |
| 地址 | 江苏省苏州市吴中经济开发区郭巷街道官浦路1号9幢 |
专利主权项内容
1.一种数据同步方法,其特征在于,所述方法包括:响应于心跳集群中至少一个节点心跳检测异常,将心跳检测异常节点的运行状态由正常状态切换为延迟状态,其中,所述心跳集群为采用基于高级消息队列协议的消息队列的集群,所述基于高级消息队列协议为rabbitmq协议,所述心跳集群为rabbitmq集群;响应于所述心跳检测异常节点在预设次数心跳检测内恢复正常,将所述心跳检测异常节点的运行状态由延迟状态切换为正常状态;获取所述心跳集群中的正常节点在所述心跳检测异常节点处于延迟状态中的节点数据和所述心跳检测异常节点的原始数据,其中,所述正常节点为所述心跳集群中除心跳检测异常的心跳检测异常节点之外的节点,所述节点数据为所述正常节点的当前数据,包括基础数据和更新数据,所述基础数据为所述正常节点在所述心跳检测异常节点转换为延迟状态之前的数据,所述更新数据为所述正常节点在所述心跳检测异常节点处于延迟状态过程中同步的数据,所述原始数据为所述心跳检测异常节点在转换为延迟状态之前的数据;根据所述节点数据和所述原始数据,同步所述心跳检测异常节点的数据,具体包括:当所述基础数据、所述更新数据和所述原始数据中任一数据发生变化时,判断所述更新数据与所述原始数据是否进行合并;若所述更新数据与所述原始数据进行合并,校验所述节点数据和合并后的数据是否一致,得到一致性结果;当所述一致性结果为数据一致时,确定所述心跳检测异常节点的同步数据为所述合并后的数据;当所述一致性结果为数据不一致时,删除所述心跳检测异常节点上合并后的数据;向所述心跳检测异常节点上同步所述正常节点的节点数据。 数据由马 克 团 队整理