CP 子系统未启用

Question

我正在使用 hazelcast：

• spring-integration-hazelcast:1.0.0.RELEASE
• hazelcast-all:3.12.4
• 有关 gradle 的详细信息，请参阅 [1]

一切正常:)

由于我遇到了一些问题，我尝试更新到最新版本，所以：

• hazelcast 3.12.6
• 和spring-integration-hazelcast 2.0.0.RELEASE

但我的应用程序甚至没有启动，我得到：

cluster-manager_1  | com.hazelcast.core.HazelcastException: CP Subsystem is not enabled!
cluster-manager_1  |    at com.hazelcast.cp.internal.RaftInvocationManager.completeExceptionallyIfCPSubsystemNotAvailable(RaftInvocationManager.java:113)
cluster-manager_1  |    at com.hazelcast.cp.internal.RaftInvocationManager.invoke(RaftInvocationManager.java:186)
cluster-manager_1  |    at com.hazelcast.cp.internal.RaftService.getGroupInfoForProxy(RaftService.java:752)
cluster-manager_1  |    at com.hazelcast.cp.internal.RaftService.createRaftGroupForProxy(RaftService.java:704)
cluster-manager_1  |    at com.hazelcast.cp.internal.datastructures.lock.RaftLockService.doCreateProxy(RaftLockService.java:193)
cluster-manager_1  |    at com.hazelcast.cp.internal.datastructures.lock.RaftLockService.createProxy(RaftLockService.java:177)
cluster-manager_1  |    at com.hazelcast.cp.internal.datastructures.lock.RaftLockService.createProxy(RaftLockService.java:43)
cluster-manager_1  |    at com.hazelcast.cp.internal.CPSubsystemImpl.getLock(CPSubsystemImpl.java:76)
cluster-manager_1  |    at org.springframework.integration.hazelcast.HazelcastLocalInstanceRegistrar.syncConfigurationMultiMap(HazelcastLocalInstanceRegistrar.java:99)
cluster-manager_1  |    at org.springframework.integration.hazelcast.HazelcastLocalInstanceRegistrar.afterSingletonsInstantiated(HazelcastLocalInstanceRegistrar.java:86)
cluster-manager_1  |    at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:896)
cluster-manager_1  |    at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:878)
cluster-manager_1  |    at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:550)
cluster-manager_1  |    at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:141)
cluster-manager_1  |    at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:747)
cluster-manager_1  |    at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:397)
cluster-manager_1  |    at org.springframework.boot.SpringApplication.run(SpringApplication.java:315)
cluster-manager_1  |    at com.btnty.citm.clustermanager.springboot.ClusterManagerApplication.main(ClusterManagerApplication.java:49)
cluster-manager_1  |    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
cluster-manager_1  |    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
cluster-manager_1  |    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
cluster-manager_1  |    at java.lang.reflect.Method.invoke(Method.java:498)
cluster-manager_1  |    at org.springframework.boot.loader.MainMethodRunner.run(MainMethodRunner.java:48)
cluster-manager_1  |    at org.springframework.boot.loader.Launcher.launch(Launcher.java:87)
cluster-manager_1  |    at org.springframework.boot.loader.Launcher.launch(Launcher.java:51)
cluster-manager_1  |    at org.springframework.boot.loader.JarLauncher.main(JarLauncher.java:52)

但为什么？:-( “问题”不是hazelcast 3.12.6因为它可以与 Fine 一起使用 spring-integration-hazelcast 1.0.0.RELEASE。而是从 更改为spring-integration-hazelcast 1.0.0.RELEASE会2.0.0.RELEASE触发此错误。

[1]

  implementation ("org.springframework.boot:spring-boot-starter-web:2.2.5.RELEASE") 
  implementation ("org.springframework.integration:spring-integration-hazelcast:1.0.0.RELEASE")
  implementation "com.hazelcast:hazelcast-all:3.12.4"
  compile group: 'org.springframework.integration', name: 'spring-integration-core', version: '5.2.1.RELEASE'

Answer 1

问题是该spring-integration模块使用Hazelcast CP 子系统（在CPSubsystemImpl.getLock()），该子系统在 Hazelcast 中默认被禁用。

您可以使用以下 Hazelcast 配置启用它：

@Bean
HazelcastInstance hazelcastInstance() {
    Config config = new Config();
    config.getCPSubsystemConfig().setCPMemberCount(3);
    return Hazelcast.newHazelcastInstance(config);
}

请注意，您的集群中应该有（至少）3 个 Hazelcast 成员。