java - Apache Curator 分布式锁

Question

我知道 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)数是否有限制？或者我们可以在进程释放锁时移除它吗？

Answer 1

ZooKeeper 提供了一个看起来像分布式文件系统的东西。对于任何 ZooKeeper 操作、配方等，您将“znodes”写入特定路径并观察变化。看这里:http://zookeeper.apache.org/doc/trunk/zookeeperOver.html#Simple+API (关于 znode)。

对于 Curator 配方，它需要知道您要用于执行配方的基本路径。对于 InterProcessSemaphoreMutex，路径是每个参与者都应该使用的。即进程 1 和进程 2 都想争夺锁。因此，它们都使用相同的路径分配 InterProcessSemaphoreMutex 实例，比如“/my/lock”。将路径视为锁标识符。在同一个 ZooKeeper 集群中，您可以通过使用不同的路径来拥有多个锁。

希望这对您有所帮助(免责声明:我是 Curator 的主要作者)。