AlibabaJava诊断工具Arthas查看Dubbo动态

　　阅读Dubbo源码过程中，会发现，Dubbo消费端在做远程调用时，默认通过Javassist框架为服务接口生成动态代理类，调用javassist框架下的JavassistProxyFactory类的getProxy（Invokerinvoker，Classlt；？〔〕interfaces）方法，动态生成一个存放在JVM中的动态代理类。publicTTgetProxy（InvokerTinvoker，Classlt；？〔〕interfaces）｛return（T）Proxy。getProxy（interfaces）。newInstance（newInvokerInvocationHandler（invoker））；｝
　　那么，问题来了，如果我们想要一睹该动态生成的代理类内部结构是怎样的，如何才能便捷做到的？
　　这就是我想介绍的一款工具，它可以帮助我们查看JDK或者javassist生成的动态代理类，当然，它的功能远不止此，还可以在生产环境进行诊断。
　　Arthas是Alibaba开源的Java诊断工具，官方在线文档地址：https：arthas。aliyun。comdoc
　　根据官网上的介绍，它还可以解决以下问题
　　当你遇到以下类似问题而束手无策时，Arthas可以帮助你解决：
　　这个类从哪个jar包加载的？为什么会报各种类相关的Exception？
　　我改的代码为什么没有执行到？难道是我没commit？分支搞错了？
　　遇到问题无法在线上debug，难道只能通过加日志再重新发布吗？
　　线上遇到某个用户的数据处理有问题，但线上同样无法debug，线下无法重现！
　　是否有一个全局视角来查看系统的运行状况？
　　有什么办法可以监控到JVM的实时运行状态？
　　怎么快速定位应用的热点，生成火焰图？
　　怎样直接从JVM内查找某个类的实例？
　　这些方案本文暂不展开，这里只展开通过该工具查看Dubbo生成的动态代理类。
　　我是直接在使用dubboparent源码中的例子，分别启动了提供者与消费者。
　　首先，启动提供者方法publicclassApplication｛publicstaticvoidmain（String〔〕args）throwsException｛startWithBootstrap（）；｝privatestaticbooleanisClassic（String〔〕args）｛returnargs。length0classic。equalsIgnoreCase（args〔0〕）；｝privatestaticvoidstartWithBootstrap（）｛ServiceConfigDemoServiceImplservicenewServiceConfig（）；service。setInterface（DemoService。class）；service。setRef（newDemoServiceImpl（））；DubboBootstrapbootstrapDubboBootstrap。getInstance（）；RegistryConfigregistryConfignewRegistryConfig（zookeeper：127。0。0。1：2181）；registryConfig。setTimeout（20000）；ProtocolConfigprotocolConfignewProtocolConfig（）；protocolConfig。setName（dubbo）；protocolConfig。setHost（192。168。100。1）；protocolConfig。setPort（20877）；bootstrap。application（newApplicationConfig（dubbodemoapiprovider））。registry（registryConfig）。service（service）。protocol（protocolConfig）。start（）。await（）；｝｝
　　注意，需要配置RegistryConfig自己的zookeeper，protocolConfig。setHost（xxx。xxx。xxx。xxx）设置成你本地内网的ip即可；
　　DemoServiceImpl类详情publicclassDemoServiceImplimplementsDemoService｛privatestaticfinalLoggerloggerLoggerFactory。getLogger（DemoServiceImpl。class）；OverridepublicStringsayHello（Stringname）｛logger。info（Helloname，requestfromconsumer：RpcContext。getContext（）。getRemoteAddress（））；returnHelloname，responsefromprovider：RpcContext。getContext（）。getLocalAddress（）；｝OverridepublicCompletableFutureStringsayHelloAsync（Stringname）｛returnnull；｝｝
　　接着，启动消费者，这里可以设置一个休眠时间，这样就可以一直维持消费者运行在内存当中publicclassApplication｛publicstaticvoidmain（String〔〕args）｛runWithRefer（）；｝privatestaticvoidrunWithRefer（）｛RegistryConfigregistryConfignewRegistryConfig（zookeeper：127。0。0。1：2181）；registryConfig。setTimeout（30000）；ProtocolConfigprotocolConfignewProtocolConfig（）；protocolConfig。setName（dubbo）；protocolConfig。setHost（192。168。200。1）；protocolConfig。setPort（20899）；ReferenceConfigDemoServicereferencenewReferenceConfig（）；reference。setApplication（newApplicationConfig（dubbodemoapiconsumer））；reference。setRegistry（registryConfig）；reference。setInterface（DemoService。class）；DemoServiceservicereference。get（）；Stringmessageservice。sayHello（dubbo）；System。out。println（打印了5555555message）；try｛Thread。sleep（100000000）；｝catch（InterruptedExceptione）｛e。printStackTrace（）；｝｝｝
　　当Dubbo的服务提供者与消费者都正常运行时，说明此时JVM虚拟机内存里已经存在动态生成的代理类，这时，我们就可以开始通过arthasboot。jar工具进行查看了。
　　首先，将arthasboot。jar工具下载到你本地，我的是Windows，随便放到一个目录当中，例如
　　接着，直接在运行着Dubbo消费端进程的IDEA上打开Terminal
　　然后，输入javajarC：Users92493Downloads12229238garthasboot。jar，arthas正常运行成功话，将列出当前JVM上运行的进程
　　可以看到我们刚刚启动的provider进程与consumer进程，这时，只需要输入对应进程前面的编号【5】，就可以将Arthas关联到启动类为org。apache。dubbo。demo。consumer。Application的Java进程上了
　　到这一步，我们就可以通过指令sc。proxy模糊查询带有proxy标志的类名了，动态代理生成的类一般都是以Proxy标志
　　其中，这里的org。apache。dubbo。common。bytecode。proxy0就是消费者生成的动态代理类，我们可以直接反编译去查看它内部结构
　　〔arthas57676〕jadorg。apache。dubbo。common。bytecode。proxy0
　　控制台就会打印出该动态代理类的内部结构DecompiledwithCFR。Couldnotloadthefollowingclasses：com。alibaba。dubbo。rpc。service。EchoServiceorg。apache。dubbo。common。bytecode。ClassGeneratorDCorg。apache。dubbo。demo。DemoServiceorg。apache。dubbo。rpc。service。Destroyablepackageorg。apache。dubbo。common。bytecode；importcom。alibaba。dubbo。rpc。service。EchoService；importjava。lang。reflect。InvocationHandler；importjava。lang。reflect。Method；importjava。util。concurrent。CompletableFuture；importorg。apache。dubbo。common。bytecode。ClassGenerator；importorg。apache。dubbo。demo。DemoService；importorg。apache。dubbo。rpc。service。Destroyable；publicclassproxy0implementsClassGenerator。DC，Destroyable，EchoService，DemoService｛publicstaticMethod〔〕methods；privateInvocationHandlerhandler；publicStringsayHello（Stringstring）｛Object〔〕objectArraynewObject〔〕｛string｝；Objectobjectthis。handler。invoke（this，methods〔0〕，objectArray）；return（String）object；｝publicCompletableFuturesayHelloAsync（Stringstring）｛Object〔〕objectArraynewObject〔〕｛string｝；Objectobjectthis。handler。invoke（this，methods〔1〕，objectArray）；return（CompletableFuture）object；｝publicObjectecho（Objectobject）｛Object〔〕objectArraynewObject〔〕｛object｝；Objectobject2this。handler。invoke（this，methods〔2〕，objectArray）；returnobject2；｝publicvoiddestroy（）｛Object〔〕objectArraynewObject〔〕｛｝；Objectobjectthis。handler。invoke（this，methods〔3〕，objectArray）；｝publicproxy0（）｛｝publicproxy0（InvocationHandlerinvocationHandler）｛this。handlerinvocationHandler；｝｝
　　在Dubbo案例当中，当我们执行Stringmessageservice。sayHello（dubbo）去调用远程接口时，其实是调用了动态代理生成的方法publicStringsayHello（Stringstring）｛Object〔〕objectArraynewObject〔〕｛string｝；Objectobjectthis。handler。invoke（this，methods〔0〕，objectArray）；return（String）object；｝
　　举一反三，这个Arthas工具类可以在线上生产环境查看一些我们新部署的代码，看是否是新改动的。
　　作者：朱季谦
　　出处：https：www。cnblogs。comzhujiqianp16114954。html