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

回到顶部