svr-cat-master/框架埋点方案集成/spring-aop

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);
	}

}