基于zookeeper实现rpc注册中心

1.什么是注册中心

注册中心中保存的是各服务的节点信息，主要包括ip和端口号，当服务端的节点增减时，服务的调用者能通过注册中心感知到服务端节点的变化。

使用注册中心的优点：如果服务节点部署机器过多，调用者需要配置太多的节点信息，不利于维护；当服务端增减节点时，客户端无需改动重启。

2.如何实现

krpc目前已经增加了zookeeper作为注册中心（如果不配置zk信息，则不使用）。

针对 服务节点意外宕掉的解决方案，zk的临时节点天然的符合这个场景。zk中当创建临时节点的链接断掉，该临时节点会自动删除。

对于客户端主动监听节点信息变化，zk也提供了对应的功能。

krpc中节点的设计如下图所示。

image

2.1 服务端注册

根节点是path固定的krpc，其子节点是所有服务名字，各个服务节点path是 ip:port，每个ip:port节点是临时节点，服务启动时会创建该path的临时节点，宕机后变自动删除。

krpc中 服务端注册实现

2.2 客户端动态监听

zc.subscribeChildChanges(path.toString(), new IZkChildListener() {
            @Override
            public void handleChildChange(String s, List<String> list) throws Exception {

                System.out.println("server change===" + list);
                if (list != null && list.size() > 0) {
                    List<Address> newAddr = new ArrayList<>(list.size());
                    for (String ipport : list) {
                        String[] content = ipport.split(":");
                        Address address = new Address();
                        address.setHost(content[0]);
                        address.setPort(Integer.valueOf(content[1]));

                        newAddr.add(address);
                    }

                    serviceParams.setAddresses(newAddr);
                    log.info("{} server change,content={}", serverName, list.toString());
                } else {
                    serviceParams.getAddresses().clear();
                    log.info("{} server change,no able server!", serverName);
                }

            }
});

客户端订阅/krpc/服务名 下子节点变更，变动后会将当前所有存在path在回掉中list参数传递过来，然后将新的节点信息更新即可。

krpc中 客户端订阅实现