Springboot Cassandra - 带有 SSL 的 CqlSessionFactoryBean

Question

关于如何连接到启用 SSL 的 Cassandra 集群的小问题。

目前，我通过执行以下操作连接到一个未启用 SSL 的 Cassandra 集群，它运行良好。

@Configuration
public class BaseCassandraConfiguration extends AbstractReactiveCassandraConfiguration {

    @Value("${spring.data.cassandra.username}")
    private String username;
    @Value("${spring.data.cassandra.password}")
    private String passPhrase;
    @Value("${spring.data.cassandra.keyspace-name}")
    private String keyspace;
    @Value("${spring.data.cassandra.local-datacenter}")
    private String datacenter;
    @Value("${spring.data.cassandra.contact-points}")
    private String contactPoints;
    @Value("${spring.data.cassandra.port}")
    private int    port;
    
    @Bean
    @NonNull
    @Override
    public CqlSessionFactoryBean cassandraSession() {
        final CqlSessionFactoryBean cqlSessionFactoryBean = new CqlSessionFactoryBean();
        cqlSessionFactoryBean.setContactPoints(contactPoints);
        cqlSessionFactoryBean.setKeyspaceName(keyspace);
        cqlSessionFactoryBean.setLocalDatacenter(datacenter);
        cqlSessionFactoryBean.setPort(port);
        cqlSessionFactoryBean.setUsername(username);
        cqlSessionFactoryBean.setPassword(passPhrase);
        return cqlSessionFactoryBean;
    }

我有另一个 Cassandra 集群，它启用了 SSL。

我期待看到像 cqlSessionFactoryBean.setSSLEnabled(true) 这样的东西。不幸的是，似乎没有。

请问设置此 bean 以使用 SSL 连接到 Cassandra 的正确方法是什么？

谢谢。

Answer 1

CqlSessionFactoryBean 没有 SSL 连接方法，因此您可能需要更改它并改用 CqlSession。

SSLContext sslContext = ...
CqlSession session = CqlSession.builder()
    .withSslContext(sslContext)
    .build();

或

SslEngineFactory yourFactory = ...
CqlSession session = CqlSession.builder()
    .withSslEngineFactory(yourFactory)
    .build();