自己动手实现分布式服务框架02-注册中心
服务提供方需要发布服务，由于应用系统的复杂性，服务的数量、类型会不断膨胀；对于服务消费方，它最关心如何获取到它所需要的服务。而且，对于服务提供方和服务消费方来说，他们还有可能兼具这两种角色，既需要提供服务，又需要消费服务。通过将服务统一管理起来，可以有效地优化内部应用对服务发布/使用的流程和管理。服务注册中心可以通过特定协议来完成服务对外的统一。我们看下dubbo官网的截图：
服务提供方发布服务到服务注册中心
服务消费方从服务注册中心订阅服务
服务消费方调用已经注册的可用服务
我们将会实现本地注册中心和基于Zookeeper的注册中心，因此定义一个IServiceDiscovery服务发现接口，该接口里面有注册服务、取消注册服务、更新服务、订阅服务、取消订阅服务、查询所有已注册服务名称、根据服务名称查询服务实例集合：
我们可以订阅感兴趣的服务，因此我们定义一个事件监听器接口：
然后定义一个抽象类AbstractServiceEventListener，当服务发生变化的时候，触发相应的事件：
然后我们定义一个抽象类AbstractServiceDiscovery：
在该抽象类中，我们将订阅的服务事件放到了一个Map中，接着看下notify方法，该方法会在注册服务、更新服务、卸载服务时触发相应的事件：
然后我们看下具体的注册中心实现，先来看本地注册中心：
我们这里定义了一个REGISTER_CENTER变量，用来保存注册的服务信息，然后看下registerLocal方法：
我们解析地址信息，解析出来主机和端口，然后构造一个ServiceInstance实例，接着调用registerService方法进行服务注册：
registerService方法就是简单的将服务保存到REGISTER_CENTER变量中，然后调用notify方法触发相应的事件，本地REGISTER_CENTER变量保存了服务注册信息，因此该类中的其他接口都是操作该变量获取相应的数据，这里就不多介绍了。
我们看下基于Zookeeper的注册中心：
我们定义了Zookeeper的默认地址为"localhost:2181"，然后定义了处理序列化的变量instanceSerializer,还有一个ServiceDiscovery的变量（curator库的类）
我们看下start方法，该方法将会连接到Zookeeper：
DevilsConstant.ZK_BASE_PATH是配置的服务注册zk基础路径：
MetaInfo是payload，记录了负载均衡类型、ha策略、权重、分组等信息：
然后看下注册服务、卸载服务、更新服务等方法的实现，只需要简单的委托调用serviceDiscovery变量的方法就可以：
最后看下childEvent方法，实现TreeCacheListener接口需要实现该方法，我们这里首先拿到节点数据信息serviceInstance，然后开始匹配当前的事件类型treeCacheEvent.getType,最后调用notify方法执行相应的事件操作：
本小节到此结束，下一节将会介绍相应的服务属性配置。
- 发表于:
- 原文链接：http://kuaibao.qq.com/s/20180227G15JFL00?refer=cp_1026
- 腾讯「腾讯云开发者社区」是腾讯内容开放平台帐号（企鹅号）传播渠道之一，根据《腾讯内容开放平台服务协议》转载发布内容。
- 如有侵权，请联系 cloudcommunity@tencent.com 删除。
相关快讯
扫码
添加站长 进交流群
领取专属 10元无门槛券
私享最新 技术干货
腾讯云开发者
