java agent技术原理及简单实现

注：本文定义-在函数执行前后增加对应的逻辑的操作统称为mock

1、引子

在某天与qa同学进行沟通时，发现qa同学有针对某个方法调用时，有让该方法停止一段时间的需求，我对这部分的功能实现非常好奇，因此决定对原理进行一些深入的了解，力争找到一种使用者尽可能少的对原有代码进行修改的方式，以达到对应的mock要求。

整体的感知程度可以分为三个级别：

• 硬编码

• 增加配置

• 无需任何修改

2、思路

在对方法进行mock，暂停以及异常模拟，在不知道其原理的情况下，进行猜想，思考其具体的实现原理，整体来说，最简单的实现模型无外乎两种：

2.1 朴素思路

假设存在如下的函数

public object targetmethod(){
	system.out.println("运行");
}

若想要在函数执行后暂停一段时间、返回特定mock值或抛出特定异常，那么可以考虑修改对应的函数内容：

public object targetmethod(){
      //在此处加入sleep return 或 throw逻辑
    system.out.println("运行");
}

或使用类似代理的方法把对应的函数进行代理：

public object proxy(){
    //执行sleep return 或 throw逻辑
      return targetmethod();
}
public object targetmethod(){
    system.out.println("运行");
}

 

2.2 略成熟思路

在朴素思路的基础上，我们可以看出，实现类似的暂停、mock和异常功能整体实现方案无外乎两种：

• 代理模式

• 深入修改内部函数

在这两种思路的基础上，我们从代理模式开始考虑（主要是代理使用的比较多，更熟悉）

2.2.1 动态代理

说起代理，最常想到的两个词语就是静态代理和动态代理，二者却别不进行详述，对于静态代理模式由于需要大量硬编码，所以完全可以不用考虑。

针对动态代理来看，开始考虑最具代表性的cglib进行调研。

下面的代码为一个典型的使用cglib进行动态代理的样例（代理的函数为hellointerface.sayhelllo）：

public class dynamicproxy implements invocationhandler {

    private object target;

    public dynamicproxy(object object) {
        this.target = object;
    }

    private void before() {
        system.out.println("before");
    }

    private void after() {
        system.out.println("after");
    }

    @override
    public object invoke(object proxy, method method, object[] args) throws throwable {
        object res = null;
        before();
        try {
            res = method.invoke(target, args);
        } catch (throwable e) {
            throw e.getcause();
        }
        after();
        return res;
    }
    public static void main(string[] args) throws ioexception {
        try {
            sayhello sayhello = new sayhello();
            dynamicproxy dynamicproxy = new dynamicproxy(sayhello);
            hellointerface hellointerface = (hellointerface) proxy.newproxyinstance(thread.currentthread().getcontextclassloader(), sayhello.getclass().getinterfaces(), dynamicproxy);
            hellointerface.sayhello();
        } catch (throwable e) {
            e.printstacktrace();
        }
    }
}

 

从上面代码可以看出，对于cglib的动态代理而言，需要在原有代码中进行硬编码，且需要在对象初始化的时候，使用特定的方式进行初始化。因此若使用cglib完成mock，需要对应代码的的感知程度最高，达到了硬编码的程度。

2.2.2 aspectj

由于使用代理方式无法在不对代码进行修改的情况下完成mock，因此我们抛弃代理方式，考虑使用修改方法内部代码的方式进行mock。

基于这种思路，将目光转向了aspectj。

在使用aspectj时，需要定义方法执行前的函数以及方法执行后的函数：

@aspect
public class aspectjframe {
    private object before() {
        system.out.println("before");
        return new object();
    }

    private object after() {
        system.out.println("after");
        return new object();
    }

    @around("aroundpoint()")
    public object domock(proceedingjoinpoint joinpoint) {
        object object=null;
        before();
        try {
            object = joinpoint.proceed();
        } catch (throwable throwable) {
            throwable.printstacktrace();
        }
        after();
        return object;
    }
}

 

并通过aop.xml指定对应的切点以及对应的环绕函数

<aspectj>
    <aspects>
        <aspect name="com.test.framework.aspectjframe">
            <before method="" pointcut=""/>
        </aspect>
    </aspects>
</aspectj>

 

但是基于以上的实现方式，需要对原有项目进行一定侵入，主要包含两部分内容：

• 在meta-inf路径下增加aop.xml

• 引入对应的切面定义的jar包

通过aspectj可以完成在硬编码的情况下实现mock，但是这种实现方式受限于aspectj自身局限，mock的功能代码在编译期就已经添加到对应的函数中了，最晚可在运行时完成mock功能代码的添加。这种方式主要有两个缺点：

• 对于运行中的java进行无法在不重启的条件下执行新增mock

• mock功能代码嵌入到目标函数中，无法对mock功能代码进行卸载，可能带来稳定性风险

