CN119484230A 基于双引擎协同的分布式服务智能选主方法及系统 （北京科杰科技有限公司）

基于双引擎协同的分布式服务智能选主方本发明提供基于双引擎协同的分布式服务包括采集服务节点的处理能力指数、网络吞吐启动基于Redis事务的增量状态同步，实现主备2创建服务实例并将所述智能标识码写入Redis存储引擎的有序集合，同时激活双层事件监所述双层事件监听器检测到新节点加入信号时，提取所述有序集合中形成动态优先级序列；听器用于捕获Nacos的实例状态变更信号和Redis的数据结构变将所述性能数据矩阵输入节点评分函数进行计算，输出节点评分结在Nacos注册中心创建分布式服务实例，将所述节点的智能标识码写入所述分布式服节点的智能标识码按照性能评分从高到低的顺序进行排列；激活双层事件监听器，所述双层事件监听器包括Nacos实例监听层和Redis数据监听据监听层通过键空间通知机制捕获有序集合的数所述双层事件监听器将捕获的状态变更信号和数据变化信号整合为统一的事件消息3基于所述概率分布特征选择最优步长计算策略：当所述步长样本集所述自适应调节模块首先获取集群当前的活跃节点数量，根据所述活采集新加入节点的性能指标，同时计算集群现有节点的平均性能水提取所述有序分值序列中每个分值的生成时间戳，计算各分值距当前时刻的时间间分析历史分值调整记录，提取分值调整的频率特征和幅所述最优分值递增步长用于表征相邻节点间的优先级间距；解析新节将所述最优分值递增步长与所述性能权重系数相乘得到基准分值；将从节点状态监控模块获取节点的运行时长的计数值；基于所述运行将所述节点初始目标分值与所述时间衰减因子相乘，得到更新后的动态优先级序列。从所述动态优先级序列中选取优先级值最高的节点作为主节点；选4监控所述第一缓冲区和所述第二缓冲区的数据量；当所述第构建基于时间窗口的轻量级内存快照机制；在每个快部署双层事件监听器，所述双层事件监听器的本地监控层采集节点的系统负载指标、所述Z_score异常检测模型基于历史数据计算各指标的均值和标准差；将当前指标值与对基于所述状态确认结果判断所述预热备用节点是否满足提升条件；当满足提升条件基于所述最新操作序号构建增量状态同步任务，所述增量状态同步对所述待同步的操作批次序列执行增量数据迁移：将每个操作批次5通过EXEC命令原子性执行所述Redis命令序列，更新同步进度标记，生成数据迁移完成标基于所述数据迁移完成标识触发主备切换：向Nacos注册服务器提交所述新主节点的角色信息和结束节点信息，通过Nacos服务发现机制将所述新主节点的角色信息和结束节为所述新主节点分配全局唯一的版本号，构建基8.基于双引擎协同的分布式服务智能选主系统，用于实现前述权利要求1_7中任一项第二单元，用于所述双层事件监听器检测到新节点加入信号第三单元，用于周期性从所述动态优先级序列中提取最高优其中，所述处理器被配置为调用所述存储器存储的指令，以执行程序指令被处理器执行时实现权利要求1至7中任意6[0003]现有的主节点选择方法主要包括静态配置、基于ZooKeeper的选举和基于数据库中心创建服务实例并将所述智能标识码写入Redis存储引擎的有序集合，同时激活双层事先级节点作为预热备用节点；所述双层事件监听器检测到主节点负载异常或故障信号时，7务特性确保主备切换过程的原子性，并通过Nacos的服务发现功能向集群广播新主节点信在Nacos注册中心创建分布式服务实例，将所述节点的智能标识码写入所述分布式服务实例的扩展属性字段；同步将所述节点的智能标识码写入Redis存储引擎的有序集合中的节点的智能标识码按照性能评分从高到低的顺序进行排列；数据监听层通过键空间通知机制捕获有序集合的数据所述双层事件监听器将捕获的状态变更信号和数据变化信号整合为统一的事件系统负载动态调整；将所述性能修正步长与所述时间权重进行加权计算得到时序加权步8合形成优先级更新记录；将所述优先级更新记录按照分值大小插入所述节点优先级序列，生成更新后的动态优先级序列。的当前内存状态得到当前内存快照；将所述当前内存快照与上一周期的内存快照进行比9当所述累积异常值超过触发阈值时，启动基于Raft协议的分布式投票仲裁流程；[0013]确认后将所述预热备用节点提升为新主节点，同时通过增量状态同步机制完成通过管道化方式打包传输至所述新主节点，在所述新主节点将操作批次转换为Redis命令基于所述数据迁移完成标识触发主备切换：向Nacos注册服务器提交所述新主节点的角色信息和结束节点信息，通过Nacos服务发现机制将所述新主节点的角色信息和结所述节点评分函数的计算结果与服务器物理时钟值进行加权组合，生成节点的智能标识码；在Nacos注册中心创建服务实例并将所述智能标识码写入Redis存储引擎的有序集合，同时激活双层事件监听器，所述双层事件监听器用于捕获Nacos的实例状态变更信号和第三单元，用于周期性从所述动态优先级序列中提取最高优先级节点作为主节[0023]图1为本发明实施例基于双引擎协同的分布式服务智能选主方法的流程示意图，注册中心创建服务实例并将所述智能标识码写入Redis存储引擎的有序集合，同时激活双事务特性确保主备切换过程的原子性，并通过Nacos的服务发现功能向集群广播新主节点[0024]在一种可选的实施方式中,将所述节点评分函数的获Nacos的实例状态变更信号和Redis的数据结构变在Nacos注册中心创建分布式服务实例，将所述节点的智能标识码写入所述分布式服务实例的扩展属性字段；同步将所述节点的智能标识码写入Redis存储引擎的有序集合中的节点的智能标识码按照性能评分从高到低的顺序进行排列；数据监听层通过键空间通知机制捕获有序集合的数据能标识码包含了性能评分部分和时序标识部分，其中性能评分部分用于排序，时序标识部分用于区分同一性能评分下的不同节点。户端可以根据节点的性能评分快速选择最优的节点，从而提高服务的响应速度和稳定性。[0032]在一种可选的实施方式中,所述双层事件监所述双层事件监听器将捕获的状态变更信号和数据变化信号整合为统一的事件系统负载动态调整；将所述性能修正步长与所述时间权重进行加权计算得到时序加权步[0033]双层事件监听器检测新节点加入并计算最优分值递增步长的方法，具体实施如首先，部署一个双层事件监听器，用于实时监控Redis集群的状态变化和数据变能比值约为0.89。根据性能比值计算性能系数。假设性能比值为0.89对应的性能系数为提高节点排序的精准性:通过分析已有节点分值的分布趋势和新加入节点的性能群的稳定性:通过自适应调节模块和时序加权机制，可以根据集群负载和节点性能动态调[0043]在一种可选的实施方式中,将所述最优分值递增步长与新节点的智能标识码组合合形成优先级更新记录；将所述优先级更新记录按照分值大小插入所述节点优先级序列，生成更新后的动态优先级序列。[0044]一种基于智能标识码和运行时长的节点动态优先级排序方法，用于优化资源调[0052]在一种可选的实施方式中,周期性从所述动态优的当前内存状态得到当前内存快照；将所述当前内存快照与上一周期的内存快照进行比[0055]在主节点A和预热备用节点B之间构建具有写前日志功能的双缓冲数据同步通[0063]将差异数据传输至预热备用节点B。预热备用节点B基于差异数据还原主节点A的[0066]在一种可选的实施方式中,所述双层事件监听当所述累积异常值超过触发阈值时，启动基于Raft协议的分布式投票仲裁流程；[0067]一种基于双层事件监听器和Raft协议的主节点故障检测方法，具体实现步骤如[0071]当累积异常值超过预设的触发阈值时，例如，阈值设置为5，当前累积异常值为[0074]在一种可选的实施方式中,确认后将所述事务特性确保主备切换过程的原子性，并通过Nacos的服务发现功能向集群广播新主节点通过管道化方式打包传输至所述新主节点，在所述新主节点将操作批次转换为Redis命令基于所述数据迁移完成标识触发主备切换：向Nacos注册服务器提交所述新主节点的角色信息和结束节点信息，通过Nacos服务发现机制将所述新主节点的角色信息和结个批量请求发送给新主节点。在新主节点上，将操作批次转换为Redis命令序列，并通过提升系统可用性:通过预热备用节点和增量状态同步机制，可以实现快速的主备[0085]图2为本发明实施例基于双引擎协同的分布式服务智能选主系统的结构示意图，所述节点评分函数的计算结果与服务器物理时钟值进行加权组合，生成节点的智能标识码；在Nacos注册中心创建服务实例并将所述智能标识码写入Red