Hazelcast-客户端模式拓扑/分布式映射锁问题

Question

下面是我们在生产中遇到的问题的描述。请注意，我无法在测试或本地环境中再现该问题，因此无法向您提供测试代码。

我们有一个hazelcast集群，有两个成员M1、M2和三个客户端C1、C2、C3。Hazelcast版本为3.9。

客户端使用IMap。tryLock（）方法，超时10秒。获得锁后，将执行关键和长时间运行的操作，最后使用IMap释放锁。unlock（）方法。

生产中出现的问题如下：

在某个时间的瞬间t，我们首先在客户端C2看到M2的心跳失败。之后，com导致在获取分区表时出错。哈泽尔卡斯特。spi。例外TargetDisconnectedException：

[hz.client_0.internal-2                       ] WARN  [] HeartbeatManager               - hz.client_0 [mygroup] [3.9] HeartbeatManager failed to connection: .....

[hz.client_0.internal-3                       ] WARN  [] ClientPartitionService         - hz.client_0 [mygroup] [3.9] Error while fetching cluster partition table!
java.util.concurrent.ExecutionException: com.hazelcast.spi.exception.TargetDisconnectedException: Heartbeat timed out to owner connection ClientConnection{alive=true, connectionId=1, ......

在初始心跳失败后约250毫秒，客户端断开连接，然后在20毫秒内重新连接。

[hz.client_0.cluster-                         ] INFO  [] LifecycleService               - hz.client_0 [mygroup] [3.9] HazelcastClient 3.9 (20171023 - b29f549) is CLIENT_DISCONNETED

[hz.client_0.cluster-                         ] INFO  [] LifecycleService               - hz.client_0 [mygroup] [3.9] HazelcastClient 3.9 (20171023 - b29f549) is CLIENT_CONNECTED

我们面临的问题是，对于之前由C2获取的一些密钥，C1和C3无法获取锁，即使它似乎是由C2释放的。C2可以获得锁，但这会给应用程序带来不可接受的延迟，这是不可接受的。。自释放锁后，所有客户端都应获取。。。

我们在收到投诉后被告知该问题，然后重新启动客户端应用程序C2。

如http://docs.hazelcast.org/docs/latest-development/manual/html/Distributed_Data_Structures/Lock.html所述，重启成员（在我的例子中是C2）获得的锁似乎在重启操作后被移除。

目前，这个问题似乎已经消失，但我们不确定它是否会再次出现。

你对可能的原因有什么建议吗？更重要的是，你有什么建议吗？

在客户端中启用重做操作是否有助于解决此问题？

正如我试图解释的客户端似乎恢复了问题，但密钥仍然锁定在集群中，这对我的应用程序是致命的。

谢谢

Answer 1

看起来客户端因为与集群断开连接而失去了锁的所有权。您可以在遇到的情况下使用IMap#forceUnlockAPI。无论锁所有者是谁，它都会释放锁，并且总是成功解锁，从不阻塞，并立即返回。