java - 如何处理 Apache Curator 分布式锁连接丢失

Question

假设我有两个分布式进程运行以下代码，使用 zookeeper 和 curator 共享锁:

public static void main(String[] args) throws Exception {
    CuratorFramework client = CuratorFrameworkFactory.newClient("localhost:2181", new ExponentialBackoffRetry(500, 2));
    client.start();
    InterProcessMutex lock = new InterProcessMutex(client, "/12345");

    System.out.println("before acquire");
    lock.acquire();
    System.out.println("lock has been acquired");
    //do some things that need to be done in an atomic fashion
    lock.release();
    System.out.println("after release");
}

其中“做一些事情”注释表示一次只需要由一个进程完成的多个语句。例如多次写入各种数据库。

这一切看起来都很好，直到其中一个 java 进程在获得锁后失去与 zookeeper 的连接。

根据文档:

It is strongly recommended that you add a ConnectionStateListener and watch for SUSPENDED and LOST state changes. If a SUSPENDED state is reported you cannot be certain that you still hold the lock unless you subsequently receive a RECONNECTED state. If a LOST state is reported it is certain that you no longer hold the lock.

如果我理解正确，在获取锁后的任何时候我都可能收到锁已丢失的通知，由于网络问题，此时其他进程可能已获取锁。如果那是真的，就不能保证在获得锁后你是唯一拥有锁的进程。我一次只能由一个进程执行的宝贵语句可能会与另一个进程交错。

我对上面的理解有误吗？如果是这样，请说明它的含义。如果我没有误解上述内容，如果不能保证独占访问，策展人锁有什么用？

Answer 1

这是分布式系统的一般规则:网络和其他实例是不稳定的。如果您的实例与 ZooKeeper 整体失去联系，您将无法确定锁定节点的状态。这就是获得 SUSPENDED 连接状态更改的含义。在内部，ZooKeeper 已通知 Curator 与其 ZooKeeper 实例的连接已丢失。

这就是说，您可以安全地假设在您的 session 超时之前没有其他实例会获得锁定，因此您的操作在某种程度上取决于您。进一步注意，LOST 连接状态的含义在 Curator 3.x 中发生了变化。在 Curator 3.x 之前，LOST 状态仅表示您的重试策略已过期。在 3.x 中，Curator 现在会在连接暂停时设置一个内部计时器，并且连接状态丢失意味着 session 已过期。因此，对于许多应用程序，您可以安全地忽略 SUSPENDED 并仅在收到 LOST 时退出锁定。

所有这些都放在一边。即使在单个 JVM 中使用 JDK 锁，您也必须能够处理线程中断。让您的 Curator 应用程序锁处理 SUSPENDED/LOST 在语义上是一回事。

希望这有帮助(注意我是 Apache Curator 的主要作者)