Spring Boot + Gzip 压缩超大 JSON 对象，传输大小减少一半！

/**

 * @ClassName: ProjectController

 * @Author zhangjin

 * @Date 2022/3/24 20:41

 * @Description:

 */

@Slf4j

@RestController

public class AdvertisingController {


    @PostMapping(
"/save")

    public Advertising saveProject(@RequestBody Advertising advertising) {

        log.info(
"获取内容"+ advertising);

return advertising;

    }

}


/**

 * @ClassName: Project

 * @Author zhangjin

 * @Date 2022/3/24 20:42

 * @Description:

 */

@Data

public class Advertising {

    private String adName;

    private String adTag;

}

编写并注册一个拦截器

/**

 * @ClassName: GZIPFilter

 * @Author zhangjin

 * @Date 2022/3/26 0:36

 * @Description:

 */

@Slf4j

@Component

public class GZIPFilter implements Filter {


    private static final String CONTENT_ENCODING = 
"Content-Encoding";

    private static final String CONTENT_ENCODING_TYPE = 
"gzip";


    @Override

    public void init(FilterConfig filterConfig) throws ServletException {

        log.info(
"init GZIPFilter");

    }


    @Override

    public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {

        long start = System.currentTimeMillis();

        HttpServletRequest httpServletRequest = (HttpServletRequest)servletRequest;


        String encodeType = httpServletRequest.getHeader(CONTENT_ENCODING);

if (CONTENT_ENCODING_TYPE.equals(encodeType)) {

            log.info(
"请求:{} 需要解压", httpServletRequest.getRequestURI());

            UnZIPRequestWrapper unZIPRequestWrapper = new UnZIPRequestWrapper(httpServletRequest);

            filterChain.doFilter(unZIPRequestWrapper,servletResponse);

        }

else {

            log.info(
"请求:{} 无需解压", httpServletRequest.getRequestURI());

            filterChain.doFilter(servletRequest,servletResponse);

        }

        log.info(
"耗时：{}ms", System.currentTimeMillis() - start);

    }


    @Override

    public void 
destroy() {

        log.info(
"destroy GZIPFilter");

    }

}


/**

 * @ClassName: FilterRegistration

 * @Author zhangjin

 * @Date 2022/3/26 0:36

 * @Description:

 */

@Configuration

public class FilterRegistration {


    @Resource

    private GZIPFilter gzipFilter;


    @Bean

    public FilterRegistrationBean<GZIPFilter> 
gzipFilterRegistrationBean() {

        FilterRegistrationBean<GZIPFilter> registration = new FilterRegistrationBean<>();

        //Filter可以new，也可以使用依赖注入Bean

        registration.setFilter(gzipFilter);

        //过滤器名称

        registration.setName(
"gzipFilter");

        //拦截路径

        registration.addUrlPatterns(
"/*");

        //设置顺序

        registration.setOrder(1);

return registration;

    }

}

实现 RequestWrapper 实现解压和写回 Body 的逻辑

/**

 * @ClassName: UnZIPRequestWrapper

 * @Author zhangjin

 * @Date 2022/3/26 11:02

 * @Description: JsonString经过压缩后保存为二进制文件 -> 解压缩后还原成JsonString转换成byte[] 写回body中

 */

@Slf4j

public class UnZIPRequestWrapper extends HttpServletRequestWrapper {


    private final byte[] bytes;


    public UnZIPRequestWrapper(HttpServletRequest request) throws IOException {

        super(request);

        try (BufferedInputStream bis = new BufferedInputStream(request.getInputStream());

             ByteArrayOutputStream baos = new ByteArrayOutputStream()) {

            final byte[] body;

            byte[] buffer = new byte[1024];

            int len;

while ((len = bis.read(buffer)) > 0) {

                baos.write(buffer, 0, len);

            }

            body = baos.toByteArray();

if (body.length == 0) {

                log.info(
"Body无内容，无需解压");

                bytes = body;

return;

            }

            this.bytes = GZIPUtils.uncompressToByteArray(body);

        } catch (IOException ex) {

            log.info(
"解压缩步骤发生异常！");

            ex.printStackTrace();

            throw ex;

        }

    }


    @Override

