Hazelcast IMap无分布式行为问题排查求助

我正在使用Hazelcast IMap缓存数据（key,uuid），代码结构如下：

在App类中：

static HazelcastInstance hzInstance; 
@Autowired private static Config config; 
public static HazelcastInstance hazelcastInstanceM { 
    if (sharedInstance == null) 
        sharedInstance = Hazelcast.newHazelcastInstance(config); 
    return sharedInstance; 
}

在另一个类B中，通过静态块获取HazelcastInstance并拿到名为CD的map：

static { 
    hazelcastInstance = App.hazelcastInstanceM(); 
    map= hazelcastInstance.getMap("CD"); 
}

我的集群中有两个节点。首次请求发往节点1时，key1,uuid1被存入map；第二次请求发往节点2时，本应仅在map中不存在key1时才添加，但实际执行kmap.putIfAbsent(key1, uuid1, 4, TimeUnit.MINUTES);后，key1,uuid2被重复添加，IMap未表现出分布式特性。请问导致该问题的原因是什么？

这个问题的核心是你的两个节点根本没有真正组成Hazelcast集群，各自维护着独立的本地IMap，所以才会出现重复插入的情况，具体原因拆解如下：

1. Spring静态字段注入的坑：Config对象根本没被正确注入 #

在Spring中，@Autowired是针对类实例的依赖注入，而静态字段属于类本身，Spring不会主动给静态字段注入依赖。你的@Autowired private static Config config;这行代码其实是无效的，config大概率是null。

当你调用Hazelcast.newHazelcastInstance(config)时，传入的是null，Hazelcast会使用默认配置启动实例。默认配置下，虽然Hazelcast会尝试用Multicast发现集群，但在很多生产环境或者容器环境中，Multicast是被禁用的，这就导致两个节点无法互相发现，各自启动了独立的单节点集群。

2. 静态块初始化时机的隐患 #

类B中的静态块会在类加载时执行，如果此时Hazelcast实例还没完成集群组建（甚至根本没在集群里），就会直接绑定到本地的独立实例上，后续所有操作都只在本地节点的IMap上进行，完全没有分布式特性。

快速验证方式 #

你可以在两个节点上分别打印Hazelcast实例的集群成员信息：

System.out.println("集群成员数量：" + hazelcastInstance.getCluster().getMembers().size());

如果两个节点打印的都是1，那就实锤了——它们根本不在同一个集群里。

第一步：修复Spring中Config的注入方式 #

把静态字段注入改成实例注入，再通过@PostConstruct初始化静态的HazelcastInstance：

@Component
public class App {
    private static HazelcastInstance sharedInstance;
    private final Config config;

    // 构造注入Config
    public App(Config config) {
        this.config = config;
    }

    @PostConstruct
    public void initHazelcast() {
        if (sharedInstance == null) {
            sharedInstance = Hazelcast.newHazelcastInstance(config);
        }
    }

    public static HazelcastInstance hazelcastInstanceM() {
        return sharedInstance;
    }
}

第二步：确保Hazelcast集群配置正确 #

检查你的Config配置，确保集群发现方式在你的环境中有效：

• 如果是容器环境（比如Docker/K8s），推荐用TCP/IP方式指定节点地址，或者用K8s的DNS发现；
• 如果是虚拟机环境，确认Multicast开启，或者配置TCP/IP集群成员列表。

示例TCP/IP配置：

Config config = new Config();
config.getNetworkConfig().getJoin().getMulticastConfig().setEnabled(false);
config.getNetworkConfig().getJoin().getTcpIpConfig()
      .setEnabled(true)
      .addMember("node1-ip:5701")
      .addMember("node2-ip:5701");

第三步：避免在静态块中过早初始化IMap #

尽量不在静态块中获取Hazelcast实例和IMap，而是通过Spring注入的方式获取，或者在需要使用时再初始化，确保集群已经组建完成。

内容的提问来源于stack exchange，提问作者user2480755