ethan / CAT

Spring AOP ANNOTATION 监控方法执行时间

• 源码中提供了CatAnnotation 以及 CatAopService 这两个类
• spring的xml中添加com.dianping.cat.aop.CatAopService 以及 aop:aspectj-autoproxy
• 在监控的bean的方法上添加CatAnnotation
• cat不推荐使用aop方法埋点，会有少量性能损耗，推荐使用api，这样type和name以及成功状态可以更加灵活
• 业务也可以将此jar两个文件copy到自己的项目工程，这样可以少引入一个jar具体的可以参考如下源码

spring的配置文件

<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:aop="http://www.springframework.org/schema/aop" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.springframework.org/schema/beans  
           http://www.springframework.org/schema/beans/spring-beans.xsd  
           http://www.springframework.org/schema/aop  
           http://www.springframework.org/schema/aop/spring-aop.xsd">

    <!-- 配置通知所在的bean，实际是aspectjs自动扫描所有bean，去找有切面的bean ，请在配置文件添加-->
    <bean id="adviceService" class="com.dianping.cat.aop.CatAopService" />

    <!-- 使用aspectjs配置自动代理，请在配置文件添加 -->
    <aop:aspectj-autoproxy />

    <!-- 这行是使用的一个demo，不需要添加 -->
    <bean id="userServiceImpl" class="com.dianping.cat.aop.UserServiceImpl" />

</beans>  

其他参考源码

package com.dianping.cat.aop;


public interface UserService {

    @CatAnnotation //此处增加annotation
    public void delete(Object entity);

    @CatAnnotation //此处增加annotation
    public void getAllObjects();

    @CatAnnotation //此处增加annotation
    public void save(Object entity);

    @CatAnnotation //此处增加annotation
    public void update(Object entity);
}

package com.dianping.cat.aop;

public class UserServiceImpl implements UserService {

    @Override
    public void delete(Object entity) {
        sleep(30);
        System.out.println("UserServiceImpl---删除方法:delete()---");
    }

    @Override
    public void getAllObjects() {
        sleep(40);
        System.out.println("UserServiceImpl---查找所有方法:getAllObjects()---");
    }

    @Override
    public void save(Object entity) {
        sleep(10);
        System.out.println("UserServiceImpl---保存方法:save()---");
    }

    private void sleep(int time) {
        try {
            Thread.sleep(time);
        } catch (Exception e) {
        }
    }

    @Override
    public void update(Object entity) {
        sleep(20);
        System.out.println("UserServiceImpl---更新方法:update()---");
    }

}

package com.dianping.cat.aop;

import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class AdviseTest {

    @SuppressWarnings("resource")
    @Test
    public void testUser() throws InterruptedException {
        ApplicationContext context = new ClassPathXmlApplicationContext("spring-aspectjs.xml");
        UserService userService = context.getBean("userServiceImpl", UserService.class);

        for (int i = 0; i < 1000; i++) {
            userService.save(null);
            userService.update(null);
            userService.delete(null);
            userService.getAllObjects();
        }

        Thread.sleep(1000);
    }

}