之前我写了一个Rpc框架,为了配合我的Rpc框架,我模仿了nacos的部分设计**,实现了ayb-registry注册中心 目前服务端功能基本实现,客户端仅基本功能实现。后面可能还会继续实现负载均衡,配置中心等功能......
主要流程:
服务端-客户端:
- 客户端启动向服务端登记服务,服务端会将服务信息,放入消息队列中,统一进行异步处理;
- 服务会在消息队列中依次处理,更新服务列表,并且通知集群数据变更;
- 同时客户端开启心跳定时任务,服务端开启心跳检测定时任务;
- 客户端可以发送请求订阅某个服务,当该服务发生变更时,服务端会通过UDP主动推送服务信息到客户端中;
- 客户端可以从服务端获取指定服务列表;
集群节点间:
- 集群间采用AP模式的Distro协议;
- 每个节点都可以独立处理读请求;
- 需要特定的节点处理特定的写请求,同时同步到其他集群中;其中使用Filter将写请求路由到指定的节点中;
- 节点启动后,会向其他节点请求拉取数据快照,同时开启集群心跳任务;
主要功能:
- 服务注册:Client端在启动后会向Server端发送请求登记服务。如果为Server集群的情况会路由到指定的Server端处理请求。
- 服务心跳:Client端登记服务后,每个5秒会发送一个心跳到Server端以确保服务可用,如果超过15秒没有收到心跳,则该服务会被设置为不健康;超过30秒后,会剔除该服务。
- 服务订阅:Client端需要将要订阅的服务告知Server端,当Client端订阅的服务发生变更后,Server端会将变更服务主动推送到Client端
- 服务发现:Client端指定服务名发送请求到Server端,Server端会响应服务列表。
- 集群同步:某个Server端节点启动后,会向各个节点拉取数据快照,直到数据拉取成功。某个Server端节点管理的指定的数据发生更改后,会将更改的数据同步的别的节点中。
- 集群心跳:Server集群节点间每隔5秒会互相发送心跳,如果发送响应失败,则将该节点从健康列表中剔除。