Hazelcast IMDG 4.2.7中IAtomicLong脑裂保护与恢复配置方法

问题说明 #

Hazelcast IMDG 4.2.7版本已移除3.x版本中直接使用<atomic-long>根节点的配置方式，旧文档中的配置会触发InvalidConfigurationException异常，原因是XML结构不符合4.x版本的schema规范，且Config类的配置逻辑已调整。

正确配置方法 #

1. XML配置 #

针对特定IAtomicLong实例的配置

将<atomic-long>节点嵌套在<distributed-objects>下，指定合并策略和可选的脑裂保护引用：

<hazelcast>
    <!-- 可选：配置脑裂保护规则 -->
    <split-brain-protection name="atomicLongSBP" enabled="true" minimum-cluster-size="2"/>

    <distributed-objects>
        <atomic-long name="default">
            <!-- 脑裂恢复合并策略，可指定全类名或简称 -->
            <merge-policy>com.hazelcast.spi.merge.PutIfAbsentMergePolicy</merge-policy>
            <!-- 可选：关联已定义的脑裂保护规则 -->
            <split-brain-protection-ref>atomicLongSBP</split-brain-protection-ref>
        </atomic-long>
    </distributed-objects>
</hazelcast>

全局默认配置（所有IAtomicLong实例生效）

配置全局合并策略，无需为每个实例单独设置：

<hazelcast>
    <!-- 设置全局默认合并策略 -->
    <merge-policy default-merge-policy="PutIfAbsentMergePolicy"/>

    <!-- 可选：全局脑裂保护规则，需在分布式对象配置中引用生效 -->
    <split-brain-protection name="globalSBP" enabled="true" minimum-cluster-size="2"/>
</hazelcast>

2. 程序化配置 #

针对特定IAtomicLong实例的配置

通过AtomicLongConfig配置合并策略和脑裂保护：

import com.hazelcast.config.*;
import com.hazelcast.core.Hazelcast;
import com.hazelcast.core.HazelcastInstance;

public class AtomicLongSplitBrainSetup {
    public static void main(String[] args) {
        Config config = new Config();

        // 定义脑裂保护规则
        SplitBrainProtectionConfig sbpConfig = new SplitBrainProtectionConfig("atomicLongSBP")
                .setEnabled(true)
                .setMinimumClusterSize(2);
        config.addSplitBrainProtectionConfig(sbpConfig);

        // 配置目标IAtomicLong实例的合并策略与脑裂保护关联
        AtomicLongConfig atomicLongConfig = new AtomicLongConfig("default")
                .setMergePolicy("com.hazelcast.spi.merge.PutIfAbsentMergePolicy")
                .setSplitBrainProtectionName("atomicLongSBP");
        config.getDistributedObjectsConfig().addAtomicLongConfig(atomicLongConfig);

        HazelcastInstance instance = Hazelcast.newHazelcastInstance(config);
    }
}

全局默认配置

设置所有分布式对象的默认合并策略：

import com.hazelcast.config.Config;
import com.hazelcast.config.MergePolicyConfig;
import com.hazelcast.core.Hazelcast;
import com.hazelcast.core.HazelcastInstance;

public class GlobalMergePolicySetup {
    public static void main(String[] args) {
        Config config = new Config();
        // 配置全局默认合并策略
        config.setMergePolicyConfig(new MergePolicyConfig().setDefaultMergePolicy("PutIfAbsentMergePolicy"));

        HazelcastInstance instance = Hazelcast.newHazelcastInstance(config);
    }
}

常用合并策略说明 #

• PutIfAbsentMergePolicy：仅当目标集群不存在该原子长实例时执行合并
• HigherHitsMergePolicy：合并访问次数更高的实例
• LatestUpdateMergePolicy：合并最后更新的实例
• PassThroughMergePolicy：直接覆盖目标集群的现有数据

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