请使用 Spring AMQP 4.0.2（最新稳定版本）！spring-doc.cadn.net.cn

@RabbitListener @Payload 验证

从版本 2.3.7 开始，现在更轻松地为验证 @RabbitListener 和 @RabbitHandler @Payload 参数添加 Validator。现在，您只需将验证器添加到注册器本身即可。spring-doc.cadn.net.cn

@Configuration
@EnableRabbit
public class Config implements RabbitListenerConfigurer {
    ...
    @Override
    public void configureRabbitListeners(RabbitListenerEndpointRegistrar registrar) {
      registrar.setValidator(new MyValidator());
    }
}

当使用 Spring Boot 与验证Starters时，会自动配置一个 LocalValidatorFactoryBean：

@Configuration
@EnableRabbit
public class Config implements RabbitListenerConfigurer {
    @Autowired
    private LocalValidatorFactoryBean validator;
    ...
    @Override
    public void configureRabbitListeners(RabbitListenerEndpointRegistrar registrar) {
      registrar.setValidator(this.validator);
    }
}

验证：spring-doc.cadn.net.cn

public static class ValidatedClass {
  @Max(10)
  private int bar;
  public int getBar() {
    return this.bar;
  }
  public void setBar(int bar) {
    this.bar = bar;
  }
}

和spring-doc.cadn.net.cn

@RabbitListener(id="validated", queues = "queue1", errorHandler = "validationErrorHandler",
      containerFactory = "jsonListenerContainerFactory")
public void validatedListener(@Payload @Valid ValidatedClass val) {
    ...
}
@Bean
public RabbitListenerErrorHandler validationErrorHandler() {
    return (m, e) -> {
        ...
    };
}