java - HazelCast Tcp-IP 编程配置无需在集群中添加成员

标签 java 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);

您应该在构建实例之前完成配置。

关于java - HazelCast Tcp-IP 编程配置无需在集群中添加成员,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/41453332/

相关文章:

java - 无法创建 PoolableConnectionFactory(未知系统变量 'language')

spring - @cacheput 不更新现有缓存

java - 使用 jar 将 Hazelcast Mancenter 连接到外部 Hazelcast 服务器,而不是设置 hazelcast 服务器配置

java - HazelcastInstance bean - 正确的销毁方法是什么?

java - 在 Spring MVC 中自定义 JSP 标记 : "Cannot find symbol": pageContext

java - java中从服务器向多个客户端发送消息

sql - 日期对象上的 Hazelcast SqlPredicate

java - 如何将 HazelCast Map 依赖项注入(inject) QueueStore

java - 是否可以使用 Capybara 测试 Java 应用程序?

java - 几个类之间的通信