10.Curator临时节点

使用Curator也可以简化Ephemeral Node (临时节点)的操作。临时节点驻存在ZooKeeper中，当连接和session断掉时被删除。比如通过ZooKeeper发布服务，服务启动时将自己的信息注册为临时节点，当服务断掉时ZooKeeper将此临时节点删除，这样client就不会得到服务的信息了。

1.PersistentEphemeralNode类

PersistentEphemeralNode类代表临时节点。其构造函数如下:

/**
 * @param client   client instance
 * @param mode     creation/protection mode
 * @param basePath the base path for the node
 * @param data     data for the node
 */
public PersistentEphemeralNode(CuratorFramework client, Mode mode, String basePath, byte[] initData) 

其它参数还好理解，不好理解的是PersistentEphemeralNode.Mode：

• EPHEMERAL： 以ZooKeeper的 CreateMode.EPHEMERAL方式创建节点。
• EPHEMERAL_SEQUENTIAL: 如果path已经存在，以CreateMode.EPHEMERAL创建节点，否则以CreateMode.EPHEMERAL_SEQUENTIAL方式创建节点。
• PROTECTED_EPHEMERAL: 以CreateMode.EPHEMERAL创建，提供保护方式。
• PROTECTED_EPHEMERAL_SEQUENTIAL: 类似EPHEMERAL_SEQUENTIAL，提供保护方式。

保护方式是指一种很边缘的情况：当服务器将节点创建好，但是节点名还没有返回给client,这时候服务器可能崩溃了，然后此时ZK session仍然合法，所以此临时节点不会被删除。对于client来说，它无法知道哪个节点是它们创建的。

即使不是sequential-ephemeral,也可能服务器创建成功但是客户端由于某些原因不知道创建的节点。

Curator对这些可能无人看管的节点提供了保护机制。 这些节点创建时会加上一个GUID。 如果节点创建失败正常的重试机制会发生。 重试时， 首先搜索父path, 根据GUID搜索节点，如果找到这样的节点， 则认为这些节点是第一次尝试创建时创建成功但丢失的节点，然后返回给调用者。

注意：节点必须调用start方法启动。 不用时调用close方法。PersistentEphemeralNode 内部自己处理错误状态。

2.编写示例程序

我们的例子创建了两个节点，一个是临时节点，一个事持久化的节点。可以看到，client重连后临时节点不存在了。

public class PersistentEphemeralNodeExample
{
    private static final String PATH = "/example/ephemeralNode";
    private static final String PATH2 = "/example/node";
    public static void main(String[] args) throws Exception
    {
        CuratorFramework client = CuratorFrameworkFactory.newClient("127.0.0.1:2181", new ExponentialBackoffRetry(1000, 3));
        client.getConnectionStateListenable().addListener(new ConnectionStateListener()
        {
            @Override
            public void stateChanged(CuratorFramework client, ConnectionState newState)
            {
                System.out.println("连接状态:" + newState.name());
            }
        });
        client.start();
        PersistentEphemeralNode node = new PersistentEphemeralNode(client, Mode.EPHEMERAL, PATH, "临时节点".getBytes());
        node.start();
        node.waitForInitialCreate(3, TimeUnit.SECONDS);
        String actualPath = node.getActualPath();
        System.out.println("临时节点路径：" + actualPath + " | 值: " + new String(client.getData().forPath(actualPath)));
        client.create().forPath(PATH2, "持久化节点".getBytes());
        System.out.println("持久化节点路径： " + PATH2 + " | 值: " + new String(client.getData().forPath(PATH2)));
        
        KillSession.kill(client.getZookeeperClient().getZooKeeper(), "127.0.0.1:2181");
        System.out.println("临时节点路径：" + actualPath + " | 是否存在: " + (client.checkExists().forPath(actualPath) != null));
        System.out.println("持久化节点路径： " + PATH2 + " | 值: " + new String(client.getData().forPath(PATH2)));
        
        CloseableUtils.closeQuietly(node);
        CloseableUtils.closeQuietly(client);
    }
}

3.示例程序运行结果

运行结果控制台：

连接状态:CONNECTED
临时节点路径：/example/ephemeralNode | 值: 临时节点
持久化节点路径： /example/node | 值: 持久化节点
连接状态:SUSPENDED
连接状态:LOST
连接状态:RECONNECTED
临时节点路径：/example/ephemeralNode | 是否存在: true
持久化节点路径： /example/node | 值: 持久化节点

-------------------------------------------------------------------------------------------------------------------------------

来自为知笔记(Wiz)