arthas助力阅读dubbo源码

框架

Dubbo 2.7.7
arthas-boot 3.4.0
系统: Mac

1. Linux/Unix/Mac 安装arthas

curl -O https://arthas.aliyun.com/arthas-boot.jar
java -jar arthas-boot.jar

SPI是dubbo实现动态修改服务参数的基石,比如下面代码

    RegistryFactory REGISTER_FACTORY = ExtensionLoader.getExtensionLoader(RegistryFactory.class)
        .getAdaptiveExtension();
    Registry registry = REGISTER_FACTORY
        .getRegistry(URL.valueOf("zookeeper://127.0.0.1:2181?client=curator"));

返回的REGISTER_FACTORYorg.apache.dubbo.registry.RegistryFactory$Adaptive@19bb07ed,
但是这个以$Adaptive为结尾的RegistryFactory到底是什么鬼,整个项目查找都没有这个class文件,如果对Dubbo的SPI源码了解的话应该就知道RegistryFactory$Adaptive是动态拼接的字符串,然后使用字节码技术编译成class,并通过自定的ClassLoader加载到java虚拟机内存中的,所以dubbo框架源码中是找不到这个class的.但是这个class的内容我很好奇到底是什么?

方法1:使用arthas(本文的重点)(包含完整的步骤),以AdapteExtendsionTestDemo为例(要使用debug模式启动main方法,不然arthas连接AdapteExtendsionTest进程失败)

public class AdapteExtendsionTest {
    RegistryFactory REGISTER_FACTORY = ExtensionLoader.getExtensionLoader(RegistryFactory.class)
        .getAdaptiveExtension();
    Registry registry = REGISTER_FACTORY
        .getRegistry(URL.valueOf("zookeeper://127.0.0.1:2181?client=curator"));
    System.in.read();
  }
}

最后要有System.in.read(),获取其他方法,让main线程保活,不然没办法使用arthas,通过断点发现REGISTER_FACTORY.toString()返回的是org.apache.dubbo.registry.RegistryFactory$Adaptive@19bb07ed,把@19bb07ed去掉就是RegistryFactory$Adaptive完整的类路径org.apache.dubbo.registry.RegistryFactory$Adaptive.
打开终端启动arthas-boot服务

 java -jar arthas-boot.jar

执行结果如下

[INFO] arthas-boot version: 3.4.0
[INFO] Found existing java process, please choose one and input the serial number of the process, eg : 1. Then hit ENTER.
* [1]: 24835 
  [2]: 30548 org.jetbrains.jps.cmdline.Launcher
  [3]: 30549 com.leimo.demo.AdapteExtendsionTest
  [4]: 25244 org.jetbrains.idea.maven.server.RemoteMavenServer36
  [5]: 508 org.apache.zookeeper.server.quorum.QuorumPeerMain

通过上面的列表可以找到AdapteExtendsionTest,就是我们刚刚跑的测试类名
[3]: 30549 com.leimo.demo.AdapteExtendsionTest
编号是[3],在控制台输入3

3
[INFO] arthas home: /Users/lemo-wu/.arthas/lib/3.4.0/arthas
[INFO] Try to attach process 31331
[INFO] Attach process 31331 success.
[INFO] arthas-client connect 127.0.0.1 3658
  ,---.  ,------. ,--------.,--.  ,--.  ,---.   ,---.                           
 /  O  \ |  .--. ''--.  .--'|  '--'  | /  O  \ '   .-'                          
|  .-.  ||  '--'.'   |  |   |  .--.  ||  .-.  |`.  `-.                          
|  | |  ||  |\  \    |  |   |  |  |  ||  | |  |.-'    |                         
`--' `--'`--' '--'   `--'   `--'  `--'`--' `--'`-----'                          
                                                                                

wiki      https://arthas.aliyun.com/doc                                         
tutorials https://arthas.aliyun.com/doc/arthas-tutorials.html                   
version   3.4.0                                                                 
pid       31331                                                                 
time      2020-09-10 14:49:41                                                   

[arthas@31331]$ 

如果显示[arthas@xxxx]$就表示连接成功了
然后在arhhas终端输入

[arthas@31331]$ jad org.apache.dubbo.registry.RegistryFactory$Adaptive

控制台就会将class反编译的结果打印在控制台上了

[arthas@31331]$ jad org.apache.dubbo.registry.RegistryFactory$Adaptive

ClassLoader:                                                                                                                                                                                                             
+-sun.misc.Launcher$AppClassLoader@18b4aac2                                                                                                                                                                              
  +-sun.misc.Launcher$ExtClassLoader@56ac3a89                                                                                                                                                                            

Location:                                                                                                                                                                                                                
/Users/lemo-wu/.m2/repository/org/apache/dubbo/dubbo/2.7.7/dubbo-2.7.7.jar                                                                                                                                               

/*
 * Decompiled with CFR.
 */
package org.apache.dubbo.registry;

import org.apache.dubbo.common.URL;
import org.apache.dubbo.common.extension.ExtensionLoader;
import org.apache.dubbo.registry.Registry;
import org.apache.dubbo.registry.RegistryFactory;

