1 .一种跨域大数据平台的分布式集群状态信息管理方法,其特征在于,包括:
将所述跨域大数据平台包括的总部大数据平台和省份大数据平台的各个大数据平台
的对外开放节点列表信息备份于所述各个大数据平台的集群内的Zookeeper服务组件,并
缓存且仅缓存一份于本集群的leader节点,所述集群内的各节点注册为所述Zookeeper组
件的客户端;
进行所述省份大数据平台在所述总部大数据平台的注册,其中所述省份大数据平台的
leader节点定期向所述总部大数据平台的集群的所述对外开放节点列表发送注册请求,在
所述总部大数据平台收到所述注册请求后,如果确认为允许注册的所述省份大数据平台,
并且确认所述省份大数据平台的所述对外开放列表是可用的,则进行数据同步和元数据信
息的同步,最终完成所述集群的信息在所述总部大数据平台内的自动备份和缓存,以完成
所述省份大数据平台的上线操作,并将最新的跨域信息缓存通过RPC向各个在线集群的对
外开放节点进行同步通知,其中,所述总部大数据平台对所述省份大数据平台的所述对外
开放节点列表保持RPC心跳机制。
2.根据权利要求1所述的跨域大数据平台的分布式集群状态信息管理方法,其特征在
于,所述进行所述省份大数据平台在所述总部大数据平台的注册,包括:
所述省份大数据平台启动后选举出集群的leader节点,并通过所述RPC向所述总部大
数据平台的对外开放节点列表MASTER_ACCESS_LIST发起注册请求;
所述总部大数据平台启动后选举出集群的leader节点,并在接收到所述注册请求后验
证所述省份大数据平台的对外开放节点列表SLAVE_ACCESS_LIST的合法性;
回复数据和元数据的同步消息,并向所述省份大数据平台同步所述数据和所述元数
据;以及
所述总部大数据平台将所述省份大数据平台的所述SLAVE_ACCESS_LIST信息备份到所
述Zookeeper服务组件,并将所述SLAVE_ACCESS_LIST信息缓存且仅缓存一份到本集群的
leader节点。
3 .根据权利要求2所述的跨域大数据平台的分布式集群状态信息管理方法,其特征在
于,所述将最新的跨域信息缓存通过RPC向各个在线集群的对外开放节点进行同步通知,包
括:
在所述总部大数据平台的Leader节点接收到刚刚注册的缓存信息后,向先前已经注册
成功的所述省份大数据平台发起远程过程调用RPC通知,通知有新平台注册进来,并通过所
述省份大数据平台的所述SLAVE_ACCESS_LIST向各个省份同步更新所述跨域数据平台的最
新缓存信息;以及
在所述省份大数据平台的SLAVE_ACCESS_LIST收到所述总部大数据平台发送的所述跨
域数据平台的所述最新缓存信息后,将所述最新缓存信息备份到所述Zookeeper服务组件,
并缓存且仅缓存一份到本集群的leader节点。
4 .根据权利要求1所述的跨域大数据平台的分布式集群状态信息管理方法,其特征在
于,所述方法还包括:
注册成功的所述省份大数据平台的Leader节点负责与所述总部大数据平台的MASTER_
ACCESS_LIST保持RPC心跳通信,并且进行可视化显示以监测跨域功能正常运行;以及
注册成功的所述总部大数据平台的leader节点负责与所述省份大数据平台的SLAVE_
权 利 要 求 书
1/2 页
2
评论