JVM插桩之二：Java agent基础原理

叁歲伎倆 2023-01-18 06:47 145阅读 0赞

Javaagent只要作用在class被加载之前对其加载，插入我们需要添加的字节码。

Javaagent面向的是我们java程序员，而且agent都是用java编写的，不需要太多的c/c++编程基础，不过这篇文章里也会讲到JVMTIAgent(c实现的)，因为javaagent的运行还是依赖于一个特殊的JVMTIAgent。

对于javaagent或许大家都听过，甚至使用过，常见的用法大致如下：

java -javaagent:myagent.jar=mode=test Test

我们通过-javaagent来指定我们编写的agent的jar路径（./myagent.jar）及要传给agent的参数（mode=test），这样在启动的时候这个agent就可以做一些我们想要它做的事了。

javaagent使用说明

![15b9e9b518ae06e2f1fdd48a57f751dd.png][]

## javaagent主要作用 ##

> 可以在加载java文件之前做拦截把字节码做修改
> 
> 可以在运行期将已经加载的类的字节码做变更，但是这种情况下会有很多的限制，后面会详细说  
> 还有其他的一些小众的功能
> 
> 获取所有已经被加载过的类
> 
> 获取所有已经被初始化过了的类（执行过了clinit方法，是上面的一个子集）
> 
> 获取某个对象的大小  
> 将某个jar加入到bootstrapclasspath里作为高优先级被bootstrapClassloader加载
> 
> 将某个jar加入到classpath里供AppClassload去加载
> 
> 设置某些native方法的前缀，主要在查找native方法的时候做规则匹配

### JVMTI ###

JVM Tool Interface，是jvm暴露出来的一些供用户扩展的接口集合，JVMTI是基于事件驱动的，JVM每执行到一定的逻辑就会调用一些事件的回调接口(如果有的话),这些接口可以供开发者去扩展自己的逻辑。

比如说我们最常见的想在某个类的字节码文件读取之后类定义之前能修改相关的字节码，从而使创建的class对象是我们修改之后的字节码内容，那我们就可以实现一个回调函数赋给JvmtiEnv（JVMTI的运行时，通常一个JVMTIAgent对应一个jvmtiEnv，但是也可以对应多个）的回调方法集合里的ClassFileLoadHook，这样在接下来的类文件加载过程中都会调用到这个函数里来了，大致实现如下:

jvmtiEventCallbacks callbacks;
    jvmtiEnv * jvmtienv = jvmti(agent);
    jvmtiError jvmtierror;
    memset(&callbacks, 0, sizeof(callbacks));
    callbacks.ClassFileLoadHook = &eventHandlerClassFileLoadHook;
    jvmtierror = (*jvmtienv)->SetEventCallbacks(jvmtienv, &callbacks, sizeof(callbacks));

### JVMTIAgent ###

JVMTIAgent其实就是一个动态库，利用JVMTI暴露出来的一些接口来干一些我们想做但是正常情况下又做不到的事情，不过为了和普通的动态库进行区分，它一般会实现如下的一个或者多个函数：

JNIEXPORT jint JNICALL
    Agent_OnLoad(JavaVM *vm, char *options, void *reserved);
    
    JNIEXPORT jint JNICALL
    Agent_OnAttach(JavaVM* vm, char *options, void *reserved);
    
    JNIEXPORT void JNICALL
    Agent_OnUnload(JavaVM *vm);

> Agent\_OnLoad函数，如果agent是在启动的时候加载的，也就是在vm参数里通过-agentlib来指定，那在启动过程中就会去执行这个agent里的Agent\_OnLoad函数。
> 
> Agent\_OnAttach函数，如果agent不是在启动的时候加载的，是我们先attach到目标进程上，然后给对应的目标进程发送load命令来加载agent，在加载过程中就会调用Agent\_OnAttach函数。
> 
> Agent\_OnUnload函数，在agent做卸载的时候调用，不过貌似基本上很少实现它。

其实我们每天都在和JVMTIAgent打交道，只是你可能没有意识到而已，比如我们经常使用eclipse等工具对java代码做调试，其实就利用了jre自带的jdwp agent来实现的，只是由于eclipse等工具在没让你察觉的情况下将相关参数(类似-agentlib:jdwp=transport=dt\_socket,suspend=y,address=localhost:61349)给自动加到程序启动参数列表里了，其中agentlib参数就是用来跟要加载的agent的名字，比如这里的jdwp(不过这不是动态库的名字，而JVM是会做一些名称上的扩展，比如在linux下会去找libjdwp.so的动态库进行加载，也就是在名字的基础上加前缀lib,再加后缀.so)，接下来会跟一堆相关的参数，会将这些参数传给Agent\_OnLoad或者Agent\_OnAttach函数里对应的options参数。

