zoukankan      html  css  js  c++  java
  • springcloud zuul 使用zuulfilter 修改请求路径和响应头

    最近做项目有一个需求:一个网盘系统,文件存放在分布式文件系统中,之前的文件下载统一走的文件下载服务,现在需要在单文件下载的时候不需要走文件下载服务,而是直接访问文件系统上的路径,响应的时候修改响应头,使之变为文件下载(减少文件下载服务的压力)。

    分析:该需求有两点;①在网关中路由的时候修改路由地址②响应的时候修改响应头,使之变为文件下载。

    直接看网关中的过滤器代码实现:

      修改请求路径:

        

    package com.example.demo;
    
    import java.net.URI;
    
    import javax.servlet.http.HttpServletRequest;
    import javax.servlet.http.HttpServletResponse;
    
    import org.springframework.cloud.netflix.zuul.filters.support.FilterConstants;
    import org.springframework.stereotype.Component;
    
    import com.netflix.zuul.ZuulFilter;
    import com.netflix.zuul.context.RequestContext;
    import com.netflix.zuul.exception.ZuulException;
    /**
     * 需求:如果请求路径内包含list请求,则重新路由到指定的接口,路由结束后,修改响应头
     * 
     * @author mxf
     *
     */
    @Component
    public class RequestFilter extends ZuulFilter {
    
    	@Override
    	public boolean shouldFilter() {
    		RequestContext ctx = RequestContext.getCurrentContext();
    		HttpServletRequest request = ctx.getRequest();
    		String uri = request.getRequestURI();
    		/**
    		 * 根据条件去判断是否需要路由,是否需要执行该过滤器
    		 */
    		if (uri.contains("list")) {
    			return true;
    		}
    		return false;
    	}
    
    	@Override
    	public Object run() throws ZuulException {
    		RequestContext ctx = RequestContext.getCurrentContext();
    		HttpServletResponse response = ctx.getResponse();
    		try {
    			// 下面是资源地址
    			// http://192.168.16.72:8077/group1/M00/00/03/wKgQSVzHshWAdSpoAAAFsn6csJI682.png
    //				URI uri2 = new URI(requestURL.substring(0,requestURL.indexOf(requestURI) + 1));
    			/**
    			 * 重点:因为根据条件去路由新的链接,所以这里要重新设置 RouteHost 和 URI
    			 */
    			URI uri2 = new URI("http://192.168.16.72:8077/");
    			// 设置新的RouteHost
    			ctx.setRouteHost(uri2.toURL());
    			/**
    			 * 请求间携带的信息  放在请求头中,方便响应的时候修改响应头
    			 */
    			response.addHeader("sign", "target");
    			response.addHeader("info", "bb.png");
    			response.addHeader("info_size", "1458");
    		} catch (Exception e1) {
    			e1.printStackTrace();
    		}
    		// 设置新的URI
    		ctx.put(FilterConstants.REQUEST_URI_KEY, "group1/M00/00/03/wKgQSVzHshWAdSpoAAAFsn6csJI682.png");
    		return null;
    	}
    
    	@Override
    	public String filterType() {
    		return FilterConstants.ROUTE_TYPE;
    	}
    
    	@Override
    	public int filterOrder() {
    		return 1;
    	}
    
    }
    

      修改响应头:

    package com.example.demo;
    
    import javax.servlet.http.HttpServletResponse;
    
    import org.springframework.cloud.netflix.zuul.filters.support.FilterConstants;
    import org.springframework.stereotype.Component;
    import org.springframework.util.StringUtils;
    
    import com.netflix.zuul.ZuulFilter;
    import com.netflix.zuul.context.RequestContext;
    import com.netflix.zuul.exception.ZuulException;
    
    /**
     * 根据您条件修改响应头
     * @author mxf
     *
     */
    @Component
    public class ResponseFilter extends ZuulFilter{
    
    	/**
    	 * 是否执行该过滤器
    	 */
    	@Override
    	public boolean shouldFilter() {
    		RequestContext currentContext = RequestContext.getCurrentContext();
    		HttpServletResponse response = currentContext.getResponse();
    		String sign = response.getHeader("sign");
    		String info = response.getHeader("info");
    		String info_size = response.getHeader("info_size");
    		
    		if (!StringUtils.isEmpty(sign) && !StringUtils.isEmpty(info) && !StringUtils.isEmpty(info_size)) {
    			return true;
    		}
    		return false;
    	}
    
    	@Override
    	public Object run() throws ZuulException {
    		RequestContext ctx = RequestContext.getCurrentContext();
    		HttpServletResponse response = ctx.getResponse();
    		String info = response.getHeader("info");
    		String info_size = response.getHeader("info_size");
    		/**
    		 * 设置响应头,使请求变为文件下载
    		 */
    		ctx.addZuulResponseHeader("Content-Type", "application/octet-stream");
            ctx.addZuulResponseHeader("Content-Disposition", "attachment;fileName=" + info);
            ctx.addZuulResponseHeader("Content-Length", ""+info_size);
    		return null;
    	}
    
    	@Override
    	public String filterType() {
    		return FilterConstants.POST_TYPE;
    	}
    
    	@Override
    	public int filterOrder() {
    		return FilterConstants.SEND_RESPONSE_FILTER_ORDER - 2;
    	}
    
    	
    }
    

      从网上找了很多资料,没有相关的信息。所以想记录一下。

  • 相关阅读:
    Smarty简介
    简易调用及实例化视图
    简易调用及实例化模型
    简易调用及实例化控制器
    MVC错误(一)
    单一入口及MVC目录规范
    MVC各个层的作用
    MVC工作流程
    【学习笔记】字符串—马拉车(Manacher)
    【题解】邻值查找 [CH1301]
  • 原文地址:https://www.cnblogs.com/blog411032/p/10876967.html
Copyright © 2011-2022 走看看