    public ServletInputStream getInputStream() throws IOException {

        final ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(bytes);

return new 
ServletInputStream() {


            @Override

            public boolean 
isFinished() {

returnfalse;

            }


            @Override

            public boolean 
isReady() {

returnfalse;

            }


            @Override

            public void setReadListener(ReadListener readListener) {


            }


            public int 
read() throws IOException {

return byteArrayInputStream.read();

            }

        };

    }


    @Override

    public BufferedReader getReader() throws IOException {

return new BufferedReader(new InputStreamReader(this.getInputStream()));

    }


}

附上压缩工具类

public class GZIPUtils {


    public static final String GZIP_ENCODE_UTF_8 = 
"UTF-8";


    /**

     * 字符串压缩为GZIP字节数组

     * @param str

     * @
return
     */

    public static byte[] compress(String str) {

return compress(str, GZIP_ENCODE_UTF_8);

    }


    /**

     * 字符串压缩为GZIP字节数组

     * @param str

     * @param encoding

     * @
return
     */

    public static byte[] compress(String str, String encoding) {

if (str == null || str.length() == 0) {

return null;

        }

        ByteArrayOutputStream out = new ByteArrayOutputStream();

        GZIPOutputStream gzip;

        try {

            gzip = new GZIPOutputStream(out);

            gzip.write(str.getBytes(encoding));

            gzip.close();

        } catch (IOException e) {

            e.printStackTrace();

        }

return out.toByteArray();

    }


    /**

     * GZIP解压缩

     * @param bytes

     * @
return
     */

    public static byte[] uncompress(byte[] bytes) {

if (bytes == null || bytes.length == 0) {

return null;

        }

        ByteArrayOutputStream out = new ByteArrayOutputStream();

        ByteArrayInputStream 
in = new ByteArrayInputStream(bytes);

        try {

            GZIPInputStream ungzip = new GZIPInputStream(
in);

            byte[] buffer = new byte[256];

            int n;

while ((n = ungzip.read(buffer)) >= 0) {

                out.write(buffer, 0, n);

            }

        } catch (IOException e) {

            e.printStackTrace();

        }

return out.toByteArray();

    }


    /**

     * 解压并返回String

     * @param bytes

     * @
return
     */

    public static String uncompressToString(byte[] bytes) throws IOException {

return uncompressToString(bytes, GZIP_ENCODE_UTF_8);

    }


    /**

     *

     * @param bytes

     * @
return
     */

    public static byte[] uncompressToByteArray(byte[] bytes) throws IOException {

return uncompressToByteArray(bytes, GZIP_ENCODE_UTF_8);

    }


    /**

     * 解压成字符串

     * @param bytes 压缩后的字节数组

     * @param encoding 编码方式

     * @
return 解压后的字符串

     */

    public static String uncompressToString(byte[] bytes, String encoding) throws IOException {

        byte[] result = uncompressToByteArray(bytes, encoding);

return new String(result);

    }


    /**

     * 解压成字节数组

     * @param bytes

     * @param encoding

     * @
return
     */

    public static byte[] uncompressToByteArray(byte[] bytes, String encoding) throws IOException {

if (bytes == null || bytes.length == 0) {

return null;

        }

        ByteArrayOutputStream out = new ByteArrayOutputStream();

        ByteArrayInputStream 
in = new ByteArrayInputStream(bytes);

        try {

            GZIPInputStream ungzip = new GZIPInputStream(
in);

            byte[] buffer = new byte[256];

            int n;

while ((n = ungzip.read(buffer)) >= 0) {

                out.write(buffer, 0, n);

            }

return out.toByteArray();

        } catch (IOException e) {

            e.printStackTrace();

            throw new IOException(
"解压缩失败！");

        }

    }


    /**

     * 将字节流转换成文件

     * @param filename

     * @param data

     * @throws Exception

     */

    public static void saveFile(String filename,byte [] data)throws Exception{

if(data != null){

            String filepath =
"/" + filename;

            File file  = new File(filepath);

if(file.exists()){

                file.delete();

            }

            FileOutputStream fos = new FileOutputStream(file);

            fos.write(data,0,data.length);

            fos.flush();

            fos.close();

            System.out.println(file);

        }

    }

}