Spring+Infinispan+JGroups：代码化配置TCPPING初始主机问题

你好，针对你遇到的问题——保留JGroups XML配置的同时，从YML文件读取主机列表替换TCPPING的initial_hosts占位符，我来分析下之前尝试的问题，并给出可行的解决办法：

先分析之前两种尝试失效的原因 #

• 第一种尝试：使用CONFIGURATION_STRING属性是错误的，这个参数的作用是传递完整的JGroups配置字符串（替代XML文件），而不是用来覆盖XML里的单个占位符属性，所以无法生效。
• 第二种尝试：在cacheManager初始化完成后修改TCPPING的配置，此时JGroups通道已经启动，修改后的配置不会被通道重新加载，因此无法触发新的节点发现逻辑。

可行的解决方案 #

方案一：通过属性传递YML中的主机列表（最简单） #

JGroups在解析XML配置时会自动读取对应属性来替换${...}占位符，我们可以先从YML读取主机列表，然后将其传递给JGroups的配置属性，再初始化EmbeddedCacheManager：

// 假设你已经从YML读取到了主机列表，格式为 "host1:port1,host2:port2"
String ymlInitialHosts = "HOST1:PORT1,HOST2:PORT2";

// 初始化EmbeddedCacheManager，直接传递JGroups属性覆盖XML占位符
EmbeddedCacheManager cacheManager = new DefaultCacheManager(
    GlobalConfigurationBuilder.defaultClusteredBuilder()
        .transport()
        .nodeName(nodeName)
        .addProperty(JGroupsTransport.CONFIGURATION_FILE, "tcp.xml")
        // 传递属性值，XML中的${jgroups.tcpping.initial_hosts}会被替换
        .addProperty("jgroups.tcpping.initial_hosts", ymlInitialHosts)
        .build(),
    new ConfigurationBuilder()
        // 你的Cache自定义配置
        .build()
);

方案二：手动加载JGroups配置并修改TCPPING（更灵活） #

如果你需要更精细地控制JGroups通道的初始化过程，可以手动加载XML配置，修改TCPPING后再传递给Infinispan：

import org.jgroups.JChannel;
import org.jgroups.protocols.TCPPING;
import org.jgroups.stack.ProtocolStack;
import org.jgroups.util.IpAddress;

// 从YML读取主机列表，转换为IpAddress对象列表
List<IpAddress> initialHosts = Arrays.asList(
    new IpAddress("HOST1:PORT1"),
    new IpAddress("HOST2:PORT2")
);

// 手动加载JGroups XML配置文件
JChannel channel = new JChannel("tcp.xml");
ProtocolStack stack = channel.getProtocolStack();
TCPPING ping = stack.findProtocol(TCPPING.class);

if (ping != null) {
    ping.setInitialHosts(initialHosts);
    ping.setPortRange(1);
    // 重新初始化协议栈，确保修改的配置生效
    stack.init();
}

// 将自定义配置后的JChannel传递给Infinispan
EmbeddedCacheManager cacheManager = new DefaultCacheManager(
    GlobalConfigurationBuilder.defaultClusteredBuilder()
        .transport()
        .nodeName(nodeName)
        .channel(channel) // 使用我们修改后的JChannel
        .build(),
    new ConfigurationBuilder()
        // 你的Cache自定义配置
        .build()
);

这个方法的核心是在JChannel启动前修改TCPPING配置并重新初始化协议栈，确保新的主机列表被通道加载。

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