zuul之过滤器Filter管理

作者: Mr_1214 | 来源:发表于2018-11-23 10:12 被阅读39次

zuul之请求处理流程
zuul之动态过滤器Filter类文件管理加载
zuul之过滤器Filter管理
JavaWeb三大组件之过滤器(Filter)
Spring Cloud(6) Zuul - 自定义Filter
Java三大器之过滤器（Filter）的工作原理和代码演示
Zuul的小节
SpringCloudZull.md
Spring系列之Filter and Interceptor
Zuul动态过滤器实现原理之Groovy

概述

zuul通过FilterLoader类负责filter的管理，是ZUUL的核心类之一。它编译、从文件加载，并检查源代码是否更改。它还包含按filterType的ZuulFilters。此类再如下两处使用：

zuul之请求处理流程:FilterProcessor 通过FilterLoader加载给定类型的过滤器列表

zuul之动态过滤器Filter类文件管理加载:调用processGroovyFiles方法遍历filter列表通过FilterLoader类处理加载Filter

FilterLoader

根据过滤器类型获取过滤器列表

FilterLoader 中缓存了所有过滤器的集合，可以根据过滤器的类型获取对应的过滤器列表

public List<ZuulFilter> getFiltersByType(String filterType) {

       //在缓存中获取当前类型的过滤器列表
        List<ZuulFilter> list = hashFiltersByType.get(filterType);
        if (list != null) return list;

        list = new ArrayList<ZuulFilter>();

       //通过filterRegistry获取所有过滤器
        Collection<ZuulFilter> filters = filterRegistry.getAllFilters();
        //遍历筛选过滤器获取给定的列表
        for (Iterator<ZuulFilter> iterator = filters.iterator(); iterator.hasNext(); ) {
            ZuulFilter filter = iterator.next();
            if (filter.filterType().equals(filterType)) {
                list.add(filter);
            }
        }
        //排序过滤器列表
        Collections.sort(list); // sort by priority

        //添加到缓存中
        hashFiltersByType.putIfAbsent(filterType, list);
        return list;
    }

getFiltersByType

在缓存中查找给定的类型列表

当前缓存为空时，通过全部过滤器列表缓存遍历组装给定类型的列表并缓存返回

通过过滤器源码加载编译过滤器并缓存

    public boolean putFilter(File file) throws Exception {
       // 获取类文件的全名
        String sName = file.getAbsolutePath() + file.getName();
        //校验类文件是否修改过，根据类文件的最后修改时间判断
        if (filterClassLastModified.get(sName) != null && (file.lastModified() != filterClassLastModified.get(sName))) {
        // 类文件修改过时，删除全局缓存中当前过滤器的信息
            LOG.debug("reloading filter " + sName);
            filterRegistry.remove(sName);
        }
        //在全局缓存中判断是否存在当前过滤器
        ZuulFilter filter = filterRegistry.get(sName);
        if (filter == null) {
           //缓存中无当前要加载的过滤器时，编译当前类文件
            Class clazz = COMPILER.compile(file);
            if (!Modifier.isAbstract(clazz.getModifiers())) {
               // 反射创建通过class创建过滤器对象
                filter = (ZuulFilter) FILTER_FACTORY.newInstance(clazz);
                //缓存当前过滤器对象
                List<ZuulFilter> list = hashFiltersByType.get(filter.filterType());
                if (list != null) {
                    hashFiltersByType.remove(filter.filterType()); //rebuild this list
                }
               
               //全局缓存当前过滤器对象 filterRegistry.put(file.getAbsolutePath() + file.getName(), filter);
                filterClassLastModified.put(sName, file.lastModified());
                return true;
            }
        }

        return false;
    }