非阻塞获取Hazelcast复制地图？

Question

我们在Hazelcast客户端中使用ReplicatedMap。客户端和服务器都是版本4.2.1。

地图很小(

我们期望ReplicatedMap.get是非阻塞的，但是在长时间运行的性能测试中，我们开始从vertx（监控阻塞线程）收到如下警告。第一个错误是在6小时后出现的，因此不容易复制。

有没有办法进行非阻塞get？或者我们需要添加EntryListener来维护ConcurrentHashmap吗？

澄清：这里真正的问题不是阻止vertx（可以通过将调用移动到Vertx工作人员垂直来解决），而是避免延迟查找。业务要求是我们在50毫秒或更短的时间内处理消息，因此即使我们将调用移动到工作人员，我们也无法实现这一点。

[vertx-blocked-thread-checker] WARN  io.vertx.core.impl.BlockedThreadChecker - Thread Thread[vert.x-eventloop-thread-0,5,main] has been blocked for 12777 ms, time limit is 2000 ms
io.vertx.core.VertxException: Thread blocked
    at jdk.internal.misc.Unsafe.park(Native Method) ~[?:?]
    at java.util.concurrent.locks.LockSupport.park(LockSupport.java:323) ~[?:?]
    at com.hazelcast.spi.impl.AbstractInvocationFuture.manageParking(AbstractInvocationFuture.java:693) ~[hazelcast-4.2.1.jar!/:4.2.1]
    at com.hazelcast.spi.impl.AbstractInvocationFuture.get(AbstractInvocationFuture.java:615) ~[hazelcast-4.2.1.jar!/:4.2.1]
    at com.hazelcast.client.impl.spi.ClientProxy.invokeOnPartition(ClientProxy.java:188) ~[hazelcast-4.2.1.jar!/:4.2.1]
    at com.hazelcast.client.impl.spi.ClientProxy.invoke(ClientProxy.java:182) ~[hazelcast-4.2.1.jar!/:4.2.1]
    at com.hazelcast.client.impl.proxy.ClientReplicatedMapProxy.get(ClientReplicatedMapProxy.java:214) ~[hazelcast-4.2.1.jar!/:4.2.1]
    at my.package.StateGetter.getState(StateGetter.java:44) ~[classes!/:1.5.189]

Answer 1

vertx的黄金法则是不阻塞应用程序中的事件循环，并且阻塞容差非常低（2秒）。然而，由于我们经常需要执行阻塞操作，vertx提供了两种解决方案。我更喜欢使用的是工人竖梃(https://vertx.io/docs/vertx-core/java/#_verticles在Worker verticles部分下）。您可以使用以下代码启动它们：

DeploymentOptions options = new DeploymentOptions().setWorker(true);
vertx.deployVerticle("com.verticles.HazelcastVerticle", options);

这种类型的垂直线是为阻塞操作而设计的，在警告开始之前具有更高的容差（默认为60秒）。如果您希望操作比这更长，那么可能需要一个单独的线程或一种不同的方法，但从您的问题来看，我假设情况并非如此，所以我不会朝这个方向去。

另一种方法是使用vertx。执行锁定。您可以在此处找到有关的详细信息：https://dzone.com/articles/how-to-run-blocking-code-in-vertx.

Answer 2

复制映射（ReplicatedMap）条目将复制到集群的所有成员上。客户端仍然需要对成员执行远程调用以获取条目。根据您的需求，我认为实现可预测延迟的最佳方法是在客户端上设置近缓存。这样，条目将在客户端本地缓存，并且仅在必要时更新。