1 .一种基于 Etcd 的分布式中间件元数据管理方法,其特征在于,包括:
元数据全量加载,包括:
管理节点集群向Etcd集群请求并获取元数据;
元数据变更推送增量,包括:
在线执行器接收DDL变更请求,发送给随机选择的一第一管理节点;
第一管理节点在Etcd节点上持久化数据变更,记录Etcd节点数据版本号作为元数据变
更记录版本号;
第一管理节点利用Etcd的订阅发布机制广播元数据变更任务;
管理节点集群中的其他管理节点利用Etcd的订阅发布机制接收元数据变更任务,分别
向其在线执行器推送;
其他管理节点的在线执行器响应元数据变更任务推送,应用增量更新;
第一管理节点更新Etcd节点中的变更任务信息;
第一管理节点检查是否收到所有其他管理节点的响应信息,将广播结果反馈给发送
DDL变更请求的在线执行器;
元数据定时比对变更,包括:
在线执行器定时发送本地元数据信息给其管理节点,本地元数据信息包括本地元数据
的压缩包、变更记录版本号及快照;
管理节点将本地元数据快照的哈希值与管理节点当前元数据快照的哈希值进行比对;
当哈希值不一致,管理节点解压缩本地元数据,比对每一条变更记录,根据变更记录版
本号是否一致决定是否向其在线执行器推送元数据变更任务;
在线执行器响应元数据变更任务推送,应用增量更新。
2 .如权利要求1所述的基于 Etcd 的分布式中间件元数据管理方法,其特征在于,还包
括断链恢复检查元数据:当在线执行器与其管理节点发生断链并重新连接时,在线执行器
主动发起增量比对,以对齐元数据。
3 .如权利要求2所述的基于 Etcd 的分布式中间件元数据管理方法,其特征在于,在线
执行器主动发起增量比对,以对齐元数据,包括:
在线执行器发送本地元数据变更记录版本号及快照给其管理节点;
管理节点将本地元数据变更记录版本号、快照的哈希值分别与管理节点当前元数据变
更记录版本号、快照的哈希值进行比对;
当哈希值不一致或本地元数据变更记录版本号较旧,管理节点下发增量信息到在线执
行器;
在线执行器应用增量更新,确保元数据保持同步。
4 .如权利要求1所述的基于 Etcd 的分布式中间件元数据管理方法,其特征在于,元数
据变更推送增量还包括:第一管理节点创建一个任务节点用于监视元数据变更任务,任务
节点被管理节点集群中的所有管理节点监视。
5 .如权利要求4所述的基于 Etcd 的分布式中间件元数据管理方法,其特征在于,其他
管理节点的在线执行器响应元数据变更任务推送,应用增量更新后,还包括:
当其他管理节点收到其在线执行器元数据变更任务的响应,在任务节点中写入元数据
变更任务响应信息;
权 利 要 求 书
1/2 页
2
文档被以下合辑收录
评论