坑记（HttpInputMessage）
一、背景知识
public interface HttpInputMessage
extends HttpMessage
Represents an HTTP input message, consisting of headers and a readable body.Typically implemented by an HTTP request on the server-side, or a response on the client-side.Since:
3.0
Author:
Arjen Poutsma
在实现接口的加密处理过程中， 我们一般选择使用SpringMVC的ResponseBody和RequestBody，实现接口报文的监听和处理操作。在监听时，需分别实现相关的Advice类，以帮助完成自己的逻辑实现。交互流程图可以参考：
而HttpInputMessage正是我们需要获取header和请求body的关键。今天我们谈谈使用过程中可能遇到的问题。
二、情况说明
1. 问题描述
我们在实现RequestBodyAdvice时，通常会重写以下方法：
public HttpInputMessage beforeBodyRead(final HttpInputMessage inputMessage, MethodParameter parameter, Type targetType, Class<? extends HttpMessageConverter<?>> converterType) throws IOException {//读取请求bodybyte[] body = new byte[inputMessage.getBody().available()];inputMessage.getBody().read(body);
}
如我们使用以上方式，读取请求报文数据时，可能产生“读不完整”的现象。因为InputStream .available()方法描述如下：
public abstract class InputStream implements Closeable {
/*** Returns an estimate of the number of bytes that can be read (or* skipped over) from this input stream without blocking by the next* invocation of a method for this input stream. The next invocation* might be the same thread or another thread. A single read or skip of this* many bytes will not block, but may read or skip fewer bytes.** <p> Note that while some implementations of {@code InputStream} will return* the total number of bytes in the stream, many will not. It is* never correct to use the return value of this method to allocate* a buffer intended to hold all data in this stream.** <p> A subclass' implementation of this method may choose to throw an* {@link IOException} if this input stream has been closed by* invoking the {@link #close()} method.** <p> The {@code available} method for class {@code InputStream} always* returns {@code 0}.** <p> This method should be overridden by subclasses.** @return an estimate of the number of bytes that can be read (or skipped* over) from this input stream without blocking or {@code 0} when* it reaches the end of the input stream.* @exception IOException if an I/O error occurs.*/public int available() throws IOException {return 0;}
}
其中，有一句描述：
many bytes will not block, but may read or skip fewer bytes.
这就厉害了，不阻塞，但是可能丢包…所以如果使用上述方法，读取请求body时，数据并不完整，会导致后续逻辑出现异常。
2. 解决过程
上述方法有问题，可使用这个办法：
String reqBody = StreamUtils.copyToString(inputMessage.getBody(), Charset.defaultCharset());
亲测有效哦~
结束语
多看、多学、多试，总会找到解决的办法和途径。