public class RegistryFactory$Adaptive
implements RegistryFactory {
    @Override
    public Registry getRegistry(URL uRL) {
        String string;
        if (uRL == null) {
            throw new IllegalArgumentException("url == null");
        }
        URL uRL2 = uRL;
        String string2 = string = uRL2.getProtocol() == null ? "dubbo" : uRL2.getProtocol();
        if (string == null) {
            throw new IllegalStateException(new StringBuffer().append("Failed to get extension (org.apache.dubbo.registry.RegistryFactory) name from url (").append(uRL2.toString()).append(") use keys([protocol])").toString());
        }
        RegistryFactory registryFactory = ExtensionLoader.getExtensionLoader(RegistryFactory.class).getExtension(string);
        return registryFactory.getRegistry(uRL);
    }
}

Affect(row-cnt:1) cost in 563 ms.

jad是arthas的命令集之一,作用就是用来将class反编译成java输出.如果想将反编译的内容输出到一个文件中,可以使用 > 输入文件路径,比如

[arthas@31331]$ jad org.apache.dubbo.registry.RegistryFactory$Adaptive > /opt/abc.java

验证输出结果

# cd /opt
# ls
# cat abc.java

控制台输出结果如下

ClassLoader:
+-sun.misc.Launcher$AppClassLoader@18b4aac2
  +-sun.misc.Launcher$ExtClassLoader@56ac3a89

Location:
/Users/lemo-wu/.m2/repository/org/apache/dubbo/dubbo/2.7.7/dubbo-2.7.7.jar

/*
 * Decompiled with CFR.
 */
package org.apache.dubbo.registry;

import org.apache.dubbo.common.URL;
import org.apache.dubbo.common.extension.ExtensionLoader;
import org.apache.dubbo.registry.Registry;
import org.apache.dubbo.registry.RegistryFactory;

public class RegistryFactory$Adaptive
implements RegistryFactory {
    @Override
    public Registry getRegistry(URL uRL) {
        String string;
        if (uRL == null) {
            throw new IllegalArgumentException("url == null");
        }
        URL uRL2 = uRL;
        String string2 = string = uRL2.getProtocol() == null ? "dubbo" : uRL2.getProtocol();
        if (string == null) {
            throw new IllegalStateException(new StringBuffer().append("Failed to get extension (org.apache.dubbo.registry.RegistryFactory) name from url (").append(uRL2.toString()).append(") use keys([protocol])").toString());
        }
        RegistryFactory registryFactory = ExtensionLoader.getExtensionLoader(RegistryFactory.class).getExtension(string);
        return registryFactory.getRegistry(uRL);
    }
}

Affect(row-cnt:1) cost in 202 ms.

方法2. 找到到生成java字符串的方法

org.apache.dubbo.common.extension.ExtensionLoader类的createAdaptiveExtensionClass方法

  private Class<?> createAdaptiveExtensionClass() {
        String code = new AdaptiveClassCodeGenerator(type, cachedDefaultName).generate();
        ClassLoader classLoader = findClassLoader();
        org.apache.dubbo.common.compiler.Compiler compiler = ExtensionLoader.getExtensionLoader(org.apache.dubbo.common.compiler.Compiler.class).getAdaptiveExtension();
        return compiler.compile(code, classLoader);
    }

通过IDE在ClassLoader classLoader = findClassLoader();断点,然后watch code,将code的内容粘贴到一个文本编辑区中查看

package org.apache.dubbo.registry;

import org.apache.dubbo.common.URL;
import org.apache.dubbo.common.extension.ExtensionLoader;
import org.apache.dubbo.registry.Registry;
import org.apache.dubbo.registry.RegistryFactory;

public class RegistryFactory$Adaptive
implements RegistryFactory {
    @Override
    public Registry getRegistry(URL uRL) {
        String string;
        if (uRL == null) {
            throw new IllegalArgumentException("url == null");
        }
        URL uRL2 = uRL;
        String string2 = string = uRL2.getProtocol() == null ? "dubbo" : uRL2.getProtocol();
        if (string == null) {
            throw new IllegalStateException(new StringBuffer().append("Failed to get extension (org.apache.dubbo.registry.RegistryFactory) name from url (").append(uRL2.toString()).append(") use keys([protocol])").toString());
        }
        RegistryFactory registryFactory = ExtensionLoader.getExtensionLoader(RegistryFactory.class).getExtension(string);
        return registryFactory.getRegistry(uRL);
    }
}

参考资料:
https://arthas.aliyun.com/doc/en/quick-start.html

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 217,277评论 6 503
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 92,689评论 3 393
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 163,624评论 0 353
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 58,356评论 1 293
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 67,402评论 6 392
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,292评论 1 301
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,135评论 3 418
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,992评论 0 275
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,429评论 1 314
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,636评论 3 334
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,785评论 1 348
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,492评论 5 345
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,092评论 3 328
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,723评论 0 22
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,858评论 1 269
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,891评论 2 370
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,713评论 2 354