Rustful Spring MVCを使用した複数のCassandraクラスタ用Beans

Question

Beansを使用して複数のCassandra Clustersに接続するにはどうすればいいでしょうか。これらの接続を生き生きとしていますか？

私はこのCassandraOperationsコードを持っている：

@Configuration 
@PropertySource(value = { "classpath:META-INF/cassandra.properties" }) 
@EnableCassandraRepositories(basePackages = { "com.rg" }) 
public class CassandraConfig { 

    @Autowired 
    private Environment environment; 

    private static final Logger LOGGER = LoggerFactory.getLogger(CassandraConfig.class); 

    @Bean 
    public CassandraClusterFactoryBean cluster() { 

     CassandraClusterFactoryBean cluster = new CassandraClusterFactoryBean(); 
     cluster.setContactPoints(environment.getProperty("cassandra.contactpoints")); 
     cluster.setPort(Integer.parseInt(environment.getProperty("cassandra.port"))); 
     return cluster; 
    } 

    @Bean 
    public CassandraMappingContext mappingContext() { 
     return new BasicCassandraMappingContext(); 
    } 

    @Bean 
    public CassandraConverter converter() { 
     return new MappingCassandraConverter(mappingContext()); 
    } 

    @Bean 
    public CassandraSessionFactoryBean session() throws Exception { 

     CassandraSessionFactoryBean session = new CassandraSessionFactoryBean(); 
     session.setCluster(cluster().getObject()); 
     session.setKeyspaceName(environment.getProperty("cassandra.keyspace")); 
     session.setConverter(converter()); 
     session.setSchemaAction(SchemaAction.NONE); 
     return session; 
    } 

    @Bean 
    public CassandraOperations cassandraTemplate() throws Exception { 
     return new CassandraTemplate(session().getObject()); 
    } 

} 

Answer 1

は現在、あなたの唯一のオプションは、複数のSession Sを使用する複数のCassandraTemplateのインスタンスを構成しています。カッサンドラSession（およびCluster）およびCassandraTemplateは、強い1：1の関係を有する。

これはSpring Data Cassandra 2.0に変わります。具体的には、実装に関してプラッガブルなSessionFactoryインターフェイスを追加して、独自のルーティングを定義できます。さらに、AbstractRoutingDataSourceに似ているAbstractRoutingSessionFactoryを追加します。詳細についてはhttps://jira.spring.io/browse/DATACASS-330を参照し、そこにあなたの考えを残してください。