Post请求报文压缩

针对项目中的大报文，想把报文进行压缩传输，降低网络消耗，所以想到了报文压缩后进行传输，从网络找了压缩的代码写了一下，成功了，现在贴出来，方便以后使用

1、先把测试类贴出来

package com.isoftstone.iics.bizsupport.sms.restful;

import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.nio.charset.Charset;
import java.util.zip.GZIPOutputStream;

import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.SimpleHttpConnectionManager;
import org.apache.commons.httpclient.methods.ByteArrayRequestEntity;
import org.apache.commons.httpclient.methods.PostMethod;
import org.apache.commons.io.FileUtils;
import org.apache.commons.io.IOUtils;

public class GzipHttp {
    
    
    public static void main(String[] args) {
        GzipHttp http=new GzipHttp();
        try {
            String url="http://localhost:8081/***************/test";
            String readFileToString = FileUtils.readFileToString(new File("f:/123.xml"), "utf-8");
            http.sendHttp(url, readFileToString);
        } catch (IOException e) {
            e.printStackTrace();
        }

    }
    
    
    
    
    
    
    public String sendHttp(String url,String message){
        HttpClient client=new HttpClient(new SimpleHttpConnectionManager());
        PostMethod post=new PostMethod(url);
        post.setContentChunked(true);//内容是否应该分块传输
        post.setRequestHeader("Content-Encoding", "gzip");
        post.setRequestHeader("Transfer-Encoding", "chunked");
        ByteArrayOutputStream bao=new ByteArrayOutputStream();
        String result=null;
        try {
            bao.write(message.getBytes(Charset.forName("UTF-8")));
            ByteArrayOutputStream base=new ByteArrayOutputStream();
            GZIPOutputStream gops=new GZIPOutputStream(base);
            bao.writeTo(gops);
            gops.finish();
            post.setRequestEntity(new ByteArrayRequestEntity(base.toByteArray(),"text/xml;charset=utf-8"));
            client.executeMethod(post);
            InputStream responseBodyAsStream = post.getResponseBodyAsStream();
            result = IOUtils.toString(responseBodyAsStream);
            System.out.println(result);
        } catch (IOException e) {
            e.printStackTrace();
        }
        
        return result;
    }

}

2、这个是Controller

package com.isoftstone.iics.bizsupport.sms.web.controller;

import java.io.IOException;

import javax.servlet.ServletInputStream;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.apache.commons.io.IOUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;

@Controller
public class GzipController {
    
    private final static Logger logger=LoggerFactory.getLogger(GzipController.class);
    
    @RequestMapping(value="/test",method=RequestMethod.POST)
    public void gZipTest(HttpServletRequest req,HttpServletResponse rep){
        try {
            ServletInputStream inputStream = req.getInputStream();
            String string = IOUtils.toString(inputStream);
            logger.error("request Message:{}",string);
        } catch (IOException e) {
            logger.error("
appear Exception");
            e.printStackTrace();
        }
    }

}

3、这个是过滤器

package com.isoftstone.iics.bizsupport.sms.web.filter;

import java.io.IOException;

import javax.servlet.Filter;
import javax.servlet.FilterChain;
import javax.servlet.FilterConfig;
import javax.servlet.ServletException;
import javax.servlet.ServletRequest;
import javax.servlet.ServletResponse;
import javax.servlet.http.HttpServletRequest;

public class RequestFilter implements Filter {

    @Override
    public void destroy() {

    }

    @Override
    public void doFilter(ServletRequest req, ServletResponse res, FilterChain chain) throws IOException,
            ServletException {
        chain.doFilter(new GzipRequestWrapper((HttpServletRequest)req), res);

    }

    @Override
    public void init(FilterConfig arg0) throws ServletException {

    }

}

package com.isoftstone.iics.bizsupport.sms.web.filter;

import java.io.IOException;
import java.util.zip.GZIPInputStream;

import javax.servlet.ServletInputStream;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletRequestWrapper;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class GzipRequestWrapper extends HttpServletRequestWrapper {
    
    private final static Logger logger=LoggerFactory.getLogger(GzipRequestWrapper.class);
    
    private  HttpServletRequest request;
    
    public GzipRequestWrapper(HttpServletRequest request){
        super(request);
        this.request = request;
    }

    @Override
    public ServletInputStream getInputStream() throws IOException{
        ServletInputStream inputStream = request.getInputStream();
        String content = request.getHeader("Content-Encoding");
        if(content!=null && content.indexOf("gzip")!=-1){
            try {
            final GZIPInputStream gzip=new GZIPInputStream(inputStream);
            
                ServletInputStream newStrem = new ServletInputStream() {
                    
                    @Override
                    public int read() throws IOException {
                        return gzip.read();
                    }
                };
                return newStrem;
            } catch (IOException e) {
                logger.error("decompression abnormal ,please check!!!");
                e.printStackTrace();
            }
            
        }
        return inputStream;
    }
    
    

}

4、在web.xml中加上过滤器地址即可

    <filter>
        <filter-name>gzipFilter</filter-name>
        <filter-class>com.isoftstone.iics.bizsupport.sms.web.filter.RequestFilter</filter-class>
    </filter>
    <filter-mapping>
        <filter-name>gzipFilter</filter-name>
        <url-pattern>/test</url-pattern>
    </filter-mapping>