Spring Data Cassandra多实例配置报错：无法创建多个CassandraOperations

问题根源 #

你遇到的Bean创建错误，大概率是因为Spring Boot的Cassandra自动配置类（CassandraAutoConfiguration）会默认创建一套Session、Template等核心Bean，和你自定义的两个CassandraConfig类产生了Bean冲突；另外如果两个自定义配置类没有明确区分Bean名称，也会导致同类型Bean重复注册的问题。

分步解决 #

1. 禁用默认Cassandra自动配置

在Spring Boot主启动类上排除自动配置类，避免默认Bean和自定义Bean冲突：

@SpringBootApplication(exclude = CassandraAutoConfiguration.class)
public class YourApplication {
    public static void main(String[] args) {
        SpringApplication.run(YourApplication.class, args);
    }
}

2. 编写两个独立的Cassandra配置类

每个配置类要明确指定Bean名称、KeySpace信息，以及绑定对应的Repository和Template：

第一个Cassandra配置（对应第一个实例）

@Configuration
@EnableCassandraRepositories(
        basePackages = "com.yourproject.repositories.cassandra1", // 可选：绑定专属Repository包
        cassandraTemplateRef = "cassandraTemplate1"
)
public class CassandraConfig1 extends AbstractCassandraConfiguration {

    @Value("${cassandra1.contact-points}")
    private String contactPoints;

    @Value("${cassandra1.port}")
    private int port;

    @Value("${cassandra1.keyspace-name}")
    private String keyspaceName;

    @Override
    protected String getKeyspaceName() {
        return keyspaceName;
    }

    @Override
    protected String getContactPoints() {
        return contactPoints;
    }

    @Override
    protected int getPort() {
        return port;
    }

    @Bean(name = "cassandraSession1")
    @Override
    public CassandraSessionFactoryBean session() {
        CassandraSessionFactoryBean session = super.session();
        // 可添加额外配置，比如连接超时、重试策略等
        return session;
    }

    @Bean(name = "cassandraTemplate1")
    public CassandraOperations cassandraTemplate(@Qualifier("cassandraSession1") CassandraSessionFactoryBean session) throws Exception {
        return new CassandraTemplate(session.getObject());
    }
}

第二个Cassandra配置（对应第二个实例）

@Configuration
@EnableCassandraRepositories(
        basePackages = "com.yourproject.repositories.cassandra2", // 可选：绑定专属Repository包
        cassandraTemplateRef = "cassandraTemplate2"
)
public class CassandraConfig2 extends AbstractCassandraConfiguration {

    @Value("${cassandra2.contact-points}")
    private String contactPoints;

    @Value("${cassandra2.port}")
    private int port;

    @Value("${cassandra2.keyspace-name}")
    private String keyspaceName;

    @Override
    protected String getKeyspaceName() {
        return keyspaceName;
    }

    @Override
    protected String getContactPoints() {
        return contactPoints;
    }

    @Override
    protected int getPort() {
        return port;
    }

    @Bean(name = "cassandraSession2")
    @Override
    public CassandraSessionFactoryBean session() {
        CassandraSessionFactoryBean session = super.session();
        // 可添加额外配置
        return session;
    }

    @Bean(name = "cassandraTemplate2")
    public CassandraOperations cassandraTemplate(@Qualifier("cassandraSession2") CassandraSessionFactoryBean session) throws Exception {
        return new CassandraTemplate(session.getObject());
    }
}

3. YAML配置文件补充

在application.yml中配置两个Cassandra实例的连接信息：

cassandra1:
  contact-points: 192.168.1.100 # 第一个Cassandra地址
  port: 9042
  keyspace-name: target_keyspace1 # 第一个数据路径对应的KeySpace

cassandra2:
  contact-points: 192.168.1.101 # 第二个Cassandra地址
  port: 9042
  keyspace-name: target_keyspace2 # 第二个数据路径对应的KeySpace

4. 实现双实例数据写入

在业务服务中，通过@Qualifier注入两个不同的CassandraOperations实例，分别执行写入操作：

@Service
public class DualCassandraWriterService {

    private final CassandraOperations template1;
    private final CassandraOperations template2;

    // 构造函数注入，通过@Qualifier指定要注入的Bean
    public DualCassandraWriterService(
            @Qualifier("cassandraTemplate1") CassandraOperations template1,
            @Qualifier("cassandraTemplate2") CassandraOperations template2) {
        this.template1 = template1;
        this.template2 = template2;
    }

    public void writeToBothCassandra(YourDataEntity entity) {
        // 写入第一个Cassandra实例
        template1.save(entity);
        // 写入第二个Cassandra实例
        template2.save(entity);
    }
}

注意事项 #

• 如果不需要为两个实例分别维护Repository，可以去掉@EnableCassandraRepositories中的basePackages配置，直接在需要时注入对应的Template即可。
• 若需要保证写入的原子性（两个实例要么都写入成功，要么都失败），可以考虑引入分布式事务框架，或者在业务层实现重试、补偿逻辑。

内容的提问来源于stack exchange，提问作者杨泽宇