连接spring数据中的2个cassandra集群

# 集群1的连接配置
spring.data.cassandra.cluster1.contact-points=192.168.1.100,192.168.1.101
spring.data.cassandra.cluster1.port=9042
spring.data.cassandra.cluster1.keyspace=mykeyspace1

# 集群2的连接配置
spring.data.cassandra.cluster2.contact-points=192.168.2.200,192.168.2.201
spring.data.cassandra.cluster2.port=9042
spring.data.cassandra.cluster2.keyspace=mykeyspace2

@Configuration
@EnableCassandraRepositories(basePackages = "com.example.repository1", cassandraTemplateRef = "cassandraTemplate1")
public class CassandraConfig1 extends AbstractCassandraConfiguration {

    @Value("${spring.data.cassandra.cluster1.contact-points}")
    private String contactPoints1;
    
    @Value("${spring.data.cassandra.cluster1.port}")
    private int port1;
    
    @Value("${spring.data.cassandra.cluster1.keyspace}")
    private String keyspace1;
    
    @Bean
    public CassandraClusterFactoryBean cluster1() {
        CassandraClusterFactoryBean cluster = new CassandraClusterFactoryBean();
        cluster.setContactPoints(contactPoints1);
        cluster.setPort(port1);
        return cluster;
    }

    @Bean
    public CassandraMappingContext mappingContext1() {
        return new CassandraMappingContext();
    }

    @Bean
    public CassandraConverter converter1() {
        return new MappingCassandraConverter(mappingContext1());
    }

    @Bean
    public CassandraSessionFactoryBean session1() {
        CassandraSessionFactoryBean session = new CassandraSessionFactoryBean();
        session.setCluster(cluster1().getObject());
        session.setKeyspaceName(keyspace1);
        session.setConverter(converter1());
        return session;
    }

    @Bean
    public CassandraOperations cassandraTemplate1() {
        return new CassandraTemplate(session1().getObject());
    }
}

@Configuration
@EnableCassandraRepositories(basePackages = "com.example.repository2", cassandraTemplateRef = "cassandraTemplate2")
public class CassandraConfig2 extends AbstractCassandraConfiguration {

    @Value("${spring.data.cassandra.cluster2.contact-points}")
    private String contactPoints2;
    
    @Value("${spring.data.cassandra.cluster2.port}")
    private int port2;
    
    @Value("${spring.data.cassandra.cluster2.keyspace}")
    private String keyspace2;
    
    @Bean
    public CassandraClusterFactoryBean cluster2() {
        CassandraClusterFactoryBean cluster = new CassandraClusterFactoryBean();
        cluster.setContactPoints(contactPoints2);
        cluster.setPort(port2);
        return cluster;
    }

    @Bean
    public CassandraMappingContext mappingContext2() {
        return new CassandraMappingContext();
    }

    @Bean
    public CassandraConverter converter2() {
        return new MappingCassandraConverter(mappingContext2());
    }

    @Bean
    public CassandraSessionFactoryBean session2() {
        CassandraSessionFactoryBean session = new CassandraSessionFactoryBean();
        session.setCluster(cluster2().getObject());
        session.setKeyspaceName(keyspace2);
        session.setConverter(converter2());
        return session;
    }

    @Bean
    public CassandraOperations cassandraTemplate2() {
        return new CassandraTemplate(session2().getObject());
    }
}