快捷導(dǎo)航

解讀HttpServletRequestWrapper處理request數(shù)據(jù)流多次讀取問(wèn)題

更新時(shí)間：2024年10月09日 10:07:26 作者：小旋風(fēng)-java

在Java Web開(kāi)發(fā)中,獲取HTTP請(qǐng)求參數(shù)是常見(jiàn)需求,本文詳細(xì)討論了通過(guò)POST方式獲取參數(shù)的兩種主要方法：使用request.getParameter()適用于application/x-www-form-urlencoded和multipart/form-data內(nèi)容類(lèi)型；而對(duì)于application/json類(lèi)型的數(shù)據(jù)

一、獲取請(qǐng)求參數(shù)

1、request.getParameter()
2、request.getInputStream()或request.getReader()

二、請(qǐng)求方contentType

1、application/x-www-form-urlencoded

@RequestMapping("/testWwwFrom")
@ResponseBody
public Book testWwwFrom(Book req, HttpServletRequest servletRequest) {
    logger.info("查詢(xún)所有1用戶(hù)信息" + JSON.toJSONString(req));
    return req;
}

2、multipart/form-data

@RequestMapping("/testFormData")
@ResponseBody
public Book testFormData(Book req, HttpServletRequest servletRequest) {
    logger.info("查詢(xún)所有1用戶(hù)信息" + JSON.toJSONString(req));
    return req;
}

3、application/json

@RequestMapping("/testJson")
@ResponseBody
public Book testJsonFrom(@RequestBody Book req, HttpServletRequest servletRequest) {
    logger.info("查詢(xún)所有1用戶(hù)信息" + JSON.toJSONString(req));
?
    return req;
}

1、request.getParameter()對(duì)應(yīng)application/x-www-form-urlencoded
2、request.getInputStream()或request.getReader()對(duì)應(yīng)application/json

那么現(xiàn)在有一個(gè)這樣的需求如果是form表單就獲取formToken然后和緩存的進(jìn)行CRSF防護(hù)

思路根據(jù)上面說(shuō)的form表單參數(shù)獲取分為2大類(lèi)。

其中request.getInputStream()獲取一次以后不能第二次獲取，以及request.getParameter()與request.getInputStream()也存在這種情況。

1、application/x-www-form-urlencoded以及multipart/form-data通過(guò)request.getParameter()獲取
2、application/json通過(guò)request.getInputStream()或request.getReader()獲取，這種要依賴(lài)HttpServletRequestWrapper

package com.study.ju.web.interceptor;
?
import org.apache.commons.io.IOUtils;
?
import javax.servlet.ReadListener;
import javax.servlet.ServletInputStream;
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.InputStream;
import java.io.InputStreamReader;
?
/**
 * <p>https://blog.csdn.net/kaizhangzhang/article/details/97900961</p>
 *
 * 
 * @version v 0.1 2023/5/29 15:37
 */
public class ResettableServletRequestWrapper extends HttpServletRequestWrapper {
    //保存流中的數(shù)據(jù)
    private byte[] data;
?
    /**
     * Constructs a request object wrapping the given request.
     *
     * @param request
     * @throws IllegalArgumentException if the request is null
     */
    public ResettableServletRequestWrapper(HttpServletRequest request) throws IOException {
        super(request);
        //從流中獲取數(shù)據(jù)
        data = IOUtils.toByteArray(request.getInputStream());
    }
?
    @Override
    public ServletInputStream getInputStream() throws IOException {
        //在調(diào)用getInputStream函數(shù)時(shí)，創(chuàng)建新的流，包含原先數(shù)據(jù)流中的信息，然后返回
        return new NewServletInputStream(new ByteArrayInputStream(data));
    }
?
    class NewServletInputStream extends ServletInputStream{
        private InputStream inputStream;
?
        public NewServletInputStream(InputStream inputStream){
            this.inputStream = inputStream;
        }
?
        @Override
        public int read() throws IOException {
            return inputStream.read();
        }
?
        @Override
        public boolean isFinished() {
            return false;
        }
?
        @Override
        public boolean isReady() {
            return false;
        }
?
        @Override
        public void setReadListener(ReadListener readListener) {
?
        }
    }
    @Override
    public BufferedReader getReader() throws IOException {
        return new BufferedReader(new InputStreamReader(this.getInputStream()));
    }
?
?
}

package com.study.ju.web.interceptor;
?
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.io.IOUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.servlet.HandlerInterceptor;
import org.springframework.web.servlet.ModelAndView;
?
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.util.List;
import java.util.Map;
?
/**
 * <p>form表單提交校驗(yàn)token</p>
 *
 * 
 * @version v 0.1 2023/5/29 13:45
 */
public class FormSubmitTokenInterceptor implements HandlerInterceptor {
?
?
    private String formSubmitTokenInterceptorUrls = "[\"/testJson\",\"/test/testJson\",\"/test/testWwwFrom\",\"/test/testRequestParam\"]";
?
    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        String requestURI = getRequestURI(request);
        if ("POST".equals(request.getMethod().toUpperCase()) && StringUtils.isNotEmpty(formSubmitTokenInterceptorUrls)) {
            List<String> formInterceptorUrls = JSONArray.parseArray(formSubmitTokenInterceptorUrls, String.class);
            if (CollectionUtils.isNotEmpty(formInterceptorUrls)) {
                boolean contains = formInterceptorUrls.stream().anyMatch(e -> e.contains(requestURI));
                if (contains) {
                    String contentType = request.getContentType();
                    System.out.println(contentType);
                    if ("application/json".equalsIgnoreCase(contentType)) {
                        ResettableServletRequestWrapper resettableServletRequestWrapper = new ResettableServletRequestWrapper(request);
                        String bodyParam = IOUtils.toString(resettableServletRequestWrapper.getInputStream());
                        System.out.println(bodyParam);
                        if (StringUtils.isNotEmpty(bodyParam)) {
                            JSONObject jsonObject = JSONObject.parseObject(bodyParam);
                            if (jsonObject.containsKey("formToken")) {
                                String formToken = (String) jsonObject.get("formToken");
                                System.out.println("formToken:"+formToken);
                            }
                        }
?
                    } else {
                        if (StringUtils.isNotEmpty(request.getParameter("formToken"))) {
                            System.out.println("formToken2:"+request.getParameter("formToken"));
                        }
                        System.out.println("name:"+request.getParameter("name"));
                    }
?
?
                }
?
            }
        }
        return true;
    }
?
    @Override
    public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler, ModelAndView modelAndView) throws Exception {
?
    }
?
    @Override
    public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {
?
    }
?
    /**
     * 獲取用戶(hù)請(qǐng)求的path，不帶contextPath
     * 如：/index.htm
     */
    public static String getRequestURI(HttpServletRequest request) {
        return StringUtils.replace(request.getRequestURI(), request.getContextPath(), "");
    }
}

web.xml放在前面

<filter>
   <filter-name>requestFilter</filter-name>
   <filter-class>com.study.ju.web.Filter.HttpServletRequestReplacedFilter</filter-class>
</filter>
<filter-mapping>
   <filter-name>requestFilter</filter-name>
   <url-pattern>/*</url-pattern>
</filter-mapping>