千家信息网

dubbo中ClassLoaderFilter的作用是什么

发表于:2025-02-02 作者:千家信息网编辑
千家信息网最后更新 2025年02月02日,本篇内容介绍了"dubbo中ClassLoaderFilter的作用是什么"的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细
千家信息网最后更新 2025年02月02日dubbo中ClassLoaderFilter的作用是什么

本篇内容介绍了"dubbo中ClassLoaderFilter的作用是什么"的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!

本文主要研究一下dubbo的ClassLoaderFilter

ClassLoaderFilter

dubbo-2.7.2/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/filter/ClassLoaderFilter.java

@Activate(group = CommonConstants.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);        }    }}
  • ClassLoaderFilter实现了Filter接口,其invoke方法首先获取当前线程的contextClassLoader,然后将其ContextClassLoader设置为invoker.getInterface().getClassLoader(),之后执行invoker.invoke方法,最后将当前线程的classLoader重置为原来的contextClassLoader

实例

dubbo-2.7.2/dubbo-rpc/dubbo-rpc-api/src/test/java/org/apache/dubbo/rpc/filter/ClassLoaderFilterTest.java

public class ClassLoaderFilterTest {    private ClassLoaderFilter classLoaderFilter = new ClassLoaderFilter();    @Test    public void testInvoke() throws Exception {        URL url = URL.valueOf("test://test:11/test?accesslog=true&group=dubbo&version=1.1");        String path = DemoService.class.getResource("/").getPath();        final URLClassLoader cl = new URLClassLoader(new java.net.URL[]{new java.net.URL("file:" + path)}) {            @Override            public Class loadClass(String name) throws ClassNotFoundException {                try {                    return findClass(name);                } catch (ClassNotFoundException e) {                    return super.loadClass(name);                }            }        };        final Class clazz = cl.loadClass(DemoService.class.getCanonicalName());        Invoker invoker = new MyInvoker(url) {            @Override            public Class getInterface() {                return clazz;            }            @Override            public Result invoke(Invocation invocation) throws RpcException {                Assertions.assertEquals(cl, Thread.currentThread().getContextClassLoader());                return null;            }        };        Invocation invocation = Mockito.mock(Invocation.class);        classLoaderFilter.invoke(invoker, invocation);    }}
  • 这里invoker的interface设置为DemoService.class,然后验证invoke方法里头的Thread.currentThread().getContextClassLoader()为加载DemoService.class的URLClassLoader

小结

ClassLoaderFilter实现了Filter接口,其invoke方法首先获取当前线程的contextClassLoader,然后将其ContextClassLoader设置为invoker.getInterface().getClassLoader(),之后执行invoker.invoke方法,最后将当前线程的classLoader重置为原来的contextClassLoader

"dubbo中ClassLoaderFilter的作用是什么"的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注网站,小编将为大家输出更多高质量的实用文章!

0