从Hazelcast 3.12.13迁移至5.1.6遇CP Subsystem未启用问题求助

1. 启用CP子系统 #

Hazelcast 5.x版本中CP子系统默认关闭，而3.x版本中无需显式配置即可使用相关组件。要解决这个错误，首先要在Hazelcast配置中开启CP子系统：

XML配置示例 #

<hazelcast>
    <cp-subsystem enabled="true">
        <!-- CP成员数量需设置为奇数，最小3个，生产环境推荐5个 -->
        <cp-member-count>3</cp-member-count>
        <!-- 开发环境可关闭持久化，生产环境建议开启 -->
        <persistence enabled="false"/>
    </cp-subsystem>
</hazelcast>

代码配置示例 #

Config config = new Config();
CPSubsystemConfig cpConfig = config.getCPSubsystemConfig();
// 开启CP子系统
cpConfig.setEnabled(true);
// 设置CP集群成员数
cpConfig.setCPMemberCount(3);
// 开发环境关闭持久化
cpConfig.getPersistenceConfig().setEnabled(false);

HazelcastInstance hazelcastInstance = Hazelcast.newHazelcastInstance(config);

2. 修正Semaphore初始化代码 #

原代码存在两处问题：未使用类内定义的hazelcastInstance变量、5.x版本中init(permits)方法已被推荐替换。修正后的代码如下：

import com.hazelcast.core.HazelcastInstance;
import com.hazelcast.cp.ISemaphore;

public class HazelcastSemaphore implements MetaSemaphore {

    private HazelcastInstance hazelcastInstance;
    private ISemaphore semaphore;
    private String id; // 需确保该变量已被正确赋值

    public boolean init(int permits) {
        if (semaphore == null) {
            // 直接创建带初始许可数的Semaphore
            semaphore = hazelcastInstance.getCPSubsystem().getSemaphore(id, permits);
            
            // 若需兼容旧版写法，也可保留init调用（不推荐）：
            // semaphore = hazelcastInstance.getCPSubsystem().getSemaphore(id);
            // semaphore.init(permits);
        }
        return true;
    }
}

3. 额外注意事项 #

• 单节点开发环境可将cp-member-count设为1，但生产环境必须使用至少3个节点的奇数配置，保证CP子系统的一致性
• 若通过Spring集成Hazelcast，需确保Spring容器中初始化的Hazelcast实例已开启CP子系统
• 5.x版本中CP子系统API有部分调整，需避免使用已废弃的方法

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