个人技术分享

概述

众所周知，zookeeper是一个分布式协调框架，它可以实现的分布式协调功能非常多，如分布式锁、动态配置、分布式选举、服务注册与发现等功能。本节我们就先介绍一下zookeeper用于实现服务注册与发现的功能，本节将分别从其原理、实现几个方面简单讲述下zookeeper的服务注册与发现。

原理

zookeeper的服务注册与发现其主要的原理是服务提供者通过创建zookeeper的某个目录下临时ZNode，并附着上应用实例自身的IP、端口信息，然后服务消费者节点通过获取此目录下的ZNode并解析出来服务提供者的IP、端口等信息（pull模式），或者服务消费者可以监听目录下ZNode的事件更新服务提供者列表（push模式），本节我们将介绍pull模式。

实现

实现我们选择使用apache curator framework去操作zookeeper，因为curator给我们封装了很多的接口和管理会话，因此我们使用curator可以大大的减少我们开发的工作量。

引入maven依赖

            <dependency>
                <groupId>org.apache.curator</groupId>
                <artifactId>curator-framework</artifactId>
                <version>4.3.0</version>
            </dependency>
            <dependency>
                <groupId>org.apache.zookeeper</groupId>
                <artifactId>zookeeper</artifactId>
                <!--需要和你zookeeper的版本一致-->
                <version>3.4.14</version>
            </dependency>

初始化CuratorFramework Client

            CuratorFrameworkFactory.Builder builder = CuratorFrameworkFactory.builder()
                    .connectString("127.0.0.1:2181")
                    .retryPolicy(new RetryNTimes(1, 1000))
                    .connectionTimeoutMs(30 * 1000)
                    .sessionTimeoutMs(60 * 1000);
            client = builder.build();
            client.start();

创建临时节点

    public void createEphemeral(String path) {
        try {
            client.create().withMode(CreateMode.EPHEMERAL).forPath(path);
        } catch (NodeExistsException e) {
            logger.warn("ZNode " + path + " already exists.", e);
            throw new IllegalStateException(e.getMessage(), e);
        } catch (Exception e) {
            throw new IllegalStateException(e.getMessage(), e);
        }
    }

查询临时节点

    public List<String> getChildren(String path) {
        try {
            return client.getChildren().forPath(path);
        } catch (NoNodeException e) {
            return new ArrayList<>();
        } catch (Exception e) {
            throw new IllegalStateException(e.getMessage(), e);
        }
    }