在 Spring Boot Rest Controller 中处理压缩的 json 请求
Process compressed json request in Spring Boot Rest Controller
我一直在尝试处理 RequestBody,它是 JSON 以 GZIP 格式发送的数据。在我的 RestController 中,我有以下方法:
@RequestMapping(value = "/api/data", method = RequestMethod.POST)
public ResponseEntity<String> updateData(@RequestBody String data) {
System.out.println(data);
return new ResponseEntity(HttpStatus.CREATED);
}
发送到控制器的 'data' 是 JSON,它是 GZIP 压缩的,当我打印它时,它都是编码的。我怎样才能decode/unzip这个数据?
最后我从不同的来源删除了答案。这是一个例子:
@Component
public class GzipBodyDecompressFilter implements Filter {
@Override
public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain chain)
throws IOException, ServletException {
HttpServletRequest request = (HttpServletRequest) servletRequest;
HttpServletResponse response = (HttpServletResponse) servletResponse;
request = new GzippedInputStreamWrapper((HttpServletRequest) servletRequest);
chain.doFilter(request, response);
}
final class GzippedInputStreamWrapper extends HttpServletRequestWrapper {
public static final String DEFAULT_ENCODING = "ISO-8859-1";
private byte[] bytes;
public GzippedInputStreamWrapper(final HttpServletRequest request) throws IOException {
super(request);
try {
final InputStream in = new GZIPInputStream(request.getInputStream());
bytes = IOUtils.toByteArray(in);
} catch (EOFException e) {
bytes = new byte[0];
}
}
@Override
public ServletInputStream getInputStream() throws IOException {
final ByteArrayInputStream sourceStream = new ByteArrayInputStream(bytes);
return new ServletInputStream() {
public int read() throws IOException {
return sourceStream.read();
}
@Override
public void setReadListener(ReadListener listener) {
// TODO Auto-generated method stub
}
@Override
public boolean isFinished() {
// TODO Auto-generated method stub
return false;
}
@Override
public boolean isReady() {
// TODO Auto-generated method stub
return false;
}
public void close() throws IOException {
super.close();
sourceStream.close();
}
};
}
@Override
public Map getParameterMap() {
return super.getParameterMap();
}
}
}
doFilter 方法将在它到达控制器之前执行,我可以在其中对请求的主体执行任何操作(因为我可以访问 ServletRequest),例如为 HttpServletRequestWrapper 创建一个实现,我在其中解压缩内容。
我一直在尝试处理 RequestBody,它是 JSON 以 GZIP 格式发送的数据。在我的 RestController 中,我有以下方法:
@RequestMapping(value = "/api/data", method = RequestMethod.POST)
public ResponseEntity<String> updateData(@RequestBody String data) {
System.out.println(data);
return new ResponseEntity(HttpStatus.CREATED);
}
发送到控制器的 'data' 是 JSON,它是 GZIP 压缩的,当我打印它时,它都是编码的。我怎样才能decode/unzip这个数据?
最后我从不同的来源删除了答案。这是一个例子:
@Component
public class GzipBodyDecompressFilter implements Filter {
@Override
public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain chain)
throws IOException, ServletException {
HttpServletRequest request = (HttpServletRequest) servletRequest;
HttpServletResponse response = (HttpServletResponse) servletResponse;
request = new GzippedInputStreamWrapper((HttpServletRequest) servletRequest);
chain.doFilter(request, response);
}
final class GzippedInputStreamWrapper extends HttpServletRequestWrapper {
public static final String DEFAULT_ENCODING = "ISO-8859-1";
private byte[] bytes;
public GzippedInputStreamWrapper(final HttpServletRequest request) throws IOException {
super(request);
try {
final InputStream in = new GZIPInputStream(request.getInputStream());
bytes = IOUtils.toByteArray(in);
} catch (EOFException e) {
bytes = new byte[0];
}
}
@Override
public ServletInputStream getInputStream() throws IOException {
final ByteArrayInputStream sourceStream = new ByteArrayInputStream(bytes);
return new ServletInputStream() {
public int read() throws IOException {
return sourceStream.read();
}
@Override
public void setReadListener(ReadListener listener) {
// TODO Auto-generated method stub
}
@Override
public boolean isFinished() {
// TODO Auto-generated method stub
return false;
}
@Override
public boolean isReady() {
// TODO Auto-generated method stub
return false;
}
public void close() throws IOException {
super.close();
sourceStream.close();
}
};
}
@Override
public Map getParameterMap() {
return super.getParameterMap();
}
}
}
doFilter 方法将在它到达控制器之前执行,我可以在其中对请求的主体执行任何操作(因为我可以访问 ServletRequest),例如为 HttpServletRequestWrapper 创建一个实现,我在其中解压缩内容。