纯Spring应用（非Spring Boot）连接Astra DB配置咨询

1. 更新依赖 #

替换原有Spring Data Cassandra依赖为响应式版本，并添加适配Astra DB的DataStax Java驱动相关包。

Maven 依赖 #

<dependencies>
    <!-- Spring Data Cassandra 响应式核心 -->
    <dependency>
        <groupId>org.springframework.data</groupId>
        <artifactId>spring-data-cassandra-reactive</artifactId>
        <version>3.4.10</version> <!-- 选择与你的Spring版本兼容的版本 -->
    </dependency>
    <!-- DataStax Java Driver 核心 -->
    <dependency>
        <groupId>com.datastax.oss</groupId>
        <artifactId>java-driver-core</artifactId>
        <version>4.15.0</version>
    </dependency>
    <!-- DataStax Java Driver 认证扩展 -->
    <dependency>
        <groupId>com.datastax.oss</groupId>
        <artifactId>java-driver-auth</artifactId>
        <version>4.15.0</version>
    </dependency>
</dependencies>

Gradle 依赖 #

dependencies {
    implementation 'org.springframework.data:spring-data-cassandra-reactive:3.4.10'
    implementation 'com.datastax.oss:java-driver-core:4.15.0'
    implementation 'com.datastax.oss:java-driver-auth:4.15.0'
}

2. 准备Astra DB Secure Connect Bundle #

从Astra控制台下载目标数据库的Secure Connect Bundle（ZIP格式），将其放置到项目的src/main/resources目录下（或自定义路径）。

3. 手动配置响应式Cassandra上下文 #

创建Spring配置类，手动注册核心Bean，替代Spring Boot的自动配置逻辑：

import com.datastax.oss.driver.api.core.CqlSession;
import com.datastax.oss.driver.api.core.config.DriverConfigLoader;
import com.datastax.oss.driver.api.core.config.DefaultDriverConfigLoader;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.cassandra.core.ReactiveCassandraTemplate;
import org.springframework.data.cassandra.core.cql.session.DefaultSessionFactory;
import org.springframework.data.cassandra.core.cql.session.SessionFactory;
import org.springframework.data.cassandra.repository.config.EnableReactiveCassandraRepositories;

import java.nio.file.Paths;

@Configuration
@EnableReactiveCassandraRepositories(basePackages = "com.yourpackage.repositories") // 替换为你的Repository所在包路径
public class ReactiveCassandraConfig {

    @Bean
    public CqlSession cqlSession() {
        // 加载Secure Connect Bundle配置
        DriverConfigLoader configLoader = DefaultDriverConfigLoader.fromBundle(
                Paths.get("src/main/resources/secure-connect-your-db.zip"), // 替换为你的bundle文件名
                () -> "your-astra-client-id", // Astra DB的Client ID
                () -> "your-astra-client-secret" // Astra DB的Client Secret
        );

        // 创建CqlSession并指定目标密钥空间
        return CqlSession.builder()
                .withConfigLoader(configLoader)
                .withKeyspace("your-keyspace-name") // 替换为你的Astra密钥空间名称
                .build();
    }

    @Bean
    public SessionFactory sessionFactory(CqlSession cqlSession) {
        return new DefaultSessionFactory(cqlSession);
    }

    @Bean
    public ReactiveCassandraTemplate reactiveCassandraTemplate(SessionFactory sessionFactory) {
        return new ReactiveCassandraTemplate(sessionFactory);
    }
}

4. 调整Repository接口 #

将原有继承CrudRepository的接口替换为ReactiveCrudRepository，方法返回类型改为Mono或Flux：

import org.springframework.data.cassandra.repository.ReactiveCrudRepository;
import com.yourpackage.model.YourEntity;
import reactor.core.publisher.Mono;

public interface YourEntityReactiveRepository extends ReactiveCrudRepository<YourEntity, String> {
    // 自定义查询示例
    Mono<YourEntity> findByUsername(String username);
}

5. 测试数据访问 #

在业务类中注入响应式Repository或ReactiveCassandraTemplate，进行数据操作：

import org.springframework.stereotype.Service;
import com.yourpackage.model.YourEntity;
import com.yourpackage.repositories.YourEntityReactiveRepository;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

@Service
public class YourEntityService {

    private final YourEntityReactiveRepository repository;

    public YourEntityService(YourEntityReactiveRepository repository) {
        this.repository = repository;
    }

    public Mono<YourEntity> saveEntity(YourEntity entity) {
        return repository.save(entity);
    }

    public Flux<YourEntity> getAllEntities() {
        return repository.findAll();
    }
}

注意事项 #

• 确保Spring版本与Spring Data Cassandra响应式版本兼容（例：Spring 5.3.x对应Spring Data Cassandra 3.4.x）。
• 替换代码中所有占位符（包路径、bundle文件名、Client ID/Secret、密钥空间名称）为你的实际信息。
• 若bundle文件不在项目资源目录，需调整Paths.get()参数为绝对路径。

内容的提问来源于stack exchange，提问作者Milad Amery