1.新加类GzipRequestWrapper 继承HttpServletRequestWrapper类
public class GzipRequestWrapper extends HttpServletRequestWrapper{
private HttpServletRequest request;
private static final Logger LOGGER = LoggerFactory.getLogger(GzipRequestWrapper.class);
public GzipRequestWrapper(HttpServletRequest request) {
super(request);
this.request = request;
}
@Override
public ServletInputStream getInputStream() throws IOException {
ServletInputStream stream = request.getInputStream();
String contentEncoding = request.getHeader("Content-Encoding");
// 如果对内容进行了压缩，则解压
if (null != contentEncoding && contentEncoding.indexOf("gzip") != -1) {
try {
final GZIPInputStream gzipInputStream = new GZIPInputStream(
stream);
ServletInputStream newStream = new ServletInputStream() {
@Override
public int read() throws IOException {
return gzipInputStream.read();
}
@Override
public boolean isFinished() {
return false;
}
@Override
public boolean isReady() {
return false;
}
@Override
public void setReadListener(ReadListener arg0) {
// TODO Auto-generated method stub
}
};
return newStream;
} catch (Exception e) {
LOGGER.debug("ungzip content fail.", e);
}
}
return stream;
}
}
2.新加FilterGzip 实现 Filter（注意使用注解）
@WebFilter(filterName="AccessFilter",urlPatterns="/")
public class FilterGzip implements Filter {
@Override
public void destroy() {
}
@Override
public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain)
throws IOException, ServletException {
System.out.println("filter");
chain.doFilter(new GzipRequestWrapper((HttpServletRequest) request),
response);
}
@Override
public void init(FilterConfig arg0) throws ServletException {
}
}
3.在启动类添加
@Bean
public FilterRegistrationBean filterRegistrationBean() {
FilterRegistrationBean registrationBean = new FilterRegistrationBean();
FilterGzip httpBasicFilter = new FilterGzip();
registrationBean.setFilter(httpBasicFilter);
List<String> urlPatterns = new ArrayList<String>();
urlPatterns.add("/*");
registrationBean.setUrlPatterns(urlPatterns);
return registrationBean;
}
4.使用
@RequestMapping(value="/info")
public String receive(HttpServletRequest req){
StringBuilder sb = null;
String json = null;
try {
ServletInputStream inputStream = req.getInputStream();
BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream,"UTF-8"));
sb = new StringBuilder();
String line = null;
while ((line = reader.readLine()) != null) {
sb.append(line);
}
json = URLEncoder.encode(sb.toString(), "UTF-8");
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
System.out.println("sb ----> " + sb.toString());
if(sb != null){
logger.info("**** 接收成功1条 ****");
}
MultiValueMap<String, String> paramMap = new LinkedMultiValueMap<>();
paramMap.add("jsonStr", json);
restTemplate.postForObject("http://SERVICE-DATA/pretreat", paramMap, String.class);
logger.info("#### 传输 成功！####");
return "ok";
}