3、 java agent介绍

由于在上述提到的各种技术都难以很好的支持在对原有项目无任何修改下完成mock功能的需求，在查阅资料后，将目光放至了java agent技术。

3.1 什么是java agent？

java agent本质上可以理解为一个插件，该插件就是一个精心提供的jar包，这个jar包通过jvmti（jvm tool interface）完成加载，最终借助jplisagent（java programming language instrumentation services agent）完成对目标代码的修改。

java agent技术的主要功能如下：

• 可以在加载java文件之前做拦截把字节码做修改

• 可以在运行期将已经加载的类的字节码做变更

• 还有其他的一些小众的功能

  • 获取所有已经被加载过的类

  • 获取所有已经被初始化过了的类

  • 获取某个对象的大小

  • 将某个jar加入到bootstrapclasspath里作为高优先级被bootstrapclassloader加载

  • 将某个jar加入到classpath里供appclassloard去加载

  • 设置某些native方法的前缀，主要在查找native方法的时候做规则匹配

3.2 java instrumentation api

通过java agent技术进行类的字节码修改最主要使用的就是java instrumentation api。下面将介绍如何使用java instrumentation api进行字节码修改。

3.2.1 实现agent启动方法

java agent支持目标jvm启动时加载，也支持在目标jvm运行时加载，这两种不同的加载模式会使用不同的入口函数，如果需要在目标jvm启动的同时加载agent，那么可以选择实现下面的方法：

[1] public static void premain(string agentargs, instrumentation inst); 
[2] public static void premain(string agentargs);

jvm将首先寻找[1]，如果没有发现[1]，再寻找[2]。如果希望在目标jvm运行时加载agent，则需要实现下面的方法：

[1] public static void agentmain(string agentargs, instrumentation inst); 
[2] public static void agentmain(string agentargs);

这两组方法的第一个参数agentargs是随同 “–javaagent”一起传入的程序参数，如果这个字符串代表了多个参数，就需要自己解析这些参数。inst是instrumentation类型的对象，是jvm自动传入的，我们可以拿这个参数进行类增强等操作。

3.2.2 指定main-class

agent需要打包成一个jar包，在manifest属性中指定“premain-class”或者“agent-class”,且需根据需求定义can-redefine-classes和can-retransform-classes：

manifest-version: 1.0
premain-class: com.test.agentclass
archiver-version: plexus archiver
agent-class: com.test.agentclass
can-redefine-classes: true
can-retransform-classes: true
created-by: apache maven 3.3.9
build-jdk: 1.8.0_112

3.2.3 agent加载

• 启动时加载

  • 启动参数增加-javaagent:[path]，其中path为对应的agent的jar包路径

• 运行中加载

  • 使用com.sun.tools.attach.virtualmachine加载

try {
  string jvmpid = 目标进行的pid;
  logger.info("attaching to target jvm with pid: " + jvmpid);
  virtualmachine jvm = virtualmachine.attach(jvmpid);
  jvm.loadagent(agentfilepath);//agentfilepath为agent的路径
  jvm.detach();
  logger.info("attached to target jvm and loaded java agent successfully");
} catch (exception e) {
  throw new runtimeexception(e);
}

 

3.2.4 instrument

instrument是jvm提供的一个可以修改已加载类的类库，专门为java语言编写的插桩服务提供支持。它需要依赖jvmti的attach api机制实现。在jdk 1.6以前，instrument只能在jvm刚启动开始加载类时生效，而在jdk 1.6之后，instrument支持了在运行时对类定义的修改。要使用instrument的类修改功能，我们需要实现它提供的classfiletransformer接口，定义一个类文件转换器。接口中的transform()方法会在类文件被加载时调用，而在transform方法里，我们可以利用上文中的asm或javassist对传入的字节码进行改写或替换，生成新的字节码数组后返回。

首先可以定义如下的类转换器：

public class testtransformer implements classfiletransformer {
      //目标类名称，  .分隔
      private string targetclassname;
    //目标类名称，  /分隔
    private string targetvmclassname;
    private string targetmethodname;
    

    public testtransformer(string classname,string methodname){
        this.targetvmclassname = new string(classname).replaceall("\\.","\\/");
        this.targetmethodname = methodname;
        this.targetclassname=classname;
    }
    //类加载时会执行该函数，其中参数 classfilebuffer为类原始字节码，返回值为目标字节码，classname为/分隔
    public byte[] transform(classloader loader, string classname, class<?> classbeingredefined, protectiondomain protectiondomain, byte[] classfilebuffer) throws illegalclassformatexception {
          //判断类名是否为目标类名
        if(!classname.equals(targetvmclassname)){
            return classfilebuffer;
        }
        try {
            classpool classpool = classpool.getdefault();
            ctclass cls = classpool.get(this.targetclassname);
            ctmethod ctmethod = cls.getdeclaredmethod(this.targetmethodname);
            ctmethod.insertbefore("{ system.out.println(\"start\"); }");
            ctmethod.insertafter("{ system.out.println(\"end\"); }");
            return cls.tobytecode();
        } catch (exception e) {

        }
        return classfilebuffer;
    }
}

 

