{
  "timestamp": "2019-12-27T02:48:50.544+0000",
  "status": 400,
  "error": "Bad Request",
  "message": "Required request body is missing: ...省略非關(guān)鍵信息...",
  "path": "/"
}

@Slf4j
@WebFilter
public class InputStreamFilter implements Filter {

  @Override
  public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws ServletException, IOException {
    ServletInputStream inputStream=servletRequest.getInputStream();
    String charSetStr = servletRequest.getCharacterEncoding();
    if (charSetStr == null) {
      charSetStr = "UTF-8";
    }
    Charset charSet = Charset.forName(charSetStr);
    log.info("請求的body為:\n{}",StreamUtils.copyToString(inputStream,charSet));
    filterChain.doFilter(servletRequest,servletResponse);
  }

  @Override
 protected <T> Object readWithMessageConverters(NativeWebRequest webRequest, MethodParameter parameter,
  Type paramType) throws IOException, HttpMediaTypeNotSupportedException, HttpMessageNotReadableException {
    ...省略非關(guān)鍵代碼...
    // 關(guān)鍵代碼
 Object arg = readWithMessageConverters(inputMessage, parameter, paramType);
 if (arg == null && checkRequired(parameter)) {
  throw new HttpMessageNotReadableException("Required request body is missing: " +
   parameter.getExecutable().toGenericString(), inputMessage);
 }
 return arg;
 }

  @Nullable
 protected <T> Object readWithMessageConverters(HttpInputMessage inputMessage, MethodParameter parameter,
  Type targetType) throws IOException, HttpMediaTypeNotSupportedException, HttpMessageNotReadableException {
    ...省略非關(guān)鍵代碼...
 EmptyBodyCheckingHttpInputMessage message;
 try {
   // 此處調(diào)用構(gòu)造方法時(shí)進(jìn)行了流的讀取
  message = new EmptyBodyCheckingHttpInputMessage(inputMessage);
      for (HttpMessageConverter<?> converter : this.messageConverters) {
  Class<HttpMessageConverter<?>> converterType = (Class<HttpMessageConverter<?>>) converter.getClass();
  GenericHttpMessageConverter<?> genericConverter =
   (converter instanceof GenericHttpMessageConverter ? (GenericHttpMessageConverter<?>) converter : null);
  if (genericConverter != null ? genericConverter.canRead(targetType, contextClass, contentType) :
   (targetClass != null && converter.canRead(targetClass, contentType))) {
   if (message.hasBody()) {
   ...省略非關(guān)鍵代碼...
   }
   else {
     // 此處是處理流讀取返回null的情況
   body = getAdvice().handleEmptyBody(null, message, parameter, targetType, converterType);
   }
   break;
  }
  }
 }
 catch (IOException ex) {
  throw new HttpMessageNotReadableException("I/O error while reading input message", ex, inputMessage);
 }

 ...省略非關(guān)鍵代碼...

 MediaType selectedContentType = contentType;
 Object theBody = body;
 LogFormatUtils.traceDebug(logger, traceOn -> {
  String formatted = LogFormatUtils.formatValue(theBody, !traceOn);
  return "Read \"" + selectedContentType + "\" to [" + formatted + "]";
 });

 return body;
 }
 

    // 從請求中獲取到的InputStream對象
    @Nullable
 private final InputStream body;

 public EmptyBodyCheckingHttpInputMessage(HttpInputMessage inputMessage) throws IOException {
  this.headers = inputMessage.getHeaders();
  InputStream inputStream = inputMessage.getBody();
  // 判斷InputStream是否支持mark
  if (inputStream.markSupported()) {
    // 標(biāo)記流的起始位置
  inputStream.mark(1);
  // 讀取流
  this.body = (inputStream.read() != -1 ? inputStream : null);
  // 重置流，下次讀取會(huì)從起始位置重新開始讀取
  inputStream.reset();
  }
  else {
    // 回退輸入流，支持重復(fù)讀取的InputStream
  PushbackInputStream pushbackInputStream = new PushbackInputStream(inputStream);
  // 讀取流
  int b = pushbackInputStream.read();
  if (b == -1) {
    // 返回-1表示流無數(shù)據(jù)存在
   this.body = null;
  }
  else {
    // 流存在數(shù)據(jù)，直接賦值
   this.body = pushbackInputStream;
   // 回退流到起始位置，等價(jià)于reset()方法
   pushbackInputStream.unread(b);
  }
  }
 }