Hazelcast异常将布尔值放入映射

Question

几个月前我们开始使用Hazelcast。我们最近开始在生产环境中测试它，现在大约每周看到一次这个异常：

2020-02-11 12:10:00,084upport.invokeNoDataMemberInClusterException：无法找到调用的目标！分区所有者为空，但无法分配分区，因为集群中的所有节点都是精简成员。upport.java:467upport.java:406com.hazelcast.map.impl.proxy.InvocationTarget（Impl.put）mpl.java:121com.hazelcast.map.impl.proxy.Invoke（Impl.put）mpl.java:111nvocation.invoke0（Invocation.java:534）com.hazelcast.spi.impl.operationservice.impl.nvocation.invoke（Invocation.java:236）com.hazelcast.map.impl.proxy.MapProxyScom.hazelcast.partition.操作（MapProxyScom.hazelcast.spi.impl.operationservice.impl.）nvocation.newMapProxySnvocation.java:90内部（MapProxyScom.hazelcast.spi.impl.operationservice.impl.）nvocation.initMapProxyInvocation.java:269（MapProxyIcom.hazelcast.spi.impl.operationservice.impl.）nvocation.doMapProxyInvocation.java:556（MapProxyIcom.hazelcast.spi.impl.operationservice.impl.）

这是20年2月4日发布的Hazelcast 4.0 GA。这也发生在我们跑3.12的时候。x版本。我们希望每次升级到新版本时，例外情况都会消失。

我们的设置非常简单。Hazelcast运行在一台具有大量可用内存和Java 8的服务器上。我们所做的就是将真/假值放入只有一个值为零的整数键的映射中。真的，这就像是最小的地图！服务器可以正常运行很多天，但最终会从映射中抛出此异常。put（0，布尔）。

我们代码的其他部分大量使用Hazelcast的执行器。到目前为止，我们还没有遇到任何问题。

我们这样配置Hazelcast：

config.setInstanceName(name);        

config.getNetworkConfig().getJoin().getMulticastConfig().setEnabled(false);
config.getNetworkConfig().getJoin().getAwsConfig().setEnabled(false);
config.getNetworkConfig().getJoin().getTcpIpConfig().setEnabled(true);
config.getNetworkConfig().setPortAutoIncrement(true);
config.getNetworkConfig().setPort(5701);
config.getNetworkConfig().getJoin().getTcpIpConfig().addMember(AppConfig.getConfigSetting("/config/server/ip_address"));

hazelcastInstance = Hazelcast.newHazelcastInstance(config);

我找不到除此之外的任何有关此异常的信息：https://docs.hazelcast.org/docs/latest/javadoc/com/hazelcast/partition/NoDataMemberInClusterException.html

希望有人能帮助解决这个问题。我们期望Hazelcast的地图在一台服务器上是防弹的。

Answer 1

看见https://github.com/hazelcast/hazelcast/issues/16651

该问题显然是由于在Amazon EC2实例上运行Hazelcast造成的。我们使用的配置设置需要调整以定义出站端口范围。我们最终的工作配置设置如下：

com.hazelcast.config.Config config = new com.hazelcast.config.Config();

config.setProperty("hazelcast.logging.type", "log4j");

String name = AppCluster.isWorkerServer ? "worker "+AppHTTP.getSystemDomainAndContext() : "master"; 

config.setInstanceName(name);        

config.getNetworkConfig().getJoin().getMulticastConfig().setEnabled(false);
config.getNetworkConfig().getJoin().getAwsConfig().setEnabled(false);
config.getNetworkConfig().getJoin().getTcpIpConfig().setEnabled(true);
config.getNetworkConfig().setPort(5701);
config.getNetworkConfig().setPortAutoIncrement(false);
config.setProperty("hazelcast.socket.bind.any", "false");

// The next line is a suggested workaround for running on Amazon AWS to avoid periodic hazelcast crashes
// https://github.com/hazelcast/hazelcast/issues/16651
config.getNetworkConfig().addOutboundPortDefinition("30000-60000");

// Default value to use when a single server
String hazelcastIP = "127.0.0.1";
if (AppCluster.isWorkerServer || AppCluster.totalServers > 1)
{
    if (AppConfig.getConfigSetting("/config/server/ec2_private_ip").length() > 0)
    {
        // If clustered and in Amazon AWS, use the server's private IP address
        hazelcastIP = AppConfig.getConfigSetting("/config/server/ec2_private_ip");
    }
    else
    {
        // If clustered and not in Amazon AWS, use the server's public IP address
        hazelcastIP = AppConfig.getConfigSetting("/config/server/ip_address");
    }
}

config.getNetworkConfig().setPublicAddress(hazelcastIP);
config.setProperty("hazelcast.local.localAddress", hazelcastIP);

hazelcastInstance = Hazelcast.newHazelcastInstance(config);