基础准备

现在，我们需要一个程序入口，随时挂接具体的java应用和刚刚开发的agent。
首先，我们考虑java自身提供的功能：监控能力，主要包在 sun.jvmstat下，可以拿到当时正在运行的所有java进程，如此便可以让系统自动找到我们的测试java应用，避免每次去查看系统的进程号。
其次，我们考虑怎么动态的加载agent，目前来说最好的方式有两种，一个是自己引用tools.jar，使用类
com.sun.tools.attach.VirtualMachine加载，另外一种，就是借助第三方工具类，比如bytebuddy，目前我们先采用方式一，后面我们会详细讲解方式二。

  1. <?xml version="1.0" encoding="UTF-8"?>
  3. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.   <parent>
  6.     <artifactId>jvm_sandbox_demo</artifactId>
  7.     <groupId>com.deer</groupId>
  8.     <version>1.0-SNAPSHOT</version>
  9.     <relativePath>../pom.xml</relativePath>
  10.   </parent>
  11.   <modelVersion>4.0.0</modelVersion>
  13.   <groupId>com.deer.agent.starter</groupId>
  14.   <artifactId>jvm_sandbox_agent_starter</artifactId>
  15.   <name>jvm_sandbox_agent_starter</name>
  18.   <properties>
  19.     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  20.     <maven.compiler.source>1.8</maven.compiler.source>
  21.     <maven.compiler.target>1.8</maven.compiler.target>
  22.   </properties>
  23.   <dependencies>
  24.     <dependency>
  25.       <groupId>com.sun</groupId>
  26.       <artifactId>tools</artifactId>
  27.       <version>1.8</version>
  28.       <scope>system</scope>
  29.       <systemPath>/Users/yudongwei/Library/Java/JavaVirtualMachines/corretto-1.8.0_322/Contents/Home/lib/tools.jar</systemPath>
  30.     </dependency>
  32.   </dependencies>
  35. </project>
  1. package com.deer.agent.starter;
  3. import com.sun.tools.attach.VirtualMachine;
  4. import sun.jvmstat.monitor.*;
  6. import java.net.URISyntaxException;
  7. import java.util.HashSet;
  8. import java.util.Set;
  10. public class AgentStarter {
  11.     public static void main(String[] args) throws URISyntaxException, MonitorException {
  12.         String processId = null;
  13.         // 获取监控主机
  14.         MonitoredHost local = MonitoredHost.getMonitoredHost("localhost");
  15.         // 取得所有在活动的虚拟机集合
  16.         Set<Integer> vmlist = new HashSet<Integer>(local.activeVms());
  17.         // 遍历集合，找到我们系统启动需要挂载的PID和进程名
  18.         for(Integer process : vmlist) {
  19.             MonitoredVm vm = local.getMonitoredVm(new VmIdentifier("//" + process));
  20.             // 获取类名
  21.             String processName = MonitoredVmUtil.mainClass(vm, true);
  22.             if(processName.equals("com.deer.base.BaseApp")){
  23.                 processId = process.toString();
  24.                 break;
  25.             }
  26.         }
  27.         if(processId == null){
  28.             return;
  29.         }
  30.         System.out.println("find processId ,and ready to attach..."+processId);
  31.         String agentPath="/Users/yudongwei/IdeaProjects/jvm_sandbox_demo/jvm_sandbox_agent/target/jvm_sandbox_agent-1.0-SNAPSHOT-jar-with-dependencies.jar";
  32.         try {
  33.             VirtualMachine vm = VirtualMachine.attach(processId);
  34.             vm.loadAgent(agentPath);
  35.         }catch (Exception e){
  36.             e.printStackTrace();
  37.         }
  38.     }
  39. }

测试效果

启动 spring 应用：com.deer.base.BaseApp
打包agent
启动入口：com.deer.agent.starter.AgentStarter

基础测试

image.png
image.png
此时，我们看到动态加载的方法执行了

功能测试

我们用浏览器访问

  1. http://localhost:9090/sayHi/zhangfei

image.png

新的问题

此时我们发现，自己定义的类有一个被agent访问到了（com.deer.base.service.BaseService），另外一个没有被agent访问到（com.deer.base.service.impl.HelloServiceImpl）
是我们代码写错了，还是另有玄机？
是不是因为spring的bean使用java代理，此时类名已经不匹配了？
这些都会随着接下来的课程一步一步抽丝剥茧解决。