转载

SpringCloud-Zuul（二）：自定义Filter及内部路由源码解析

上一篇介绍了 SpringCloud使用Zuul的调用流程 ,明白了Zuul的工作原理关键在于ZuulServlet和它的内置Filter，所以在实际工作中，编写业务逻辑的关键就在于自定义filter。

用法

实现ZuulFilter

实现一个自定义Filter很简单，继承自 ZuulFilter 即可：

@Component
public class Filter extends ZuulFilter {
    @Override
    public String filterType() {
        return "pre";
    }

    @Override
    public int filterOrder() {
        return 0;
    }

    @Override
    public boolean shouldFilter() {
        return true;
    }

    @Override
    public Object run() throws ZuulException {
        RequestContext context = RequestContext.getCurrentContext().getRequest();
        HttpServletRequest request = context.getRequest();
        HttpServletResponse response = context.getResponse();
        System.out.println("Filter.run");
        return null;
    }
}
复制代码

同类型filter执行顺序
RequestContext.getCurrentContext()

Filter类型

Zuul的Filter一共分为四个种类， Pre , Route , Post , Error ，每种Filter的执行时机不同，所以他们在业务逻辑功能上有所不同，如图：

Pre类型的Filter总是先执行，它可以做 限流 , 权限控制 等。
Route类型的Filter为Zuul内部转发请求到真正的服务的Filter，一般我们不需要实现这种类型.
Post为请求转发完成后的后续动作，可以进行日志等的一些添加。
Error为上述Filter出错后执行的动作，可以进行错误处理等。关于它们的执行顺序，如图：

源码解析

zuul内部已经定义了各种类型的filter，如预处理，路由转发，错误处理等。我们可以通过源码来研究Zuul是如何帮我们转发请求的：

RibbonRoutingFilter
SimpleHostRoutingFilter
SendForwardFilter 上面三个Filter只会执行一个，控制它们执行过程的为 PreDecorationFilter :

当整合的是微服务时，则配置的为服务名，如：

zuul:
  prefix: /api
  routes:
    espay-auth:
      path: /test/**
      service-id: service-name
复制代码

这个时候将调用RibbonRoutingFilter作负载均衡转发请求：

protected ClientHttpResponse forward(RibbonCommandContext context) throws Exception {
    Map<String, Object> info = this.helper.debug(context.getMethod(),
            context.getUri(), context.getHeaders(), context.getParams(),
            context.getRequestEntity());

    RibbonCommand command = this.ribbonCommandFactory.create(context);
    try {
        ClientHttpResponse response = command.execute();
        this.helper.appendDebug(info, response.getRawStatusCode(), response.getHeaders());
        return response;
    }
    catch (HystrixRuntimeException ex) {
        return handleException(info, ex);
    }
}
复制代码

而当我们配置的直接为某个地址:

zuul:
  routes:
    espay-auth:
      path: /auth/**
      url: http://baidu.com
复制代码

则会调用SimpleHostRoutingFilter进行转发，它内部直接使用HttpClient进行转发：

而当请求出错时，则会交由 SendErrorFilter 处理，它会设置标志位 SEND_ERROR_FILTER_RAN 为true，然后重新发送请求到 PreDecorationFilter

。这个时候的流程为：

SendForwardFilter:

这样一次完整的路由，转发，错误处理就分析完毕。

原文 https://juejin.im/post/5cedd862e51d45773e418a13

正文到此结束

所属分类： Spring

本文标签： 负载均衡 CTO IO zuul https 代码 Service ribbon servlet API http springcloud IDE entity 权限控制源码配置 src Hystrix spring map client bug 2019 cat 解析 id 微服务 CDN App 工作原理限流
版权声明： 本文为互联网转载文章，出处已在文章中说明(部分除外)。如果侵权，请联系本站长删除，谢谢。
本文海报： 生成海报一生成海报二

其他链接

关于本站

本站定位：个人技术类博客

本站作用：写博客、记日志、闲聊扯淡鼓捣技术。

问题交流

SpringCloud-Zuul（二）：自定义Filter及内部路由源码解析

用法

实现ZuulFilter

Filter类型

源码解析

热门推荐

相关文章

说给你听

本文目录

随机标签

书籍教程

近期评论

网站信息

其他链接

关于本站

问题交流