Spring Integration HTTP入站网关请求POJO必填字段验证问题咨询

嘿，我刚好碰到过类似的问题！Spring Integration确实不会自动触发Spring Validation的注解校验，但有几个简单的方案能帮你搞定POJO必填字段的验证需求，咱们一步步来看：

方法1：使用Spring Integration的ValidationInterceptor #

这是最贴合Spring Integration生态的做法，专门用来做消息payload的校验：

• 首先确保你的请求POJO已经加上了JSR-380的校验注解，比如@NotNull、@NotBlank这些（优先用javax.validation.constraints包下的，或者搭配Spring的@Validated）
• 配置一个默认的Validator Bean：

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

• 把这个Validator包装成ValidationInterceptor，添加到你的HTTP Inbound Gateway的拦截器列表中：

@Bean
public IntegrationFlow httpInboundFlow() {
    return IntegrationFlows.from(Http.inboundGateway("/submit")
                    .requestMapping(r -> r.methods(HttpMethod.POST))
                    .requestPayloadType(YourRequestPojo.class)
                    // 添加校验拦截器
                    .interceptors(new ValidationInterceptor(validator())))
            .handle("yourRequestHandler", "process")
            .get();
}

• 校验失败时会抛出MessageValidationException，你可以通过ErrorMessageExceptionHandler来捕获这个异常，返回给客户端400 Bad Request的响应，比如：

@Bean
public ErrorMessageExceptionHandler exceptionHandler() {
    ErrorMessageExceptionHandler handler = new ErrorMessageExceptionHandler();
    handler.setAdviceChain(Collections.singletonList(errorMessage -> {
        Throwable cause = errorMessage.getPayload().getCause();
        if (cause instanceof MessageValidationException) {
            return MessageBuilder.withPayload("请求参数不合法：" + cause.getMessage())
                    .setHeader(HttpHeaders.STATUS_CODE, HttpStatus.BAD_REQUEST)
                    .build();
        }
        return errorMessage;
    }));
    return handler;
}

方法2：在业务Handler中手动触发校验 #

如果不想用拦截器，也可以在处理请求的Handler里手动调用Validator来校验：

@Service
public class YourRequestHandler {
    private final Validator validator;

    // 注入Validator
    public YourRequestHandler(Validator validator) {
        this.validator = validator;
    }

    public Object process(YourRequestPojo request) {
        // 执行校验
        Set<ConstraintViolation<YourRequestPojo>> violations = validator.validate(request);
        if (!violations.isEmpty()) {
            // 校验失败抛出异常，后续可以统一处理
            throw new ConstraintViolationException(violations);
        }
        // 正常处理业务逻辑
        return "处理成功";
    }
}

方法3：使用@MessagingGateway结合@Valid注解 #

如果你用的是注解式的Messaging Gateway，可以在方法参数上加上@Valid，同时给Gateway配置Validator：

@MessagingGateway
public interface RequestGateway {
    @Gateway(requestChannel = "inputChannel")
    String handleRequest(@Valid YourRequestPojo request);
}

@Bean
public GatewayProxyFactoryBean requestGateway() {
    GatewayProxyFactoryBean factory = new GatewayProxyFactoryBean(RequestGateway.class);
    factory.setValidator(validator());
    factory.setDefaultRequestChannelName("inputChannel");
    return factory;
}

这样当通过Gateway传递请求时，会自动触发校验，失败时同样会抛出异常。

注意事项 #

别忘了确保你的项目中已经引入了Validation相关依赖，Spring Boot 2.0版本中spring-boot-starter-web已经包含了hibernate-validator，如果是手动引入的话，需要添加：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-validation</artifactId>
</dependency>

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