Kubernetes使用service-dns配置spring-session-hazelcast出现脑裂错误如何修复

该报错是Hazelcast Kubernetes发现插件通过service-dns解析服务地址时，返回的IP列表包含当前节点自身的Pod IP，节点向自身IP发起集群连接请求时触发了内部自连接校验逻辑，抛出的拦截错误。通常伴随集群成员发现异常问题，核心是节点无法正确识别自身地址，或解析的成员列表未过滤自身IP。

按以下步骤调整即可：

1. 确认发现用的是Headless Service
   用于Hazelcast发现的服务必须是Headless类型（Service的spec.clusterIP设置为None），普通ClusterIP服务的域名只会返回单个虚拟IP，无法返回所有后端Pod的真实IP列表，会导致成员发现逻辑异常，也容易触发自连接错误。

2. 显式配置service端口
   在Kubernetes发现配置中新增service-port属性，指定为Hazelcast的通信端口5701，避免端口解析异常。

3. 配置节点自身地址（可选但推荐）
   首先在Deployment的Pod配置中注入Pod IP环境变量：

   env:
   - name: POD_IP
     valueFrom:
       fieldRef:
         fieldPath: status.podIP
   

   然后在Hazelcast配置中指定节点自身的公开地址，让节点可以直接识别自身IP，不会发起自连接请求。

4. 开启自身地址排除（4.2+版本支持）
   启动参数中添加系统属性-Dhazelcast.discovery.exclude-own-address=true，发现插件会自动把当前节点的IP从候选成员列表中移除，从根源避免自连接请求。

调整后的配置代码片段 #

@Bean
public HazelcastInstance hazelcastInstance() {
    var config = new Config();
    config.setClusterName("spring-session-cluster");
    // 新增：设置节点自身公开地址
    config.getNetworkConfig().setPublicAddress(System.getenv("POD_IP") + ":5701");

    var join = config.getNetworkConfig().getJoin();
    join.getTcpIpConfig().setEnabled(false);
    join.getMulticastConfig().setEnabled(false);
    join.getKubernetesConfig().setEnabled(true)
                .setProperty("service-dns", "<multicast-service-name>")
                // 新增：显式指定服务端口
                .setProperty("service-port", "5701");

    var attribute = new AttributeConfig()
                .setName(Hazelcast4IndexedSessionRepository.PRINCIPAL_NAME_ATTRIBUTE)
                .setExtractorClassName(Hazelcast4PrincipalNameExtractor.class.getName());

    config.getMapConfig(Hazelcast4IndexedSessionRepository.DEFAULT_SESSION_MAP_NAME)
                .addAttributeConfig(attribute)
                .addIndexConfig(new IndexConfig(IndexType.HASH, Hazelcast4IndexedSessionRepository.PRINCIPAL_NAME_ATTRIBUTE));

    var serializer = new SerializerConfig();
    serializer.setImplementation(new HazelcastSessionSerializer())
        .setTypeClass(MapSession.class);
    config.getSerializationConfig().addSerializerConfig(serializer);

    return Hazelcast.newHazelcastInstance(config);
}

补充说明 #

如果调整后仍有偶发的该ERROR日志，只要集群可以正常形成（可通过启动日志搜索Members {size:2, ver:2}类的输出确认成员数），可以通过调整日志级别忽略该错误，不会影响集群正常运行。

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