update 优化 使用 hutool 替换 ruoyi 自带工具类 解决部分方法过期与高版本JDK不兼容问题

疯狂的狮子li

2021-06-12 b3541e975898e17a6cbc1a9ea776f3ec7e91d39a

 ruoyi-common/src/main/java/com/ruoyi/common/filter/RepeatedlyRequestWrapper.java

@@ -1,75 +1,77 @@
package com.ruoyi.common.filter;



import java.io.BufferedReader;

import java.io.ByteArrayInputStream;

import java.io.IOException;

import java.io.InputStreamReader;

import javax.servlet.ReadListener;

import javax.servlet.ServletInputStream;

import javax.servlet.ServletResponse;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletRequestWrapper;

import com.ruoyi.common.utils.http.HttpHelper;



/**

 * 构建可重复读取inputStream的request

 * 
 * @author ruoyi

 */

public class RepeatedlyRequestWrapper extends HttpServletRequestWrapper

{

    private final byte[] body;



    public RepeatedlyRequestWrapper(HttpServletRequest request, ServletResponse response) throws IOException

    {

        super(request);

        request.setCharacterEncoding("UTF-8");

        response.setCharacterEncoding("UTF-8");



        body = HttpHelper.getBodyString(request).getBytes("UTF-8");

    }



    @Override

    public BufferedReader getReader() throws IOException

    {

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

    }



    @Override

    public ServletInputStream getInputStream() throws IOException

    {

        final ByteArrayInputStream bais = new ByteArrayInputStream(body);

        return new ServletInputStream()

        {

            @Override

            public int read() throws IOException

            {

                return bais.read();

            }



            @Override

            public int available() throws IOException

            {

                return body.length;

            }



            @Override

            public boolean isFinished()

            {

                return false;

            }



            @Override

            public boolean isReady()

            {

                return false;

            }



            @Override

            public void setReadListener(ReadListener readListener)

            {



            }

        };

    }

}

package com.ruoyi.common.filter;

import cn.hutool.core.io.IoUtil;

import javax.servlet.ReadListener;
import javax.servlet.ServletInputStream;
import javax.servlet.ServletResponse;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletRequestWrapper;
import java.io.BufferedReader;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.nio.charset.StandardCharsets;

/**
 * 构建可重复读取inputStream的request
 *
 * @author ruoyi
 */
public class RepeatedlyRequestWrapper extends HttpServletRequestWrapper
{
    private final byte[] body;

    public RepeatedlyRequestWrapper(HttpServletRequest request, ServletResponse response) throws IOException
    {
        super(request);
        request.setCharacterEncoding("UTF-8");
        response.setCharacterEncoding("UTF-8");

        body = IoUtil.readUtf8(request.getInputStream()).getBytes(StandardCharsets.UTF_8);
    }

    @Override
    public BufferedReader getReader() throws IOException
    {
        return new BufferedReader(new InputStreamReader(getInputStream()));
    }

    @Override
    public ServletInputStream getInputStream() throws IOException
    {
        final ByteArrayInputStream bais = new ByteArrayInputStream(body);
        return new ServletInputStream()
        {
            @Override
            public int read() throws IOException
            {
                return bais.read();
            }

            @Override
            public int available() throws IOException
            {
                return body.length;
            }

            @Override
            public boolean isFinished()
            {
                return false;
            }

            @Override
            public boolean isReady()
            {
                return false;
            }

            @Override
            public void setReadListener(ReadListener readListener)
            {

            }
        };
    }
}