过滤器（一）之ClassLoaderFilter

发表于 2022/05/13

作者 deathwhispers

6 分钟阅读

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

1. 概述

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

```plain text plain /** * 创建带 Filter 链的 Invoker 对象 * * @param invoker Invoker 对象 * @param key 获取 URL 参数名 * @param group 分组 * @param 泛型 * @return Invoker 对象 */ private static Invoker buildInvokerChain(final Invoker invoker, String key, String group) { Invoker last = invoker; // 获得过滤器数组 List 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 next = last; last = new Invoker() { @Override public Class 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 调用，已经分享，这里就不重复解释啦。

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

![](/assets/images/learning/dubbo/dubbo-filter-classloader/d766a82adb3416c668689e638426f5a9.png)

过滤器整理

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

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

# 2. Filter

在 [《精尽 Dubbo 源码分析 —— 核心流程一览》「4.4 Filter」](http://svip.iocoder.cn/Dubbo/implementation-intro/?self=) 中，已经详细分享。

# 3. ClassLoaderFilter

[com.alibaba.dubbo.rpc.filter.ClassLoaderFilter](https://github.com/YunaiV/dubbo/blob/master/dubbo-rpc/dubbo-rpc-api/src/main/java/com/alibaba/dubbo/rpc/filter/ClassLoaderFilter.java) ，实现 Filter 接口，类加载器切换过滤器实现类。代码如下：

```plain text
plain 1: @Activate(group = Constants.PROVIDER, order = -30000)  2: public class ClassLoaderFilter implements Filter {  3:   4:     @Override  5:     public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {  6:         // 获得原来的类加载器  7:         ClassLoader ocl = Thread.currentThread().getContextClassLoader();  8:         // 切换当前线程的类加载器为服务接口的类加载器  9:         Thread.currentThread().setContextClassLoader(invoker.getInterface().getClassLoader()); 10:         // 服务调用 11:         try { 12:             return invoker.invoke(invocation); 13:         } finally { 14:             // 切换当前线程的类加载器为原来的类加载器 15:             Thread.currentThread().setContextClassLoader(ocl); 16:         } 17:     } 18:  19: }

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

笔者看到这个过滤器，表示一脸懵逼，于是开始 Google 探索之路。

1、于是搜到

《ISSUE#1406：classloaderFilter》

，内容如下：