Spring Webflux函数式端点中Bean Validation不生效问题求助

1. 确认依赖匹配性 #

Spring Boot 2.7.14对应的spring-boot-starter-validation依赖要明确指定版本，避免依赖冲突：

<!-- Maven -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-validation</artifactId>
    <version>2.7.14</version>
</dependency>

// Gradle
implementation 'org.springframework.boot:spring-boot-starter-validation:2.7.14'

2. 检查DTO注解合法性 #

确保注解使用场景正确，比如@NotBlank仅适用于字符串类型，且字段注解配置无误：

public class DTOObject {
    @NotBlank(message = "名称不能为空")
    private String name;

    // 必须提供getter方法，否则校验器无法读取字段值
    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }
}

3. 修正Validator Bean配置 #

直接注册LocalValidatorFactoryBean可能无法适配WebFlux环境，建议添加WebFlux专用校验器Bean：

@Configuration
public class ValidationConfig {
    @Bean
    public Validator validator() {
        LocalValidatorFactoryBean factoryBean = new LocalValidatorFactoryBean();
        // 显式初始化，避免懒加载导致校验器未就绪
        factoryBean.afterPropertiesSet();
        return factoryBean;
    }

    @Bean
    public WebFluxValidator webFluxValidator(Validator validator) {
        return new WebFluxValidator(validator);
    }
}

4. 完善校验逻辑的错误处理 #

仅调用validator.validate()不会自动触发校验生效，必须处理校验结果的错误集合：

@Component
public class RequestHandler {
    private final Validator validator;

    public RequestHandler(Validator validator) {
        this.validator = validator;
    }

    public Mono<ServerResponse> handleRequest(ServerRequest request) {
        return request.bodyToMono(DTOObject.class)
                .flatMap(dto -> {
                    Set<ConstraintViolation<DTOObject>> violations = validator.validate(dto);
                    if (!violations.isEmpty()) {
                        // 抛出校验异常，或收集错误信息返回响应
                        return Mono.error(new ConstraintViolationException(violations));
                    }
                    return Mono.just(dto);
                })
                .flatMap(validDto -> ServerResponse.ok().bodyValue("处理成功：" + validDto.getName()))
                // 全局捕获校验异常，返回标准化错误响应
                .onErrorResume(ConstraintViolationException.class, ex -> {
                    String errorMsg = ex.getConstraintViolations().stream()
                            .map(v -> v.getPropertyPath() + ": " + v.getMessage())
                            .collect(Collectors.joining("; "));
                    return ServerResponse.badRequest().bodyValue(errorMsg);
                });
    }
}

5. 确认路由配置的请求匹配规则 #

确保路由的请求谓词和实际请求的Content-Type匹配，比如JSON请求要明确指定accept(APPLICATION_JSON)：

@Configuration
public class RouterConfig {
    @Bean
    public RouterFunction<ServerResponse> route(RequestHandler handler) {
        return RouterFunctions.route(
                RequestPredicates.POST("/api/test")
                        .and(RequestPredicates.accept(MediaType.APPLICATION_JSON)),
                handler::handleRequest
        );
    }
}

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