### **Javaagent** ###

说到javaagent必须要讲的是一个叫做instrument的JVMTIAgent（linux下对应的动态库是libinstrument.so），因为就是它来实现javaagent的功能的，另外instrument agent还有个别名叫JPLISAgent(Java Programming Language Instrumentation Services Agent)，从这名字里也完全体现了其最本质的功能：就是专门为java语言编写的插桩服务提供支持的。

### INSTRUMENT AGENT ###

instrument agent实现了Agent\_OnLoad和Agent\_OnAttach两方法，也就是说我们在用它的时候既支持启动的时候来加载agent，也支持在运行期来动态来加载这个agent，其中启动时加载agent还可以通过类似-javaagent:myagent.jar的方式来间接加载instrument agent，运行期动态加载agent依赖的是jvm的attach机制JVM Attach机制实现，通过发送load命令来加载agent。

instrument agent的核心数据结构如下：

struct _JPLISAgent {
        JavaVM *                mJVM;                   /* handle to the JVM */
        JPLISEnvironment        mNormalEnvironment;     /* for every thing but retransform stuff */
        JPLISEnvironment        mRetransformEnvironment;/* for retransform stuff only */
        jobject                 mInstrumentationImpl;   /* handle to the Instrumentation instance */
        jmethodID               mPremainCaller;         /* method on the InstrumentationImpl that does the premain stuff (cached to save lots of lookups) */
        jmethodID               mAgentmainCaller;       /* method on the InstrumentationImpl for agents loaded via attach mechanism */
        jmethodID               mTransform;             /* method on the InstrumentationImpl that does the class file transform */
        jboolean                mRedefineAvailable;     /* cached answer to "does this agent support redefine" */
        jboolean                mRedefineAdded;         /* indicates if can_redefine_classes capability has been added */
        jboolean                mNativeMethodPrefixAvailable; /* cached answer to "does this agent support prefixing" */
        jboolean                mNativeMethodPrefixAdded;     /* indicates if can_set_native_method_prefix capability has been added */
        char const *            mAgentClassName;        /* agent class name */
        char const *            mOptionsString;         /* -javaagent options string */
    };
     
    struct _JPLISEnvironment {
        jvmtiEnv *              mJVMTIEnv;              /* the JVM TI environment */
        JPLISAgent *            mAgent;                 /* corresponding agent */
        jboolean                mIsRetransformer;       /* indicates if special environment */
    };

这里解释下几个重要项：

*  mNormalEnvironment：主要提供正常的类transform及redefine功能的。
 *  mRetransformEnvironment：主要提供类retransform功能的。
 *  mInstrumentationImpl：这个对象非常重要，也是我们java agent和JVM进行交互的入口，或许写过javaagent的人在写premain以及agentmain方法的时候注意到了有个Instrumentation的参数，这个参数其实就是这里的对象。
 *  mPremainCaller：指向sun.instrument.InstrumentationImpl.loadClassAndCallPremain方法，如果agent是在启动的时候加载的，那该方法会被调用。
 *  mAgentmainCaller：指向sun.instrument.InstrumentationImpl.loadClassAndCallAgentmain方法，该方法在通过attach的方式动态加载agent的时候调用。
 *  mTransform：指向sun.instrument.InstrumentationImpl.transform方法。
 *  mAgentClassName：在我们javaagent的MANIFEST.MF里指定的Agent-Class。
 *  mOptionsString：传给agent的一些参数。
 *  mRedefineAvailable：是否开启了redefine功能，在javaagent的MANIFEST.MF里设置Can-Redefine-Classes:true。
 *  mNativeMethodPrefixAvailable：是否支持native方法前缀设置，通样在javaagent的MANIFEST.MF里设置Can-Set-Native-Method-Prefix:true。
 *  mIsRetransformer：如果在javaagent的MANIFEST.MF文件里定义了Can-Retransform-Classes:true，那将会设置mRetransformEnvironment的mIsRetransformer为true。

红色标注的是我们最常用的,下面的列子也是会用到的...,接下来看一个具体的例子,如果熟悉分布式调用链系统的人肯定知道,调用链中最基础的一个功能就是统计一个服务里面的某个方法执行了多长时间...，其实这个就目前来说大多数系统底层都是基于字节码插桩技术实现的,接下来就演示一个完整的例子....,定义一个业务类,类里面定义几个方法,然后在执行这个方法的时候,会动态实现方法的耗时统计。示例见《》。

### 启动时加载instrument agent ###

正如『概述』里提到的方式，就是启动的时候加载instrument agent，具体过程都在InvocationAdapter.c的Agent\_OnLoad方法里，简单描述下过程：

