java – Apache Curator分布式锁

我知道Apache Curator可以执行分布式锁定功能,该功能构建在zookeeper的顶部.根据Apache Curator官方网站上发布的文档,它看起来很容易使用.例如：

RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);
CuratorFramework client = CuratorFrameworkFactory.newClient("host:ip",retryPolicy);
client.start();

InterProcessSemaphoreMutex lock = new InterProcessSemaphoreMutex(client, path);
if(lock.acquire(10, TimeUnit.SECONDS))
{
     try { /*do something*/ }
     finally { lock.release(); }
}

但是“InterProcessSemaphoreMutex”的第二个参数“path”是什么意思呢？它意味着基于API的“锁定路径”但究竟是什么呢？谁能举个例子？

如果我有数以百万计的锁,我是否必须创造数百万的“锁定之路”？ zookeeper集群的最大锁(znode)数量是否有限制？或者,当进程释放时,我们可以删除此锁吗？

解决方法:

ZooKeeper呈现了看起来像分布式文件系统的东西.对于任何ZooKeeper操作,配方等,您将“znodes”写入特定路径并监视更改.见这里：http://zookeeper.apache.org/doc/trunk/zookeeperOver.html#Simple+API(关于znodes).

对于策展人食谱,它需要知道您想要用来执行配方的基本路径.对于InterProcessSemaphoreMutex,路径是每个参与者应该使用的路径.即进程1和进程2都希望同时争用锁.因此,它们都使用相同的路径分配InterProcessSemaphoreMutex实例,例如“/ my / lock”.将路径视为锁定标识符.在同一个ZooKeeper集群中,您可以使用不同的路径进行多次锁定.

希望这会有所帮助(免责声明：我是策展人的主要作者).

标签：java,apache-zookeeper,apache-curator
来源： https://codeday.me/bug/20190717/1491245.html