如何在Spring Cloud Functions的AWS Lambda中强制校验必填参数？

方法1：使用JSR-380 Bean Validation（推荐） #

• 给InputObj的所有字段添加@NotNull注解，标记为必填项

  import javax.validation.constraints.NotNull;
  
  public class InputObj {
      @NotNull(message = "属性a不能为空")
      private String a;
  
      @NotNull(message = "属性b不能为空")
      private Integer b;
  
      // 生成getter、setter方法
  }
  

• 在函数处理类中注入Validator，手动校验输入对象

  import org.springframework.stereotype.Component;
  import org.springframework.validation.BeanPropertyBindingResult;
  import org.springframework.validation.Validator;
  import java.util.function.Function;
  
  @Component
  public class MyFunction implements Function<InputObj, String> {
      private final Validator validator;
  
      // 构造函数注入Validator
      public MyFunction(Validator validator) {
          this.validator = validator;
      }
  
      @Override
      public String apply(InputObj input) {
          BeanPropertyBindingResult validationResult = new BeanPropertyBindingResult(input, "inputObj");
          validator.validate(input, validationResult);
  
          if (validationResult.hasErrors()) {
              // 抛出自定义异常，后续由异常处理器转为400响应
              throw new InvalidInputException("必填参数缺失：" + validationResult.getAllErrors());
          }
  
          // 正常业务逻辑处理
          return "处理完成";
      }
  }
  

• 编写全局异常处理器，将自定义异常转为API Gateway可识别的400响应

  import org.springframework.web.bind.annotation.ControllerAdvice;
  import org.springframework.web.bind.annotation.ExceptionHandler;
  import java.util.HashMap;
  import java.util.Map;
  
  @ControllerAdvice
  public class GlobalExceptionHandler {
  
      @ExceptionHandler(InvalidInputException.class)
      public Map<String, Object> handleInvalidInput(InvalidInputException e) {
          Map<String, Object> response = new HashMap<>();
          response.put("statusCode", 400);
          response.put("body", e.getMessage());
          response.put("headers", Map.of("Content-Type", "application/json"));
          return response;
      }
  
      // 自定义异常类
      static class InvalidInputException extends RuntimeException {
          public InvalidInputException(String message) {
              super(message);
          }
      }
  }
  

方法2：手动校验每个字段 #

若不想引入Bean Validation依赖，可直接在函数逻辑中逐个检查字段是否为null：

import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.stereotype.Component;
import java.util.HashMap;
import java.util.Map;
import java.util.function.Function;

@Component
public class MyFunction implements Function<InputObj, String> {
    private static final ObjectMapper objectMapper = new ObjectMapper();

    @Override
    public String apply(InputObj input) {
        if (input.getA() == null || input.getB() == null) {
            Map<String, Object> errorResponse = new HashMap<>();
            errorResponse.put("statusCode", 400);
            errorResponse.put("body", "所有属性均为必填项，请勿缺失");
            try {
                throw new RuntimeException(objectMapper.writeValueAsString(errorResponse));
            } catch (Exception e) {
                throw new RuntimeException("参数校验失败");
            }
        }

        // 正常业务处理逻辑
        return "处理完成";
    }
}

额外注意事项 #

• 确保API Gateway集成请求设置为传递完整请求体到Lambda，避免参数丢失
• 对于基本数据类型（如int），建议改用包装类（如Integer），避免Jackson自动填充默认值导致校验失效

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