> 1.创建并初始化JPLISAgent;
> 
> 2.监听VMInit事件，在vm初始化完成之后坐下面的事情;
> 
> 3.创建InstrumentationImpl对象;
> 
> 4.监听ClassFileLoadHook事件;
> 
> 5.调用InstrumentationImpl的loadClassAndCallPremain方法，在这个方法里会去调用javaagent里MANIFEST.MF里指定的Premain-Class类的premain方法;
> 
> 6.解析javaagent里MANIFEST.MF里的参数，并根据这些参数来设置JPLISAgent里的一些内容;

### 运行时加载instrument agent ###

运行时加载的方式，大致按照下面的方式来操作：

VirtualMachine vm = VirtualMachine.attach(pid);
    vm.loadAgent(agentPath, agentArgs);

上面会通过jvm的attach机制来请求目标jvm加载对应的agent，过程大致如下：

*  创建并初始化JPLISAgent
 *  解析javaagent里MANIFEST.MF里的参数
 *  创建InstrumentationImpl对象
 *  监听ClassFileLoadHook事件
 *  调用InstrumentationImpl的loadClassAndCallAgentmain方法，在这个方法里会去调用javaagent里MANIFEST.MF里指定的Agent-Class类的agentmain方法

### instrument agent的ClassFileLoadHook回调实现 ###

不管是启动时还是运行时加载的instrument agent都关注着同一个jvmti事件---ClassFileLoadHook，这个事件是在读取字节码文件之后回调时用的，这样可以对原来的字节码做修改，那这里面究竟是怎样实现的呢？

void JNICALL
    eventHandlerClassFileLoadHook(  jvmtiEnv *              jvmtienv,
                                    JNIEnv *                jnienv,
                                    jclass                  class_being_redefined,
                                    jobject                 loader,
                                    const char*             name,
                                    jobject                 protectionDomain,
                                    jint                    class_data_len,
                                    const unsigned char*    class_data,
                                    jint*                   new_class_data_len,
                                    unsigned char**         new_class_data) {
        JPLISEnvironment * environment  = NULL;
     
        environment = getJPLISEnvironment(jvmtienv);
        /* if something is internally inconsistent (no agent), just silently return without touching the buffer */
        if ( environment != NULL ) {
            jthrowable outstandingException = preserveThrowable(jnienv);
            transformClassFile( environment->mAgent,
                                jnienv,
                                loader,
                                name,
                                class_being_redefined,
                                protectionDomain,
                                class_data_len,
                                class_data,
                                new_class_data_len,
                                new_class_data,
                                environment->mIsRetransformer);
            restoreThrowable(jnienv, outstandingException);
        }
    }

先根据jvmtiEnv取得对应的JPLISEnvironment，因为上面我已经说到其实有两个JPLISEnvironment（并且有两个jvmtiEnv），其中一个专门做retransform的，而另外一个用来做其他的事情，根据不同的用途我们在注册具体的ClassFileTransformer的时候也是分开的，对于作为retransform用的ClassFileTransformer我们会注册到一个单独的TransformerManager里。

接着调用transformClassFile方法，由于函数实现比较长，我这里就不贴代码了，大致意思就是调用InstrumentationImpl对象的transform方法，根据最后那个参数来决定选哪个TransformerManager里的ClassFileTransformer对象们做transform操作。

private byte[]
        transform(  ClassLoader         loader,
                    String              classname,
                    Class               classBeingRedefined,
                    ProtectionDomain    protectionDomain,
                    byte[]              classfileBuffer,
                    boolean             isRetransformer) {
            TransformerManager mgr = isRetransformer?
                                            mRetransfomableTransformerManager :
                                            mTransformerManager;
            if (mgr == null) {
                return null; // no manager, no transform
            } else {
                return mgr.transform(   loader,
                                        classname,
                                        classBeingRedefined,
                                        protectionDomain,
                                        classfileBuffer);
            }
        }
     
      public byte[]
        transform(  ClassLoader         loader,
                    String              classname,
                    Class               classBeingRedefined,
                    ProtectionDomain    protectionDomain,
                    byte[]              classfileBuffer) {
            boolean someoneTouchedTheBytecode = false;
     
            TransformerInfo[]  transformerList = getSnapshotTransformerList();
     
            byte[]  bufferToUse = classfileBuffer;
     
            // order matters, gotta run 'em in the order they were added
            for ( int x = 0; x < transformerList.length; x++ ) {
                TransformerInfo         transformerInfo = transformerList[x];
                ClassFileTransformer    transformer = transformerInfo.transformer();
                byte[]                  transformedBytes = null;
     
                try {
                    transformedBytes = transformer.transform(   loader,
                                                                classname,
                                                                classBeingRedefined,
                                                                protectionDomain,
                                                                bufferToUse);
                }
                catch (Throwable t) {
                    // don't let any one transformer mess it up for the others.
                    // This is where we need to put some logging. What should go here? FIXME
                }
     
                if ( transformedBytes != null ) {
                    someoneTouchedTheBytecode = true;
                    bufferToUse = transformedBytes;
                }
            }
     
            // if someone modified it, return the modified buffer.
            // otherwise return null to mean "no transforms occurred"
            byte [] result;
            if ( someoneTouchedTheBytecode ) {
                result = bufferToUse;
            }
            else {
                result = null;
            }
     
            return result;
        }

