Filter中获取传递参数方式(解决post请求参数问题)|Filter中获取传递参数方式(解决post请求参数问题) Filter中获取传递参数方式(解决

Filter中获取传递参数

1. GET 传递
2. Post 传递

XyRequestWrapper 类
XySecurityFilter

【Filter中获取传递参数方式(解决post请求参数问题)|Filter中获取传递参数方式(解决post请求参数问题)】
Filter中获取传递参数
1. GET 传递
参数可以直接通过request.getParameter获取。

2. Post 传递
产生不能过直接从request.getInputStream() 读取，必须要进行重新写。（request.getInputStream()只能够读取一次）
方式：
通过重写 HttpServletRequestWrapper 类获取getInputStream中的流数据，然后在将body数据进行重新写入传递下去。

XyRequestWrapper 类

package com.xy.boot.cmiap.filter; import com.alibaba.fastjson.JSONObject;import com.xy.boot.common.util.StringUtils;import org.apache.catalina.servlet4preview.http.HttpServletRequestWrapper;import org.apache.commons.codec.Charsets; import javax.servlet.ReadListener;import javax.servlet.ServletInputStream;import javax.servlet.http.HttpServletRequest;import java.io.*;import java.util.Enumeration;import java.util.HashMap;import java.util.Map; /** * Created by fuwenshen * Date:2018/10/26 * Time:12:21 */public class XyRequestWrapper extends HttpServletRequestWrapper { private String body; public XyRequestWrapper(HttpServletRequest request) throws IOException {super(request);StringBuilder stringBuilder = new StringBuilder();BufferedReader bufferedReader = null;try {InputStream inputStream = request.getInputStream();if (inputStream != null) {bufferedReader = new BufferedReader(new InputStreamReader(inputStream,"UTF-8"));char[] charBuffer = new char[128];int bytesRead = -1;while ((bytesRead = bufferedReader.read(charBuffer)) > 0) {stringBuilder.append(charBuffer, 0, bytesRead);}} else {stringBuilder.append("");}} catch (IOException ex) {throw ex;} finally {if (bufferedReader != null) {try {bufferedReader.close();} catch (IOException ex) {throw ex;}}}body = stringBuilder.toString();} @Overridepublic ServletInputStream getInputStream() throws IOException {final ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(body.getBytes("UTF-8"));ServletInputStream servletInputStream = new ServletInputStream() {@Overridepublic boolean isFinished() {return false;} @Overridepublic boolean isReady() {return false;} @Overridepublic void setReadListener(ReadListener readListener) { } @Overridepublic int read() throws IOException {return byteArrayInputStream.read();}};return servletInputStream;} @Overridepublic BufferedReader getReader() throws IOException {return new BufferedReader(new InputStreamReader(this.getInputStream(), Charsets.UTF_8));} public String getBody() {return this.body;} @Overridepublic String getParameter(String name) {return super.getParameter(name);} @Overridepublic Map getParameterMap() {return super.getParameterMap();} @Overridepublic Enumeration getParameterNames() {return super.getParameterNames();} @Overridepublic String[] getParameterValues(String name) {return super.getParameterValues(name);} /*** 设置自定义post参数 //** @param paramMaps* @return*/public void setParamsMaps(Map paramMaps) {Map paramBodyMap = new HashMap();if (!StringUtils.isEmpty(body)) {paramBodyMap = JSONObject.parseObject(body, Map.class);}paramBodyMap.putAll(paramMaps);body = JSONObject.toJSONString(paramBodyMap);}}

XySecurityFilter

package com.xy.boot.cmiap.filter; import com.alibaba.fastjson.JSONObject;import com.xy.boot.cmiap.bo.VerifyTokenResultBO;import com.xy.boot.cmiap.constant.HttpConstant;import com.xy.boot.cmiap.entity.enums.XyHttpCodeEnum;import com.xy.boot.cmiap.service.IXySecurityService;import com.xy.boot.cmiap.service.helper.XyHttpSecurityHelper;import com.xy.boot.common.util.StringUtils;import lombok.extern.slf4j.Slf4j;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.beans.factory.annotation.Value;import org.springframework.http.MediaType;import org.springframework.stereotype.Component; import javax.servlet.*;import javax.servlet.annotation.WebFilter;import javax.servlet.http.HttpServletRequest;import javax.servlet.http.HttpServletResponse;import java.io.IOException;import java.util.*; /** * Created by fuwenshen * Date:2018/10/29 * Time:15:36 */@Component@Slf4j@WebFilter(filterName = "xySecurityFilter", urlPatterns = {"/api/adv/*"})public class XySecurityFilter implements Filter { @Value("${verify_token_switch}")private boolean tokenSwitch;@Value("${zy.app_secret}")private String zyAppSecret;@Value("${zy.token}")private String zyToken; //验证 token boprivate VerifyTokenResultBO tokenBO=null; @Autowiredprivate IXySecurityService iXySecurityService; @Overridepublic void init(FilterConfig filterConfig) throws ServletException { } @Overridepublic void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {log.debug("进入XySecurityFilter！");// 参数集合初始化TreeMap paramsMaps = new TreeMap();String token = null, v = null, timestamp = null, sign = null; HttpServletRequest req = (HttpServletRequest) request;HttpServletResponse resp = (HttpServletResponse) response;resp.setCharacterEncoding("UTF-8");resp.setContentType(MediaType.APPLICATION_JSON_UTF8_VALUE);/*** 验证通用请求头是否完整*/token = req.getHeader(HttpConstant.TOKEN);v = req.getHeader(HttpConstant.V);timestamp = req.getHeader(HttpConstant.TIMESTAMP);sign = req.getHeader(HttpConstant.SIGN);if (StringUtils.isEmpty(token) || StringUtils.isEmpty(v) || StringUtils.isEmpty(timestamp) || StringUtils.isEmpty(sign)) {resp.sendError(XyHttpCodeEnum.ILLEGAL_REQUEST.getCode(), XyHttpCodeEnum.ILLEGAL_REQUEST.getMessage());return;} // 防止流读取一次后就没有了, 所以需要将流继续写出去XyRequestWrapper requestWrapper = new XyRequestWrapper(req); /*** 校验token*//*********************************************************/ /*** 获取请求参数*/if ("POST".equals(req.getMethod().toUpperCase())) {String body = requestWrapper.getBody();paramsMaps = JSONObject.parseObject(body, TreeMap.class);log.debug("parameterMap:" + paramsMaps.toString()); } else { Map parameterMap = requestWrapper.getParameterMap();Set entries = parameterMap.entrySet();Iterator iterator = entries.iterator();while (iterator.hasNext()) {Map.Entry next = iterator.next();paramsMaps.put(next.getKey(), next.getValue()[0]);}log.debug("parameterMap:" + paramsMaps.toString());} /*** 验证签名是否合法*//***************************************/ //设置企业信息（自定义参数）if(tokenBO!=null){Map paramsPlus = new HashMap();paramsPlus.put(HttpConstant.TOKEN, tokenBO.getTokenCode());paramsPlus.put(HttpConstant.APPID, tokenBO.getAppid());requestWrapper.setParamsMaps(paramsPlus);} chain.doFilter(requestWrapper, response); } @Overridepublic void destroy() { }}

以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。