SpringCloud学习笔记(三)-网关Zuul(下)

简介: Zuul在SpringCloud中起到网关的作用,可用于请求路由转发、过滤、安全检查等作用,通过@EnableZuulProxy来开启网关的配置。

3:控制器


Http请求被控制器拦截后交给ZuulServlet处理。

@Bean
public ZuulController zuulController() {
        return new ZuulController();
}


执行顺序越小会越先执行,所有pre过滤器执行完成,才会执行route过滤器,同样所有的post过滤器都会再route过滤器之后执行。(zuulFileter的compareTo方法会比较Order大小,执行过程中,从注册的过滤器列表中获取到相关类型的过滤器,根据优先级从小到大排序。)


image.png


大概整理了下zuul自带的一些过滤器


过滤器类型 名称 执行顺序 功能
pre ServletDetectionFilter -3 判断请求头来源是zuulServlet还是DispatcherServlet,决定后续的处理机制
pre FormBodyWrapperFilter -1 解析表单数据重新包装,提供给下游服务使用
pre DebugFilter 1 是否开启调试标志
pre Servlet30WrapperFilter -2 包装为符合servlet3.0规范的请求体
pre PreDecorationFilter 5 路由转发前基本信息配置
post SendResponseFilter 1000 处理正常的请求响应
error SendErrorFilter 0 错误请求响应,早起版本是post的一种,新版本单独列为一种
post LocationRewriteFilter 900 重写位置头信息为zuul url
route SendForwardFilter 500 处理内部转发
route RibbonRoutingFilter 10 使用Ribbon, Hystrix转发请求
route SimpleHostRoutingFilter 100 普通请求转发


二、ZuulServlet执行过程


前面说过ZuulServlet是Http请求的处理入口,类似用SpringMVC的请求转发器DispatcherServlet,当有Http请求到来时,会先交给ZuulServlet。


ZuulServlet继承HttpServlet,所以大概过程也是初始化-调用service()-销毁。


从service方法可以看出,按pre过滤器-route过滤器-postRoute顺序执行,如果出现错误会调用filterType为error的过滤器处理。


前置过滤器出现错误,会调用error过滤器处理后再交给post过滤器处理。


route过滤器出现错误,也是会先调用error过滤器处理再交给post过滤器处理。


而当post过滤器出现错误,直接调用error过滤器处理,结束流程。

public class ZuulServlet extends HttpServlet {
    private static final long serialVersionUID = -3374242278843351500L;
    private ZuulRunner zuulRunner;
    @Override
    public void init(ServletConfig config) throws ServletException {
        super.init(config);
        String bufferReqsStr = config.getInitParameter("buffer-requests");
        boolean bufferReqs = bufferReqsStr != null && bufferReqsStr.equals("true") ? true : false;
        zuulRunner = new ZuulRunner(bufferReqs);
    }
    @Override
    public void service(javax.servlet.ServletRequest servletRequest, javax.servlet.ServletResponse servletResponse) throws ServletException, IOException {
        try {
            init((HttpServletRequest) servletRequest, (HttpServletResponse) servletResponse);
            // Marks this request as having passed through the "Zuul engine", as opposed to servlets
            // explicitly bound in web.xml, for which requests will not have the same data attached
            RequestContext context = RequestContext.getCurrentContext();
            context.setZuulEngineRan();
            try {
                preRoute();
            } catch (ZuulException e) {
                error(e);
                postRoute();
                return;
            }
            try {
                route();
            } catch (ZuulException e) {
                error(e);
                postRoute();
                return;
            }
            try {
                postRoute();
            } catch (ZuulException e) {
                error(e);
                return;
            }
        } catch (Throwable e) {
            error(new ZuulException(e, 500, "UNHANDLED_EXCEPTION_" + e.getClass().getName()));
        } finally {
            RequestContext.getCurrentContext().unset();
        }
    }
...
}


所有过滤器的执行都是通过FilterProcessor来完成,这是过滤器执行的核心类,FilterProcessor是一个单例对象,会根据传入的过滤器类型,获取相关过滤器,根据order排序后依次执行。


相关文章
|
2月前
|
监控 负载均衡 Java
深入理解Spring Cloud中的服务网关
深入理解Spring Cloud中的服务网关
|
18天前
|
Java Spring
【Azure Spring Cloud】Spring Cloud Azure 4.0 调用Key Vault遇见认证错误 AADSTS90002: Tenant not found.
【Azure Spring Cloud】Spring Cloud Azure 4.0 调用Key Vault遇见认证错误 AADSTS90002: Tenant not found.
|
17天前
|
Java Spring 容器
【Azure Spring Cloud】在Azure Spring Apps上看见 App Memory Usage 和 jvm.menory.use 的指标的疑问及OOM
【Azure Spring Cloud】在Azure Spring Apps上看见 App Memory Usage 和 jvm.menory.use 的指标的疑问及OOM
|
18天前
|
存储 Java Spring
【Azure Spring Cloud】Azure Spring Cloud服务,如何获取应用程序日志文件呢?
【Azure Spring Cloud】Azure Spring Cloud服务,如何获取应用程序日志文件呢?
|
18天前
|
SQL Java 数据库连接
【Azure Spring Cloud】Azure Spring Cloud connect to SQL using MSI
【Azure Spring Cloud】Azure Spring Cloud connect to SQL using MSI
|
18天前
|
Java 开发工具 Spring
【Azure Spring Cloud】使用azure-spring-boot-starter-storage来上传文件报错: java.net.UnknownHostException: xxxxxxxx.blob.core.windows.net: Name or service not known
【Azure Spring Cloud】使用azure-spring-boot-starter-storage来上传文件报错: java.net.UnknownHostException: xxxxxxxx.blob.core.windows.net: Name or service not known
|
18天前
|
NoSQL Java Redis
【Azure Spring Cloud】Java Spring Cloud 应用部署到Azure上后,发现大量的 java.lang.NullPointerException: null at io.lettuce.core.protocol.CommandHandler.writeSingleCommand(CommandHandler.java:426) at ... 异常
【Azure Spring Cloud】Java Spring Cloud 应用部署到Azure上后,发现大量的 java.lang.NullPointerException: null at io.lettuce.core.protocol.CommandHandler.writeSingleCommand(CommandHandler.java:426) at ... 异常
|
18天前
|
Java Spring
【Azure 应用服务】记一次Azure Spring Cloud 的部署错误 (az spring-cloud app deploy -g dev -s testdemo -n demo -p ./hellospring-0.0.1-SNAPSHOT.jar --->>> Failed to wait for deployment instances to be ready)
【Azure 应用服务】记一次Azure Spring Cloud 的部署错误 (az spring-cloud app deploy -g dev -s testdemo -n demo -p ./hellospring-0.0.1-SNAPSHOT.jar --->>> Failed to wait for deployment instances to be ready)
|
18天前
|
Java Maven Python
【Azure Spring Cloud】部署Azure spring cloud 失败
【Azure Spring Cloud】部署Azure spring cloud 失败
|
2月前
|
JSON 前端开发 Java
SpringCloud怎么搭建GateWay网关&统一登录模块
本文来分享一下,最近我在自己的项目中实现的认证服务,目前比较简单,就是可以提供一个公共的服务,专门来处理登录请求,然后我还在API网关处实现了登录拦截的效果,因为在一个博客系统中,有一些地址是可以不登录的,比方说首页;也有一些是必须登录的,比如发布文章、评论等。所以,在网关处可以支持自定义一些不需要登录的地址,一些需要登录的地址,也可以在网关处进行校验,如果未登录,可以返回JSON格式的出参,前端可以进行相关处理,比如跳转到登录页面等。