Spring Boot WebFlux中R2DBC Repository未初始化问题解决

以下是针对PercorsiRepository未初始化异常的排查和解决步骤：

1. 核对核心依赖 #

确保项目依赖中包含Spring Data R2DBC和SQL Server的R2DBC驱动：

• Maven配置（pom.xml）：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-r2dbc</artifactId>
</dependency>
<dependency>
    <groupId>com.microsoft.sqlserver</groupId>
    <artifactId>mssql-r2dbc</artifactId>
</dependency>

• Gradle配置（build.gradle）：

implementation 'org.springframework.boot:spring-boot-starter-data-r2dbc'
implementation 'com.microsoft.sqlserver:mssql-r2dbc'

2. 修正Repository注解 #

PercorsiRepository需继承R2dbcRepository（或ReactiveCrudRepository），并添加@Repository注解让Spring识别：

import org.springframework.data.r2dbc.repository.R2dbcRepository;
import org.springframework.stereotype.Repository;

@Repository
public interface PercorsiRepository extends R2dbcRepository<Percorsi, Long> {
    // 自定义查询方法按需添加
}

推荐用R2dbcRepository，它是Spring Data针对R2DBC的专属Repository接口，兼容性更好。

3. 确保组件扫描覆盖Repository #

检查Spring Boot主启动类的包范围，或者手动指定Repository扫描路径：

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.data.r2dbc.repository.config.EnableR2dbcRepositories;

@SpringBootApplication
@EnableR2dbcRepositories(basePackages = "com.your.project.repository") // 替换为你的Repository所在包
public class SilverMountainApplication {
    public static void main(String[] args) {
        SpringApplication.run(SilverMountainApplication.class, args);
    }
}

如果Repository和主启动类在同一父包下，@EnableR2dbcRepositories可省略，Spring会自动扫描。

4. 改用构造函数注入Repository #

在SilverMountainHandler中必须通过构造函数注入PercorsiRepository，避免字段注入带来的初始化问题：

import org.springframework.stereotype.Component;
import org.springframework.web.reactive.function.server.ServerRequest;
import org.springframework.web.reactive.function.server.ServerResponse;
import reactor.core.publisher.Mono;

@Component
public class SilverMountainHandler {
    private final PercorsiRepository percorsiRepository;

    // 构造函数注入，Spring会自动注入实例
    public SilverMountainHandler(PercorsiRepository percorsiRepository) {
        this.percorsiRepository = percorsiRepository;
    }

    // 示例请求处理方法
    public Mono<ServerResponse> getAllPercorsi(ServerRequest request) {
        return percorsiRepository.findAll()
                .collectList()
                .flatMap(data -> ServerResponse.ok().bodyValue(data));
    }
}

WebFlux生态下优先使用构造注入，能避免循环依赖和未初始化的问题。

5. 校验R2DBC数据库配置 #

确保application.yml（或application.properties）中的R2DBC连接配置正确：

spring:
  r2dbc:
    url: r2dbc:mssql://localhost:1433/your_database
    username: db_user
    password: db_password

注意URL前缀是r2dbc:mssql，不要和JDBC的jdbc:sqlserver混淆。

6. 检查实体类映射配置 #

Percorsi实体类需正确配置R2DBC映射注解，确保Spring能识别为数据库实体：

import org.springframework.data.annotation.Id;
import org.springframework.data.relational.core.mapping.Table;

@Table("percorsi") // 对应数据库表名
public class Percorsi {
    @Id
    private Long id;
    private String routeName;
    // 其他字段、getter/setter方法
}

缺少@Table或@Id注解会导致Spring Data R2DBC无法关联Repository与实体，进而引发初始化失败。

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