以上是最终调到的java代码，可以看到已经调用到我们编写的javaagent代码里了，我们一般是实现一个ClassFileTransformer类，然后创建一个对象注册了对应的TransformerManager里。

### Class Transform的实现 ###

这里说的class transform其实是狭义的，主要是针对第一次类文件加载的时候就要求被transform的场景，在加载类文件的时候发出ClassFileLoad的事件，然后交给instrument agent来调用javaagent里注册的ClassFileTransformer实现字节码的修改。

### Class Redefine的实现 ###

类重新定义，这是Instrumentation提供的基础功能之一，主要用在已经被加载过的类上，想对其进行修改，要做这件事，我们必须要知道两个东西，一个是要修改哪个类，另外一个是那个类你想修改成怎样的结构，有了这两信息之后，于是你就可以通过InstrumentationImpl的下面的redefineClasses方法去操作了。

public void redefineClasses(ClassDefinition[] definitions)
        throws ClassNotFoundException {
            if (!isRedefineClassesSupported()) {
                throw new UnsupportedOperationException("redefineClasses is not supported in this environment");
            }
            if (definitions == null) {
                throw new NullPointerException("null passed as 'definitions' in redefineClasses");
            }
            for (int i=0; i<definitions.length; ++i) {
                if (definitions[i] == null) {
                    throw new NullPointerException("element of 'definitions' is null in redefineClasses");
                }
            }
            if (definitions.length == 0) {
                return; // short-circuit if there are no changes requested
            }
    
            redefineClasses0(mNativeAgent, definitions);
    }

在JVM里对应的实现是创建一个VM\_RedefineClasses的VM\_Operation,注意执行它的时候会stop the world的:

jvmtiError
    JvmtiEnv::RedefineClasses(jint class_count, const jvmtiClassDefinition* class_definitions) {
    //TODO: add locking
    VM_RedefineClasses op(class_count, class_definitions, jvmti_class_load_kind_redefine);
    VMThread::execute(&op);
    return (op.check_error());
    } /* end RedefineClasses */

这个过程我尽量用语言来描述清楚，不详细贴代码了，因为代码量实在有点大：

>  *  挨个遍历要批量重定义的jvmtiClassDefinition
>  *  然后读取新的字节码，如果有关注ClassFileLoadHook事件的，还会走对应的transform来对新的字节码再做修改
>  *  字节码解析好，创建一个klassOop对象
>  *  对比新老类，并要求如下:
> 
> 1.  父类是同一个
> 2.  实现的接口数也要相同，并且是相同的接口
> 3.  类访问符必须一致
> 4.  字段数和字段名要一致
> 5.  新增或删除的方法必须是private static/final的
> 6.  可以修改方法
> 
>  *  对新类做字节码校验
>  *  合并新老类的常量池
>  *  如果老类上有断点，那都清除掉
>  *  对老类做jit去优化
>  *  对新老方法匹配的方法的jmethodid做更新，将老的jmethodId更新到新的method上
>  *  新类的常量池的holer指向老的类
>  *  将新类和老类的一些属性做交换，比如常量池，methods，内部类
>  *  初始化新的vtable和itable
>  *  交换annotation的method，field，paramenter
>  *  遍历所有当前类的子类，修改他们的vtable及itable

上面是基本的过程，总的来说就是只更新了类里内容，相当于只更新了指针指向的内容，并没有更新指针，避免了遍历大量已有类对象对它们进行更新带来的开销。

更多的信息见原贴：《[https://blog.csdn.net/ancinsdn/article/details/58276945][https_blog.csdn.net_ancinsdn_article_details_58276945]》

[15b9e9b518ae06e2f1fdd48a57f751dd.png]: /images/20221021/d421c6794868430a9058f47827b6ff2a.png
[https_blog.csdn.net_ancinsdn_article_details_58276945]: https://blog.csdn.net/ancinsdn/article/details/58276945