精华内容
下载资源
问答
  • 基于javaagent监控方法执行耗时

    千次阅读 2019-10-24 10:01:55
    开发者通过这种机制(Instrumentation)可以在加载class文件之前修改方法的字节码(此时字节码尚未加入JVM),动态更改类方法实现AOP,提供监控服务如;方法调用时长、可用率、内存等。 开发简述 通过实现...

    动态代理实现原理.png

    背景描述
    javaagent是在JDK5之后提供的新特性,也可以叫java代理。开发者通过这种机制(Instrumentation)可以在加载class文件之前修改方法的字节码(此时字节码尚未加入JVM),动态更改类方法实现AOP,提供监控服务如;方法调用时长、可用率、内存等。

    开发简述
    通过实现ClassFileTransformer接口方法,动态更改方法的字节码。在方法前后加上时间戳,最后执行完成输出执行时长。

    环境准备
    1、IntelliJ IDEA Community Edition 2018.3.1 x64
    2、jdk1.8 64位

    配置信息(路径相关修改为自己的)
    1、java调试时配置
    2.1、配置位置:Run/Debug Configurations ->VM options
    2.2、配置内容(编译后的jar放到根目录下):-javaagent:E:\itstack-demo-javaagent-1.0-SNAPSHOT.jar=agentargs

    代码示例

    itstack-demo-javaagent
    ├── pom.xml
    └── src
        └── main
            ├── java
            │   └── org.itstack.demo.agent
    		│        ├── MyAgent.java
    		│        └── MyTransformer.java
            ├── resources
            │    ├── META-INF
            │    │   └── MANIFEST.MF
            │    └── log4j2.xml
    		└── test
    		     └── java
    			     └── org.itstack.demo.test
    				     └── AgentTest.java
    			  
    

    pom.xml

    <?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
    
        <groupId>com.jd.jr.test</groupId>
        <artifactId>baitiao-test-javaagent</artifactId>
        <version>1.0-SNAPSHOT</version>
    
        <name>test-javaagent</name>
        <description>test-javaagent</description>
    
        <properties>
            <!-- Build args -->
            <argline>-Xms512m -Xmx512m</argline>
            <skip_maven_deploy>false</skip_maven_deploy>
            <updateReleaseInfo>true</updateReleaseInfo>
            <project.build.sourceEncoding>utf-8</project.build.sourceEncoding>
            <maven.test.skip>true</maven.test.skip>
            <maven.configuration.manifestFile>src/main/resources/META-INF/MANIFEST.MF</maven.configuration.manifestFile>
        </properties>
    
        <dependencies>
            <dependency>
                <groupId>org.javassist</groupId>
                <artifactId>javassist</artifactId>
                <version>3.22.0-GA</version>
            </dependency>
        </dependencies>
    
        <build>
            <sourceDirectory>src/main/java</sourceDirectory>
            <resources>
                <resource>
                    <directory>src/main/resources</directory>
                    <filtering>true</filtering>
                    <includes>
                        <include>**/**</include>
                    </includes>
                </resource>
            </resources>
            <testSourceDirectory>src/test/java</testSourceDirectory>
            <testResources>
                <testResource>
                    <directory>src/test/resources</directory>
                    <filtering>true</filtering>
                    <includes>
                        <include>**/**</include>
                    </includes>
                </testResource>
            </testResources>
            <plugins>
                <plugin>
                    <groupId>org.apache.maven.plugins</groupId>
                    <artifactId>maven-jar-plugin</artifactId>
                    <version>2.4</version>
                    <configuration>
                        <archive>
                            <manifestFile>${maven.configuration.manifestFile}</manifestFile>
                        </archive>
                    </configuration>
                </plugin>
                <plugin>
                    <groupId>org.apache.maven.plugins</groupId>
                    <artifactId>maven-resources-plugin</artifactId>
                    <version>2.5</version>
                    <configuration>
                        <encoding>${project.build.sourceEncoding}</encoding>
                    </configuration>
                </plugin>
                <plugin>
                    <groupId>org.apache.maven.plugins</groupId>
                    <artifactId>maven-compiler-plugin</artifactId>
                    <version>2.3.2</version>
                    <configuration>
                        <source>1.6</source>
                        <target>1.6</target>
                        <encoding>${project.build.sourceEncoding}</encoding>
                    </configuration>
                </plugin>
                <plugin>
                    <groupId>org.apache.maven.plugins</groupId>
                    <artifactId>maven-source-plugin</artifactId>
                    <version>2.1.2</version>
                    <executions>
                        <execution>
                            <id>attach-sources</id>
                            <goals>
                                <goal>jar</goal>
                            </goals>
                        </execution>
                    </executions>
                </plugin>
            </plugins>
        </build>
    
        <profiles>
            <profile>
                <id>production</id>
                <activation>
                    <activeByDefault>true</activeByDefault>
                    <jdk>1.6</jdk>
                </activation>
                <properties>
                    <maven.compiler.source>1.6</maven.compiler.source>
                    <maven.compiler.target>1.6</maven.compiler.target>
                    <maven.compiler.compilerVersion>1.6</maven.compiler.compilerVersion>
                </properties>
            </profile>
        </profiles>
    </project>
    

    MyAgent.java

    package org.itstack.demo.agent;
    
    import java.lang.instrument.Instrumentation;
    
    public class MyAgent {
    
        //JVM 首先尝试在代理类上调用以下方法
        public static void premain(String agentArgs, Instrumentation inst) {
            inst.addTransformer(new MyTransformer());
        }
    
        //如果代理类没有实现上面的方法,那么 JVM 将尝试调用该方法
        public static void premain(String agentArgs) {
        }
    
    }
    

    MyTransformer.java

    package org.itstack.demo.agent;
    
    import javassist.ClassPool;
    import javassist.CtClass;
    import javassist.CtMethod;
    import javassist.CtNewMethod;
    
    import java.lang.instrument.ClassFileTransformer;
    import java.lang.instrument.IllegalClassFormatException;
    import java.security.ProtectionDomain;
    import java.util.ArrayList;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    
    public class MyTransformer implements ClassFileTransformer {
    
        private final static String prefix = "\nlong startTime = System.currentTimeMillis();\n";
        private final static String postfix = "\nlong endTime = System.currentTimeMillis();\n";
    
        // 被处理的方法列表
        private final static Map<String, List<String>> methodMap = new HashMap<String, List<String>>();
    
        public MyTransformer() {
            //对指定方法监控
            add("org.itstack.demo.test.AgentTest.queryUserAge");
            add("org.itstack.demo.test.AgentTest.queryUserName");
        }
    
        private void add(String methodString) {
            String className = methodString.substring(0, methodString.lastIndexOf("."));
            String methodName = methodString.substring(methodString.lastIndexOf(".") + 1);
            List<String> list = methodMap.get(className);
            if (list == null) {
                list = new ArrayList<String>();
                methodMap.put(className, list);
            }
            list.add(methodName);
        }
    
        @Override
        public byte[] transform(ClassLoader loader, String className, Class<?> classBeingRedefined,
                                ProtectionDomain protectionDomain, byte[] classfileBuffer) throws IllegalClassFormatException {
            className = className.replace("/", ".");
            // 判断加载的class的包路径是不是需要监控的类
            if (methodMap.containsKey(className)) {
                CtClass ctclass = null;
                try {
                    ctclass = ClassPool.getDefault().get(className);// 使用全称,用于取得字节码类<使用javassist>
                    for (String methodName : methodMap.get(className)) {
                        String outputStr = "\nSystem.out.println(\"监控信息(执行耗时):" + className + "." + methodName + " => \" +(endTime - startTime) +\"毫秒\");";
                        CtMethod ctmethod = ctclass.getDeclaredMethod(methodName);// 得到这方法实例
                        String newMethodName = methodName + "$new";// 新定义一个方法叫做比如queryUserAge$new
                        ctmethod.setName(newMethodName);// 将原来的方法名字修改
                        // 创建新的方法,复制原来的方法,名字为原来的名字
                        CtMethod newMethod = CtNewMethod.copy(ctmethod, methodName, ctclass, null);
                        // 构建新的方法体
                        StringBuilder methodBodyStr = new StringBuilder();
                        methodBodyStr.append("{");
                        methodBodyStr.append(prefix);
                        methodBodyStr.append(newMethodName + "($$);\n");// 调用原有代码,类似于method();($$)表示所有的参数
                        methodBodyStr.append(postfix);
                        methodBodyStr.append(outputStr);
                        methodBodyStr.append("}");
                        newMethod.setBody(methodBodyStr.toString());// 替换新方法
                        ctclass.addMethod(newMethod);         // 增加新方法
                    }
                    return ctclass.toBytecode();
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
            return null;
        }
    }
    

    MANIFEST.MF

    Manifest-Version: 1.0
    Premain-Class: org.itstack.demo.agent.MyAgent
    Can-Redefine-Classes: true
    
    

    AgentTest.java

    package org.itstack.demo.test;
    
    import java.util.logging.Logger;
    
    /**
     * vm options = -javaagent:E:\itstack-demo-javaagent-1.0-SNAPSHOT.jar=agentargs
     */
    public class AgentTest {
    
        private static Logger logger = Logger.getLogger("AgentTest");
    
        public static void main(String[] args) {
            String userId = "100001";
            queryUserAge(userId);
            queryUserName(userId);
        }
    
        private static void queryUserAge(String userId) {
            try {
                Thread.sleep(300);
                logger.info("hello userId:" + userId +" age 18");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    
        private static void queryUserName(String userId) {
            try {
                Thread.sleep(100);
                logger.info("hello userId:" + userId +" name agent");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    
    }
    

    测试结果

    2019-4-17 11:34:33 org.itstack.demo.test.AgentTest queryUserAge$new
    信息: hello userId:100001 age 18
    监控信息(执行耗时):org.itstack.demo.test.AgentTest.queryUserAge => 316毫秒
    2019-4-17 11:34:33 org.itstack.demo.test.AgentTest queryUserName$new
    信息: hello userId:100001 name agent
    监控信息(执行耗时):org.itstack.demo.test.AgentTest.queryUserName => 100毫秒
    

    微信公众号:bugstack虫洞栈,欢迎您的关注&获取源码!

    展开全文
  • Java性能耗时监控工具

    2020-11-18 23:44:44
    Java性能耗时监控工具(基于Spring的StopWatch监控工具) 特点 改编自Spring的StopWatch,功能增强,原理不变 代码实现简单,使用更简单 支持Slf4j日志打印,可使用Log4j,Logback等日志库 统一归纳,展示每项任务...

    Java性能耗时监控工具(基于Spring的StopWatch监控工具)

    特点

    • 改编自Spring的StopWatch,功能增强,原理不变
    • 代码实现简单,使用更简单
    • 支持Slf4j日志打印,可使用Log4j,Logback等日志库
    • 统一归纳,展示每项任务耗时与占用总时间的百分比,展示结果直观
    • 性能消耗相对较小,并且最大程度的保证了start与stop之间的时间记录的准确性
    • 可在start时直接指定任务名字,从而更加直观的显示记录结果
    • 支持嵌套,可在一个任务中监控另一个任务
    • 单独发布jar,不需要依赖spring相关的jar

    使用实例

    • 添加依赖

    已发布到jitpack,可直接使用

    allprojects {
        repositories {
            mavenCentral()
            maven {
                url "https://jitpack.io"
            }
        }
    }
    
    dependencies {
        implementation 'com.github.virtuex:time_watcher:1.0'
        implementation("org.slf4j:slf4j-log4j12:1.6.6")
        implementation("org.slf4j:slf4j-api:1.7.26")
    }
    
    
    • 测试代码
    
    public class LogingStopWatchTest {
        private static Logger logger = LoggerFactory.getLogger(LogingStopWatchTest.class);
    
        public static void main(String[] args) {
            initWatch("ROOT");
            startWatch("TEST");
            startWatch("TEST2-1");
            try {
                Thread.sleep(3000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            stopWatch();
            startWatch("TEST2-2");
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            stopWatch();
            stopWatch();
            outAndReleaseWatch();
        }
    
    
        /**
         * 开始监控任务,与stopWatch成对出现
         */
        protected static void startWatch(String taskName) {
            if (logger.isDebugEnabled()) {
                StopWatchContext.startWatch(taskName, -1);
            }
        }
    
        /**
         * 结束监控任务,与startWatch成对出现
         */
        protected static void stopWatch() {
            if (logger.isDebugEnabled()) {
                StopWatchContext.stopWatch();
            }
        }
    
        /**
         * 初始化监控
         */
        private static void initWatch(String watchName) {
            if (logger.isDebugEnabled()) {
                StopWatch stopWatch = new Slf4jStopWatch(watchName, true, -1);
                StopWatchContext.setCurrentStopWatch(new StopWatchPack(stopWatch));
                // 开始根任务
                startWatch("--");
            }
        }
    
    
        /**
         * 始放监控资源
         */
        private static void outAndReleaseWatch() {
            if (logger.isDebugEnabled()) {
                // 结束根任务
                stopWatch();
                // 打印详细
                StopWatchContext.prettyPrint();
                StopWatchContext.releaseStopWatch();
            }
        }
    }
    
    • 运行结果

    运行结果中很直观的展示了任务耗时,及其子任务所占的百分比

    2020-11-18 23:31:16 [DEBUG] slf4j.Slf4jStopWatch (log:49) -   
    Task Name 'ROOT': Running Time = 4s 1ms 
      -----------------------------------------
      time        %     Task name
      -----------------------------------------
      4s 1ms   100%  --
        Task Name 'TEST': Running Time = 4s 1ms 
        -----------------------------------------
        time        %     Task name
        -----------------------------------------
        4s 1ms   100%  TEST
          Task Name 'TEST2-1': Running Time = 4s 1ms 
          -----------------------------------------
          time        %     Task name
          -----------------------------------------
          3s   075%  TEST2-1
          1s 1ms   025%  TEST2-2
    

    Github地址

    展开全文
  • 基于JavaAgent的全链路监控&...基于JavaAgent的全链路监控二《通过字节码增加监控执行耗时》 基于JavaAgent的全链路监控三《ByteBuddy操作监控方法字节码》 基于JavaAgent的全链路监控四《JVM内存与GC信息》 基于Ja...

    章节列表 | 关注微信公众号,bugstack虫洞栈,回复<基于JavaAgent的全链路监控>获取源码

    案例简述
    通过上一章节的介绍《嗨!JavaAgent》,我们已经知道通过配置-javaagent:文件.jar后,在java程序启动时候会执行premain方法。接下来我们使用javassist字节码增强的方式,来监控方法程序的执行耗时。

    Javassist是一个开源的分析、编辑和创建Java字节码的类库。是由东京工业大学的数学和计算机科学系的 Shigeru Chiba (千叶 滋)所创建的。它已加入了开放源代码JBoss应用服务器项目,通过使用Javassist对字节码操作为JBoss实现动态"AOP"框架。

    关于java字节码的处理,目前有很多工具,如bcel,asm。不过这些都需要直接跟虚拟机指令打交道。如果你不想了解虚拟机指令,可以采用javassist。javassist是jboss的一个子项目,其主要的优点,在于简单,而且快速。直接使用java编码的形式,而不需要了解虚拟机指令,就能动态改变类的结构,或者动态生成类。

    环境准备
    1、IntelliJ IDEA Community Edition
    2、jdk1.8.0_45 64位

    配置信息(路径相关修改为自己的)
    1、配置位置:Run/Debug Configurations -> VM options
    2、配置内容:-javaagent:E:\itstack\GIT\itstack.org\itstack-demo-agent\itstack-demo-agent-02\target\itstack-demo-agent-02-1.0.0-SNAPSHOT.jar=testargs

    代码示例

    itstack-demo-agent-02
    ├── pom.xml
    └── src
        ├── main
        │   ├── java
        │   │   └── org.itstack.demo.agent
        │   │       ├── MyAgent.java
        │   │	    └── MyMonitorTransformer.java
        │	└── resources
        │       └── META-INF
        │           └── MANIFEST.MF 	
        └── test
             └── java
                 └── org.itstack.demo.test
                     └── ApiTest.java
    

    pom.xml (引入javassist并打入到Agent包中)

     <properties>
            <!-- Build args -->
    	<argline>-Xms512m -Xmx512m</argline>
    	<skip_maven_deploy>false</skip_maven_deploy>
    	<updateReleaseInfo>true</updateReleaseInfo>
    	<project.build.sourceEncoding>utf-8</project.build.sourceEncoding>
    	<maven.test.skip>true</maven.test.skip>
    	<!-- 自定义MANIFEST.MF -->
    	<maven.configuration.manifestFile>src/main/resources/META-INF/MANIFEST.MF</maven.configuration.manifestFile>
    </properties>
    
    <dependencies>
    	<dependency>
    		<groupId>javassist</groupId>
    		<artifactId>javassist</artifactId>
    		<version>3.12.1.GA</version>
    		<type>jar</type>
    	</dependency>
    </dependencies>
    
    <!-- 将javassist包打包到Agent中 -->
    <plugin>
    	<groupId>org.apache.maven.plugins</groupId>
    	<artifactId>maven-shade-plugin</artifactId>
    	<executions>
    		<execution>
    			<phase>package</phase>
    			<goals>
    				<goal>shade</goal>
    			</goals>
    		</execution>
    	</executions>
    	<configuration>
    		<artifactSet>
    			<includes>
    				<include>javassist:javassist:jar:</include>
    			</includes>
    		</artifactSet>
    	</configuration>
    </plugin>            
    

    MyAgent.java

    /**
     * 博客:http://itstack.org
     * 论坛:http://bugstack.cn
     * 公众号:bugstack虫洞栈  {获取学习源码}
     * create by fuzhengwei on 2019
     */
    public class MyAgent {
    
        //JVM 首先尝试在代理类上调用以下方法
        public static void premain(String agentArgs, Instrumentation inst) {
            System.out.println("this is my agent:" + agentArgs);
            MyMonitorTransformer monitor = new MyMonitorTransformer();
            inst.addTransformer(monitor);
        }
    
        //如果代理类没有实现上面的方法,那么 JVM 将尝试调用该方法
        public static void premain(String agentArgs) {
        }
    
    }
    

    MyMonitorTransformer.java

    /**
     * 博客:http://itstack.org
     * 论坛:http://bugstack.cn
     * 公众号:bugstack虫洞栈  {获取学习源码}
     * create by fuzhengwei on 2019
     */
    public class MyMonitorTransformer implements ClassFileTransformer {
    
        private static final Set<String> classNameSet = new HashSet<>();
    
        static {
            classNameSet.add("org.itstack.demo.test.ApiTest");
        }
    
        @Override
        public byte[] transform(ClassLoader loader, String className, Class<?> classBeingRedefined, ProtectionDomain protectionDomain, byte[] classfileBuffer) {
            try {
                String currentClassName = className.replaceAll("/", ".");
                if (!classNameSet.contains(currentClassName)) { // 提升classNameSet中含有的类
                    return null;
                }
                System.out.println("transform: [" + currentClassName + "]");
    
                CtClass ctClass = ClassPool.getDefault().get(currentClassName);
                CtBehavior[] methods = ctClass.getDeclaredBehaviors();
                for (CtBehavior method : methods) {
                    enhanceMethod(method);
                }
                return ctClass.toBytecode();
            } catch (Exception e) {
                e.printStackTrace();
            }
            
            return null;
    
        }
    
    
        private void enhanceMethod(CtBehavior method) throws Exception {
            if (method.isEmpty()) {
                return;
            }
            String methodName = method.getName();
            if ("main".equalsIgnoreCase(methodName)) {
                return;
            }
    
            final StringBuilder source = new StringBuilder();
            // 前置增强: 打入时间戳
            // 保留原有的代码处理逻辑
            source.append("{")
                    .append("long start = System.nanoTime();\n") //前置增强: 打入时间戳
                    .append("$_ = $proceed($$);\n")              //调用原有代码,类似于method();($$)表示所有的参数
                    .append("System.out.print(\"method:[")
                    .append(methodName).append("]\");").append("\n")
                    .append("System.out.println(\" cost:[\" +(System.nanoTime() - start)+ \"ns]\");") // 后置增强,计算输出方法执行耗时
                    .append("}");
    
            ExprEditor editor = new ExprEditor() {
                @Override
                public void edit(MethodCall methodCall) throws CannotCompileException {
                    methodCall.replace(source.toString());
                }
            };
            method.instrument(editor);
        }
    
    }
    

    MANIFEST.MF

    Manifest-Version: 1.0
    Premain-Class: org.itstack.demo.agent.MyAgent
    Can-Redefine-Classes: true
    

    ApiTest.java

    /**
     * 博客:http://itstack.org
     * 论坛:http://bugstack.cn
     * 公众号:bugstack虫洞栈  {获取学习源码}
     * create by fuzhengwei on 2019
     *
     * VM options:
     * -javaagent:E:\itstack\GIT\itstack.org\itstack-demo-agent\itstack-demo-agent-02\target\itstack-demo-agent-02-1.0.0-SNAPSHOT.jar=testargs
     *
     */
    public class ApiTest {
    
        public static void main(String[] args) {
            ApiTest apiTest = new ApiTest();
            apiTest.echoHi();
        }
    
        private void echoHi(){
            System.out.println("hi agent");
        }
    
    }
    

    测试结果

    this is my agent:testargs
    transform: [org.itstack.demo.test.ApiTest]
    hi agent
    method:[echoHi] cost:[294845ns]
    

    关注{bugstack虫洞栈}公众号获取源码

    关注{bugstack虫洞栈}公众号获取源码

    展开全文
  • 平常在统计方法执行的耗时时长时,一般都是在方法的开头和结尾通过System.currentTimeMillis()拿到时间,然后做差值,计算耗时,这样不得不在每个方法中都重复这样的操作,现在使用Instrument,可以优雅的实现该功能...

    平常在统计方法执行的耗时时长时,一般都是在方法的开头和结尾通过System.currentTimeMillis()拿到时间,然后做差值,计算耗时,这样不得不在每个方法中都重复这样的操作,现在使用Instrument,可以优雅的实现该功能。

    一、编写Agent类

    package com.jdktest.instrument;
    
    import java.lang.instrument.ClassFileTransformer;
    import java.lang.instrument.Instrumentation;
    
    public class AopAgentTest {
        static private Instrumentation _inst = null;  
        /** 
         * The agent class must implement a public static premain method similar in principle to the main application entry point. 
         * After the Java Virtual Machine (JVM) has initialized, 
         * each premain method will be called in the order the agents were specified, 
         * then the real application main method will be called.
         **/  
        public static void premain(String agentArgs, Instrumentation inst) {  
            System.out.println("AopAgentTest.premain() was called.");  
    
            /* Provides services that allow Java programming language agents to instrument programs running on the JVM.*/  
            _inst = inst; 
    
            /* ClassFileTransformer : An agent provides an implementation of this interface in order to transform class files.*/  
            ClassFileTransformer trans = new AopAgentTransformer(); 
    
            System.out.println("Adding a AopAgentTest instance to the JVM.");  
    
            /*Registers the supplied transformer.*/
            _inst.addTransformer(trans);  
        }  
    }

    代码功能详见注释。

    二、编写ClassFileTransformer

    ClassFileTransformer需要实现transform方法,根据自己的功能需要修改class字节码,在修改字节码过程中需要借助javassist进行字节码编辑。

    javassist是一个开源的分析、编辑和创建java字节码的类库。通过使用javassist对字节码操作可以实现动态”AOP”框架。

    关于java字节码的处理,目前有很多工具,如bcel,asm(cglib只是对asm又封装了一层)。不过这些都需要直接跟虚拟机指令打交道。javassist的主要的优点,在于简单,而且快速,直接使用java编码的形式,而不需要了解虚拟机指令,就能动态改变类的结构,或者动态生成类。

    package com.jdktest.instrument;
    
    import java.lang.instrument.ClassFileTransformer;
    import java.lang.instrument.IllegalClassFormatException;
    import java.security.ProtectionDomain;
    
    import javassist.CannotCompileException;
    import javassist.ClassPool;
    import javassist.CodeConverter;
    import javassist.CtClass;
    import javassist.CtMethod;
    import javassist.NotFoundException;
    import javassist.expr.ExprEditor;
    import javassist.expr.MethodCall;
    
    public class AopAgentTransformer implements ClassFileTransformer{
    
        public byte[] transform(ClassLoader loader, String className,
                Class<?> classBeingRedefined, ProtectionDomain protectionDomain,
                byte[] classfileBuffer) throws IllegalClassFormatException {
            byte[] transformed = null;  
            System.out.println("Transforming " + className);  
            ClassPool pool = null;  
            CtClass cl = null;  
            try {  
                pool = ClassPool.getDefault();
    
                cl = pool.makeClass(new java.io.ByteArrayInputStream(  
                        classfileBuffer));  
    
    //            CtMethod aop_method = pool.get("com.jdktest.instrument.AopMethods").
    //                    getDeclaredMethod("aopMethod");
    //            System.out.println(aop_method.getLongName());
    
                CodeConverter convert = new CodeConverter();
    
                if (cl.isInterface() == false) {  
                    CtMethod[] methods = cl.getDeclaredMethods();  
                    for (int i = 0; i < methods.length; i++) {  
                        if (methods[i].isEmpty() == false) {  
                            AOPInsertMethod(methods[i]);  
                        }  
                    }  
                    transformed = cl.toBytecode();  
                }  
            } catch (Exception e) {  
                System.err.println("Could not instrument  " + className  
                        + ",  exception : " + e.getMessage());  
            } finally {  
                if (cl != null) {  
                    cl.detach();  
                }  
            }  
            return transformed;  
        }
    
        private void AOPInsertMethod(CtMethod method) throws NotFoundException,CannotCompileException {
            //situation 1:添加监控时间
            method.instrument(new ExprEditor() {  
                public void edit(MethodCall m) throws CannotCompileException {  
                    m.replace("{ long stime = System.currentTimeMillis(); $_ = $proceed($$);System.out.println(\""
                            + m.getClassName() + "." + m.getMethodName()
                            + " cost:\" + (System.currentTimeMillis() - stime) + \" ms\");}");
                }
            }); 
            //situation 2:在方法体前后语句
    //      method.insertBefore("System.out.println(\"enter method\");");
    //      method.insertAfter("System.out.println(\"leave method\");");
        }
    
    }

    三、打包Agent jar包

    因为agent依赖javassist,在build时需要加入<Boot-Class-Path>,pom文件如下:

    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
      <modelVersion>4.0.0</modelVersion>
    
      <groupId>com.jdktest</groupId>
      <artifactId>MyInstrument</artifactId>
      <version>0.0.1-SNAPSHOT</version>
      <packaging>jar</packaging>
    
      <name>instrument</name>
      <url>http://maven.apache.org</url>
    
      <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
      </properties>
    
      <dependencies>
          <dependency>
            <groupId>javassist</groupId>
            <artifactId>javassist</artifactId>
            <version>3.8.0.GA</version>
          </dependency>
        <dependency>
          <groupId>junit</groupId>
          <artifactId>junit</artifactId>
          <version>3.8.1</version>
          <scope>test</scope>
        </dependency>
      </dependencies>
      <build>  
        <plugins>  
          <plugin>  
            <groupId>org.apache.maven.plugins</groupId>  
            <artifactId>maven-jar-plugin</artifactId>  
            <version>2.2</version>  
            <configuration>  
              <archive>  
                <manifestEntries>  
                  <Premain-Class>com.jdktest.instrument.AopAgentTest</Premain-Class>  
                  <Boot-Class-Path>E:/maven-lib/javassist/javassist/3.8.0.GA/javassist-3.8.0.GA.jar</Boot-Class-Path>  
    
                </manifestEntries>  
              </archive>  
            </configuration>  
          </plugin>  
    
          <plugin>  
           <artifactId>maven-compiler-plugin </artifactId >  
                  <configuration>  
                      <source> 1.6 </source >  
                      <target> 1.6 </target>  
                  </configuration>  
         </plugin>  
        </plugins>   
    
    
      </build> 
    </project>
    

    四、需要添加耗时监控的client

    随意编写需要添加耗时监控的代码并打jar包。

    package com.jdktest.SayHello;
    
    public class Target {
    
        public static void main(String[] args) {
            new Target().sayHello();
        }
    
        public void sayHello(){
            System.out.println("Hello, guys!");
        }
    }

    如果sayHello方法中又调用了同类中的方法或者别的类中的方法,这些被调用的方法的耗时仍可被监控到。

    五、执行

    在cmd下执行如下命令:

    java -javaagent:E:/workspace/MyInstrument/target/MyInstrument-0.0.1-SNAPSHOT.jar -cp E:/workspace/SayHello/target/SayHello-0.0.1-SNAPSHOT.jar com.jdktest.SayHello.Target

    六、执行结果

    这里写图片描述

    展开全文
  • VisualVM - JAVA 监控工具(8) 查找JAVA应用程序耗时方法函数 那些方法函数需要监控 如何排查 如何处理
  • 基于JavaAgent的全链路监控&...基于JavaAgent的全链路监控二《通过字节码增加监控执行耗时》 基于JavaAgent的全链路监控三《ByteBuddy操作监控方法字节码》 基于JavaAgent的全链路监控四《JVM内存与GC信息》 基于Ja...
  • mWebView.setWebViewClient(new WebViewClient(){ ... @Override public void onPageFinished(WebView view, String url) { super.onPageFinished(view, url); // 注入js Cage.onPageFinish(mWebView);...
  • JAVA方法耗时信息捕捉并日志

    千次阅读 2015-11-24 17:16:59
    一. 设计思想:  1、要保证日志的先后顺序,要保证输出的先后... 2、其次就是要保证不要出现存储耗时时间的List量太大的情况,所以解决方法是  A、使用ThreadLocal,每个线程输出自己的日志,这样比较清晰;  
  • 方法执行耗时、出入参获取、异常捕获、添加链路ID等等。而这些一个个的功能点,最快的掌握方式就是去实现他最基本的功能验证,这个阶段基本也是技术选型的阶段,验证各项技术点是否可以满足你后续开.
  • Java虚拟机性能管理神器 - VisualVM(8) 查找JAVA应用程序耗时方法函数【转】 标签:javajvm监控工具性能优化 2015-04-07 16:471846人阅读评论(0)收藏举报 分类: VisualVM(8) 版权声明:本文...
  • SpringBoot中使用AOP 监控sql耗时

    千次阅读 2017-02-20 17:10:20
    SpringBoot中AOP 监控sql耗时
  • 1.有一个需求,我们的业务java服务正在运行,有一天我们定位到系统中某方法可能出现异常,我们要在不修改代码重新发版的情况下,统计出此方法耗时和请求参数和返回值,怎么办? 业务服务代码: public class ...
  • public static void main(String[] args) { boolean a = false; boolean b = true; int d = 0; for (int i = 0; i <...java"...java"...//位运算耗时250ms //布尔运算耗时16ms
  • 提交了多少代码、提交了多少方法、有单元测试吗、影响了那些流程链路、有没有夹带上线。 大部分时候这些问题的汇总都是人为的方式进行提供,以依赖相信研发为主。剩下的就需要依赖有经验的测试进行白盒验证。所以...
  • 前言 相信各位大佬肯定在开发中遇到过这个问题:一顿操作猛如虎之后,总感觉程序有时候有点...答案当然是肯定的,为了方便大家使用,这里我先列出来自己刚写的一个开源项目,专门监听Android主线程耗时方法。传送门...
  • 本文是关于实时监控方法耗时的工具,不依赖任何插件,采用ThreadLocal实现多线程分化管理监控信息,写的比较潦草,很多地方没优化,有兴趣的可以改改,方便用于测试,不建议投入生产。 import java.io....
  • Windows环境下jvisualvm+Btrace 监控Java程序一、背景 在项目开发中,想要监控程序,我们可以本地启动项目,然后断点调试,可是对于线上的项目需要监控或者调试的时候,就没什么办法,目前有以下几种监控方式:1、...
  • 基于JavaAgent的全链路监控&...基于JavaAgent的全链路监控二《通过字节码增加监控执行耗时》 基于JavaAgent的全链路监控三《ByteBuddy操作监控方法字节码》 基于JavaAgent的全链路监控四《JVM内存与GC信息》 基于Ja...

空空如也

空空如也

1 2 3 4 5 ... 20
收藏数 39,456
精华内容 15,782
关键字:

java监控方法耗时

java 订阅