SpringCloud Zuul自定义filter代码实例

时间:2021-05-20

实现过滤器很简单,只需要继承ZuulFilter,并实现ZuulFilter中的抽象方法。

  • filterType():定义过滤器的类型,它有4种类型,分别是pre、post、routing和error
  • filterOrder():过滤顺序,它是一个Int类型的值,值越小,越早执行该过滤器
  • shouldFilter():表示该过滤器是否过滤逻辑,如果为true,则执行run方法,如果为false,则不执行run方法
  • Object run():写具体的过滤逻辑

注意重要说明,有些版本在转发post时,文件上传无法转法。只要升级下版本就可以了。

本示中使用的是 springcloud Edgware.RELEASE 对应springboot1.5.9

Spring Boot Spring Cloud 1.2.x Angel版本 1.3.x Brixton版本 1.4.xstripes Camden版本 1.5.x Dalston版本、Edgware版本 2.0.x Finchley版本 2.1.x Greenwich.SR2

示例

1.pom中引用

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://.netflix.zuul.context.RequestContext;public class MyFilter extends ZuulFilter { final static Logger logger = LoggerFactory.getLogger(FirstFilter.class); // 这里可以依据url规则判断是否需要进行过滤 true需要过滤进入run方法 ,false直接忽略 public boolean shouldFilter() { RequestContext ctx = RequestContext.getCurrentContext(); logger.info(ctx.getRequest().getRequestURI() + " get request path info"); String url = ctx.getRequest().getRequestURI().toLowerCase(); // 这里判断url逻辑 if (url.startsWith("/login")) { return false; } return true; } public Object run() { RequestContext ctx = RequestContext.getCurrentContext(); // 通过其它业务生成token String access_token = "user_name_token"; // 使用1 :向request的header中增加参数access_token ctx.addZuulRequestHeader("access_token", access_token); // 使用2:向request的url里增加参数,示例增加 access_token Map<String, List<String>> requestQueryParams = ctx.getRequestQueryParams(); if (requestQueryParams == null) { requestQueryParams = new HashMap<>(); } requestQueryParams.put("access_token", Arrays.asList(access_token)); ctx.setRequestQueryParams(requestQueryParams); //使用3 ::判断是否登录,如果未登录直接返回404 if (access_token == null || access_token.trim().length() == 0) { //过滤该请求,不对其进行路由(直接输入返回) ctx.setSendZuulResponse(false); //返回错误码 ctx.setResponseStatusCode(401); // 返回错误内容 ctx.setResponseBody("{\"result\":\"access_token is not correct!\"}"); //让下一个Filter看到上一个Filter的状态用于过滤器间的协调 ctx.set("my_filter_is_success", false); return null; } // 对该请求进行路由(默认就是true) //ctx.setSendZuulResponse(true); //ctx.setResponseStatusCode(200); //让下一个Filter看到上一个Filter的状态用于过滤器间的协调 ctx.set("my_filter_is_success", false); return null; //直接返回null即可 } @Override public String filterType() { // 前置过滤器 //pre:可以在请求被路由之前调用 //route:在路由请求时候被调用 //post:在route和error过滤器之后被调用 //error:处理请求时发生错误时被调用 return "pre"; } @Override public int filterOrder() { //优先级为0,数字越大,优先级越低 return 0; }}

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。

声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。

相关文章