Curator工具类之EnsurePath。

骑猪看日落 2024-02-18 17:09 3阅读 0赞

EnsurePath提供了一种能够确保数据节点存在的机制，多用于这样的业务场景中：

> **上层业务希望对一个数据节点进行一些操作，但是操作之前需要确保该节点存在。**

基于ZooKeeper提供的原始API接口，为解决上述场景的问题，开发人员需要首先对该节点进行一个判断，如果该节点不存在，那么就需要创建节点。而与此同时，在分布式环境中，在A机器试图进行节点创建的过程中，由于并发操作的存在，另一台机器，如B机器，也在同时创建这个节点，于是A机器创建的时候，可能会抛出诸如“节点已经存在”的异常。因此开发人员还必须对这些异常进行单独的处理，逻辑通常非常琐碎。

EnsurePath正好可以用来解决这些烦人的问题，他采取了静默的节点创建方式，其**内部实现就是试图创建指定节点，如果节点已经存在，那么就不进行任何操作，也不对外抛出异常，否则正常创建数据节点**，关于EnsurePath的具体用法，可以参考下面的示例程序。

## 工具类EnsurePath使用示例 ##

public class EnsurePathDemo \{

> static String path = "/zk-book/c1";
> 
> static CuratorFramework client = CuratorFrameworkFactory.builder().connectString("domain1.book.zookeeper:2181").sessionTimeoutMs(5000).retryPolicy(new ExponentialBackoffRetry(1000, 3)).build();
> 
> public static void main(String\[\] args) throws Exception \{
> 
> > client.start();
> > 
> > client.usingNamespace("zk-book");
> > 
> > EnsurePath ensurePath = new EnsurePath();
> > 
> > ensurePath.ensure(client.getZookeeperClient());
> > 
> > ensurePath.ensure(client.getZookeeperClient());
> > 
> >   
> > 
> > 
> > EnsurePath ensurePath = client.newNamespaceAwareEnsurePath("/c1");  
> > 
> > 
> > ensurePath2.ensure(client.getZookeeperClient());
> 
> \}  
>