如何给HttpServletRequest增加消息头

您所在的位置:网站首页 前端设置请求头 如何给HttpServletRequest增加消息头

如何给HttpServletRequest增加消息头

#如何给HttpServletRequest增加消息头| 来源: 网络整理| 查看: 265

如何给HttpServletRequest增加消息头

2021-09-19 10:31meihuiziaaaaaa Java教程

这篇文章主要介绍了如何给HttpServletRequest增加消息头的实现方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教

HttpServletRequest增加header

由于在请求中请求域的属性在请求转发,路由等过程中,请求域的值会丢失,在项目项目中使用请求头来传递信息,但是HttpRequest并没有实现增加请求头的方法,所以找到他的子类来实现

  class MutableHttpServletRequest extends HttpServletRequestWrapper { // holds custom header and value mapping private final Map customHeaders; public MutableHttpServletRequest(HttpServletRequest request){ super(request); this.customHeaders = new HashMap(); }   public void putHeader(String name, String value){ this.customHeaders.put(name, value); }   public String getHeader(String name) { // check the custom headers first String headerValue = customHeaders.get(name);   if (headerValue != null){ return headerValue; } // else return from into the original wrapped object return ((HttpServletRequest) getRequest()).getHeader(name); }   public Enumeration getHeaderNames() { // create a set of the custom header names Set set = new HashSet(customHeaders.keySet());   // now add the headers from the wrapped request object @SuppressWarnings("unchecked") Enumeration e = ((HttpServletRequest) getRequest()).getHeaderNames(); while (e.hasMoreElements()) { // add the names of the request headers into the list String n = e.nextElement(); set.add(n); }   // create an enumeration from the set and return return Collections.enumeration(set); } }

使用:

public class SecurityFilter implements javax.servlet.Filter { @Override public void destroy() { }   @Override public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException { HttpServletRequest req = (HttpServletRequest) request; MutableHttpServletRequest mutableRequest = new MutableHttpServletRequest(req); ... mutableRequest.putHeader("x-custom-header", "custom value"); chain.doFilter(mutableRequest, response); }   @Override public void init(FilterConfig filterConfig) throws ServletException { } }

但是项目中我使用的SpringCloud ZUUL中使用这样 的方式失败:

@Component public class AccessFilter extends ZuulFilter { private Logger log = LoggerFactory.getLogger(AccessFilter.class); @Autowired private VerificationHelper helper; private BufferedReader reader=null; @Autowired private KeyAndFrequencyService service; @Autowired private ZuulTest zuulTest; @Autowired private PermissionHandler permissionHandler; @Override public String filterType() { //前置过滤器 return "pre"; } @Override public int filterOrder() { //优先级,数字越大,优先级越低 return 0; } @Override public boolean shouldFilter() { //是否执行该过滤器,true代表需要过滤 return true; } @Override public Object run() { RequestContext ctx = RequestContext.getCurrentContext(); HttpServletRequest request = ctx.getRequest(); try { permissionHandler.setTokenExpireTime(200000000); String type = request.getHeader("type"); zuulTest.say(); System.out.println("......................................................"); if (type == null) { System.out.println("......................................................验证1"); Object object = helper.AccessZuul(request, ctx); return object; } else { System.out.println("......................................................验证2"); PermissionResult result=permissionHandler.check(request); System.out.println(result); if(result.isState()){   MutableHttpServletRequest mutRequest=new MutableHttpServletRequest (request); //增加头部信息 DasAccountInfo accountInfo= permissionHandler.GetDasAccountInfoById(Integer.parseInt(result.getUserId()));   mutRequest.putHeader("dasAccountInfo", JSON.toJSONString(disablePropertyName())) ;RequestContext.getCurrentContext().setRequest(mutRequest); ctx.setSendZuulResponse(true);// 对该请求进行路由 ctx.setResponseStatusCode(200); ctx.set("isSuccess", true); }else{ ctx.setSendZuulResponse(false);// 过滤该请求,不对其进行路由 ctx.setResponseStatusCode(401);// 返回错误码 ctx.setResponseBody("{\"code\":0,\"result\":\"网关验证失败!验证方式为2\"}");// 返回错误内容 ctx.set("isSuccess", false); } } }catch (Exception e){ e.printStackTrace(); log.error("网关报错!!!",e.fillInStackTrace()); } return null; }

使用zuul网关的自带的设置请求头的方法,在网关中设置的请求头可以被路由下面的服务获取到:

ctx.getZuulRequestHeaders().put("dasAccountInfo", JSON.toJSONString(disablePropertyName())); 修改HttpServletRequest中header的信息

废话一堆:由于业务有统一的鉴权系统,页面请求时在header中带过来gsid,正常业务没有问题,但是当需要下载文件时,前端统一用json解析响应,当响应文件时,对于前端来说不好处理,就决定使用简单的get请求下载文件,将gsid通过url带过来,这样的话后端鉴权就需要处理,当header中没有gsid时,从参数中取,为了尽可能少的改变公用的业务代码(指sso),就在当前项目中自定义权限拦截器。

总结一句,我就是想想header中加东西!!往下看具体实现方式:

新建拦截器类,继承原有的拦截器,重写其preHandle方法

@Override public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object o) throws Exception { String gsid = request.getHeader("GSID"); if(StringUtils.isBlank(gsid)){ String gsid= request.getParameter("GSID"); //使用反射,将gsid设置到request中的的header中去 reflectSetparam(request,"GSID",gsid); log.info("请求连接中的gsid={}",request.getHeader("GSID")); } return super.preHandle(request, response, o); }

说明:可以看到在方法中,

1、先进行header信息判断,如果header中没有GSID,就去请求参数中拿

gsid= request.getParameter("GSID");

2、通过反射将参数中的GSID键值对儿:“GSID”:“376645354562335”加入到header中去

话不多少,先上代码,再解释:

解释:

/** * 修改header信息,key-value键值对儿加入到header中 * @param request * @param key * @param value */ private void reflectSetparam(HttpServletRequest request,String key,String value){ Class


【本文地址】


今日新闻


推荐新闻


CopyRight 2018-2019 办公设备维修网 版权所有 豫ICP备15022753号-3