Tcp-IP的HazelCast程序化配置未在群集中添加成员
以下是文档中给出的HazelCast程序配置,但无法在HazelCast群集中添加成员。
Config cfg = new Config(); Hazelcast.newHazelcastInstance(cfg);
cfg.setProperty("hazelcast.initial.min.cluster.size","3");
cfg.getGroupConfig().setName("DEV").setPassword("DEV-pass");
NetworkConfig network = cfg.getNetworkConfig();
JoinConfig join = network.getJoin();
TcpIpConfig tcpipConfig=join.getTcpIpConfig();
tcpipConfig.addMember("172.17.153.87").addMember("10.45.67.100")
.setRequiredMember("192.168.10.100").setEnabled(true);
network.getInterfaces().setEnabled(true).addInterface("10.45.67.*");
System.out.println(tcpipConfig.isEnabled());
System.out.println(tcpipConfig.getMembers());
MapConfig mapCfg = new MapConfig();
mapCfg.setName("testMap");
mapCfg.setBackupCount(2);
mapCfg.getMaxSizeConfig().setSize(10000);
mapCfg.setTimeToLiveSeconds(300);
MapStoreConfig mapStoreCfg = new MapStoreConfig();
mapStoreCfg.setClassName("com.hazelcast.examples.DummyStore").setEnabled(true);
mapCfg.setMapStoreConfig(mapStoreCfg);
NearCacheConfig nearCacheConfig = new NearCacheConfig();
nearCacheConfig.setMaxSize(1000).setMaxIdleSeconds(120).setTimeToLiveSeconds(300);
mapCfg.setNearCacheConfig(nearCacheConfig);
cfg.addMapConfig(mapCfg);
请查看代码,如果需要进一步修改以将成员添加到hazelcast集群,请让我看看
回答:
添加此行以关闭多播以支持TCP,
join.getMulticastConfig().setEnabled(false);
将此行移到最后,
Hazelcast.newHazelcastInstance(cfg);
您应该在构建实例之前完成配置。
以上是 Tcp-IP的HazelCast程序化配置未在群集中添加成员 的全部内容, 来源链接: utcz.com/qa/421271.html