SpringMVC获取、重写请求request中的json参数

曾经终败给现在 2023-07-11 15:06 22阅读 0赞

如图，postman中的json格式，后台解析参数

我的json：\{"loginName":"shanghu001","password":"shanghu1","belongType":1\}

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hnZzkyMw_size_16_color_FFFFFF_t_70][]

请求体解析参数的工具类：

package com.mortals.iot.framework.util;
    
    import com.alibaba.fastjson.JSONObject;
    import com.mortals.iot.module.login.web.LoginController;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import javax.servlet.http.HttpServletRequest;
    import java.io.BufferedReader;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.InputStreamReader;
    
    /**
     * @Description RequestUtil
     * @Author hgg
     * @Date 2020/3/6 9:44
     * @Version 1.0
     */
    public class RequestUtil {
    
        private static Logger logger = LoggerFactory.getLogger(LoginController.class);
    
        /**
         * 获取请求中参数
         * @param request
         * @return
         */
        public static JSONObject getParameters(HttpServletRequest request){
            BufferedReader bReader = null;
            InputStreamReader isr = null;
            try {
                InputStream iis = request.getInputStream();
                isr = new InputStreamReader(iis, "utf-8");
                bReader = new BufferedReader(isr);
                String str = null;
                StringBuffer buffer = new StringBuffer();
    
                while ((str = bReader.readLine()) != null) {
                    buffer.append(str).append("\n");
                }
                logger.info(buffer.toString());
                JSONObject json = (JSONObject)JSONObject.parseObject(buffer.toString());
                logger.info("[ACCESS LOG] body args：" + (json == null ? "" : json.toJSONString()));
                return json;
            } catch (IOException e) {
            } finally{
                try {
                    bReader.close();
                } catch (IOException e) {
                }
                try {
                    isr.close();
                } catch (IOException e) {
                }
            }
            return new JSONObject();
        }
    
        /**
         * 重写zuul路由前request的参数
         * @param ctx
         * @param reqBodyBytes
         */
        public static void rewriteRequest(RequestContext ctx, byte[] reqBodyBytes) {
            ctx.setRequest(new HttpServletRequestWrapper(ctx.getRequest()) {
                @Override
                public ServletInputStream getInputStream() {
                    return new ServletInputStreamWrapper(reqBodyBytes);
                }
                @Override
                public int getContentLength() {
                    return reqBodyBytes.length;
                }
                @Override
                public long getContentLengthLong() {
                    return reqBodyBytes.length;
                }
            });
        }
    }

**获取参数**

JSONObject param = RequestUtil.getParameters(request);
    loginName = param.getString("loginName");
    password = param.getString("password");
    belongType = param.getInteger("belongType");

**重写参数**（zuul路由前pre，修改请求参数场景）：

RequestContext context = getCurrentContext();
            HttpServletRequest request = context.getRequest();
    
    
            String requestUri = context.get(FilterConstants.REQUEST_URI_KEY).toString();
            UserCookieInfo cookie = UserCookieService.getLoginCookie(request, config.getSecurityKey());
    
            //封装cookie中的user信息，到request中
            JSONObject params = RequestUtil.getParameters(request);
            JSONObject user = new JSONObject();
            user.put("userId",cookie.getUser().getId());
            user.put("userName",cookie.getUser().getRealName());
            params.put("user",user);
    
            logger.info("用户:"+cookie.getUser().getLoginName()+"，请求："+requestUri+";请求参数："+params.toJSONString());
    
            //重写路由前request的参数
            final byte[] reqBodyBytes = params.toJSONString().getBytes();
            RequestUtil.rewriteRequest(context, reqBodyBytes);

[借鉴文章：SpringCloud Zuul修改请求参数信息][SpringCloud Zuul]

[文章二：SpringCloud zuul获取请求参数的方法（包括分离普通参数与文件流）][SpringCloud zuul]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hnZzkyMw_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/2020030610094597.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hnZzkyMw==,size_16,color_FFFFFF,t_70
[SpringCloud Zuul]: https://blog.csdn.net/cml_blog/article/details/78361373
[SpringCloud zuul]: https://blog.csdn.net/qq_19734597/article/details/102667045