类转换器定义完毕后，需要将定义好的类转换器添加到对应的instrmentation中，对于已经加载过的类使用retransformclasses对类进行重新加载：

public class agentdemo {

    private static string classname = "hello.greetingcontroller";
    private static string methodname = "getdomain";

    public static void agentmain(string args, instrumentation instrumentation) {

        try {
            list<class> needretransformclasses = new linkedlist<>();
            class[] loadedclass = instrumentation.getallloadedclasses();
            for (int i = 0; i < loadedclass.length; i++) {
                if (loadedclass[i].getname().equals(classname)) {
                    needretransformclasses.add(loadedclass[i]);
                }
            }

            instrumentation.addtransformer(new testtransformer(classname, methodname));
            instrumentation.retransformclasses(needretransformclasses.toarray(new class[0]));
        } catch (exception e) {

        }
    }

    public static void premain(string args, instrumentation instrumentation) {
        instrumentation.addtransformer(new testtransformer(classname, methodname));
    }


}

 

从上图的代码可以看出，主方法实现了两个，分别为agentmain和premain，其中

• premain

  • 用于在启动时，类加载前定义类的transformer，在类加载的时候更新对应的类的字节码

• agentmain

  • 用于在运行时进行类的字节码的修改，步骤整体分为两步

    • 注册类的transformer

    • 调用retransformclasses函数进行类的重加载

4、java agent原理简述

4.1 启动时修改

 

 

启动时修改主要是在jvm启动时，执行native函数的agent_onload方法，在方法执行时，执行如下步骤：

• 创建instrumentationimpl对象

• 监听classfileloadhook事件

• 调用instrumentationimpl的loadclassandcallpremain方法，在这个方法里会去调用javaagent里manifest.mf里指定的premain-class类的premain方法

4.2 运行时修改

 

 

运行时修改主要是通过jvm的attach机制来请求目标jvm加载对应的agent，执行native函数的agent_onattach方法，在方法执行时，执行如下步骤：

• 创建instrumentationimpl对象

• 监听classfileloadhook事件

• 调用instrumentationimpl的loadclassandcallagentmain方法，在这个方法里会去调用javaagent里manifest.mf里指定的agentmain-class类的agentmain方法

4.3 classfileloadhook和transformclassfile

在4.1和4.2节中，可以看出整体流程中有两个部分是具有共性的，分别为：

• classfileloadhook

• tranformclassfile

classfileloadhook是一个jvmti事件，该事件是instrument agent的一个核心事件，主要是在读取字节码文件回调时调用，内部调用了transformclassfile函数。

transformclassfile的主要作用是调用java.lang.instrument.classfiletransformer的tranform方法，该方法由开发者实现，通过instrument的addtransformer方法进行注册。

通过以上描述可以看出在字节码文件加载的时候，会触发classfileloadhook事件，该事件调用transformclassfile，通过经由instrument的addtransformer注册的方法完成整体的字节码修改。

对于已加载的类，需要调用retransformclass函数，然后经由redefineclasses函数，在读取已加载的字节码文件后，若该字节码文件对应的类关注了classfileloadhook事件，则调用classfileloadhook事件。后续流程与类加载时字节码替换一致。

4.4 何时进行运行时替换？

在类加载完毕后，对应的想要替换函数可能正在执行，那么何时进行类字节码的替换呢？

由于运行时类字节码替换依赖于redefineclasses，那么可以看一下该方法的定义：

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 */

其中整体的执行依赖于vmthread，vmthread是一个在虚拟机创建时生成的单例原生线程，这个线程能派生出其他线程。同时，这个线程的主要的作用是维护一个vm操作队列(vmoperationqueue)，用于处理其他线程提交的vm operation，比如执行gc等。

vmthread在执行一个vm操作时，先判断这个操作是否需要在safepoint下执行。若需要safepoint下执行且当前系统不在safepoint下，则调用safepointsynchronize的方法驱使所有线程进入safepoint中，再执行vm操作。执行完后再唤醒所有线程。若此操作不需要在safepoint下，或者当前系统已经在safepoint下，则可以直接执行该操作了。所以，在safepoint的vm操作下，只有vm线程可以执行具体的逻辑，其他线程都要进入safepoint下并被挂起，直到完成此次操作。

因此，在执行字节码替换的时候需要在safepoint下执行，因此整体会触发stop-the-world。

99、参考文档