过滤器（一）之ClassLoaderFilter

发表于 2022/05/13 更新于 2026/06/02

作者 deathwhispers

6 分钟阅读

本文基于 Dubbo 2.6.1 版本，望知悉。

1. 概述

从本文开始，我们来分享 Dubbo 的过滤器们。在 ProtocolFilterWrapper 中，在服务引用和暴露时，#buildInvokerChain(invoker, key, group) 方法中，基于 Dubbo SPI Active 机制，加载匹配对应的过滤器数组，创建带有过滤器链的 Invoker 对象。代码如下：

  
/**
 * 创建带 Filter 链的 Invoker 对象
 *
 * @param invoker Invoker 对象
 * @param key 获取 URL 参数名
 * @param group 分组
 * @param <T> 泛型
 * @return Invoker 对象
 */
private static <T> Invoker<T> buildInvokerChain(final Invoker<T> invoker, String key, String group) {
    Invoker<T> last = invoker;
    // 获得过滤器数组
    List<Filter> filters = ExtensionLoader.getExtensionLoader(Filter.class).getActivateExtension(invoker.getUrl(), key, group);
    // 倒序循环 Filter ，创建带 Filter 链的 Invoker 对象
    if (!filters.isEmpty()) {
        for (int i = filters.size() - 1; i >= 0; i--) {
            final Filter filter = filters.get(i);
            final Invoker<T> next = last;
            last = new Invoker<T>() {

                @Override
                public Class<T> getInterface() {
                    return invoker.getInterface();
                }

                @Override
                public URL getUrl() {
                    return invoker.getUrl();
                }

                @Override
                public boolean isAvailable() {
                    return invoker.isAvailable();
                }

                @Override
                public Result invoke(Invocation invocation) throws RpcException {
                    return filter.invoke(next, invocation);
                }

                @Override
                public void destroy() {
                    invoker.destroy();
                }

                @Override
                public String toString() {
                    return invoker.toString();
                }
            };
        }
    }
    return last;
}

具体的过滤器链的执行过程，在前面的 Dubbo RPC 调用，已经分享，这里就不重复解释啦。

我们把服务提供者和消费者的过滤器统一整理如下：

黄色部分，代表过滤器在服务提供者和消费者上的顺序。若为空，则表示无该过滤器。
蓝色部分，EchoFilter 等等，已经在其他文章里分享。
- dubbo-filter-cache 的 CacheFilter, dubbo-filter-validation 的 ValidationFilter ，未罗列在表格中，也会在其他文章里分享。
绿色部分，CompatibleFilter 等等，目前未开启 Dubbo SPI @Adaptive 注解，我们就不写了。

本文分享 ClassLoaderFilter 。后续的文章，也会是每篇文章分享 1-2 个过滤器，根据实际用途的情况。

2. Filter

在《精尽 Dubbo 源码分析 —— 核心流程一览》「4.4 Filter」中，已经详细分享。

3. ClassLoaderFilter

com.alibaba.dubbo.rpc.filter.ClassLoaderFilter ，实现 Filter 接口，类加载器切换过滤器实现类。代码如下：

  
@Activate(group = Constants.PROVIDER, order = -30000)
public class ClassLoaderFilter implements Filter {

    @Override
    public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
        // 获得原来的类加载器
        ClassLoader ocl = Thread.currentThread().getContextClassLoader();
        // 切换当前线程的类加载器为服务接口的类加载器
        Thread.currentThread().setContextClassLoader(invoker.getInterface().getClassLoader());
        // 服务调用
        try {
            return invoker.invoke(invocation);
        } finally {
            // 切换当前线程的类加载器为原来的类加载器
            Thread.currentThread().setContextClassLoader(ocl);
        }
    }

}

第 7 行：调用 Thread#getContextClassLoader() 方法，获得原来的类加载器。
第 9 行：调用 Thread#setContextClassLoader(ClassLoader) 方法，切换当前线程的类加载器为服务接口的类加载器。
第 12 行：调用 Invoker#invoke(invocation) 方法，服务调用。
第 15 行：调用 Thread#setContextClassLoader(ClassLoader) 方法，切换当前线程的类加载器为原来的类加载器。