09.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)

[/code]其它参数还好理解，不好理解的是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);

}

}

[/code]

3.示例程序运行结果

运行结果控制台：

连接状态:CONNECTED

临时节点路径：/example/ephemeralNode | 值: 临时节点

持久化节点路径： /example/node | 值: 持久化节点

连接状态:SUSPENDED

连接状态:LOST

连接状态:RECONNECTED

临时节点路径：/example/ephemeralNode | 是否存在: true

持久化节点路径： /example/node | 值: 持久化节点

[/code]-------------------------------------------------------------------------------------------------------------------------------

来自为知笔记(Wiz)