Spring AOP的案例

屌丝的时间总是有那么多。

无聊等球赛中，不知道尽头的巴西会如何拾取被德国摧残的尊严。突然想起teamleader周5的时候让我给现在刚上线的一个项目中加入一个切面，以便统一输出一些日志。之所以会有这个想法，是因为在周5的早上我跟teamleader提交了一个关于项目中缺少业务日志问题产生的。至于为什么会有这个问题，我不得不吐槽下我现在的团队兄弟们，算了，还是言归正传，说说我刚才写的一个AOP案例吧。

因为初衷只是为了给代码中加入一些日志，而我后来想到顺便加上一个对service层的方法执行时间的统计。对于这个，衍生出一个线程安全问题，统计时间意味着在Before需要有一个变量去接收起始时间，在After时获得之前的变量值进行计算并输出。这样一来之前的变量在并发情况下，后来的访问的起始时间将会覆盖这个变量值，想到ThreadLocal，泛型Long。由此解决线程安全问题。

关于ThreadLocal，请自行google。

切面类

package com.eric.aop.aspect;

import java.lang.reflect.Method;
import java.text.MessageFormat;

import org.springframework.aop.AfterReturningAdvice;
import org.springframework.aop.MethodBeforeAdvice;
import org.springframework.aop.ThrowsAdvice;

public class MyAspect implements MethodBeforeAdvice, AfterReturningAdvice,
		ThrowsAdvice {
	private ThreadLocal<Long> tl=new ThreadLocal<Long>();

	public void before(Method method, Object[] objArr, Object target)
			throws Throwable {
		// 获得当前时间,set到ThreadLocal中
		tl.set(System.currentTimeMillis());
	}

	public void afterReturning(Object obj, Method method, Object[] objArr,
			Object target) throws Throwable {
		// 从ThreadLocal中get值并进行计算
		long runTime=System.currentTimeMillis()-tl.get();
		System.out.println(MessageFormat.format("{0}>>>本次耗时>>>{1}ms", 
				Thread.currentThread().getName(),runTime));
	}
	public void afterThrowing(Method method, Object[] objArr, Object target,
			Exception ex) throws Throwable {
		System.out.println("err>>>"+ex);
	}
}

业务接口类

package com.eric.aop.service;

public interface VOService {
        public void print();
}

业务实现类

package com.eric.aop.service.imp;

import org.springframework.context.annotation.Scope;
import org.springframework.stereotype.Service;

import com.eric.aop.service.VOService;

@Service("vOService")
@Scope("prototype")
public class VOServiceImpl implements VOService {

	public void print() {
		System.out.println("我是VO");
		try {
			Thread.sleep(new Random().nextInt(10000));
			// Object obj=null;
			// obj.toString();
		} catch (InterruptedException e) {
		}
	}

}

Spring配置

<?xml version="1.0" encoding="UTF-8" ?>  
<beans xmlns="http://www.springframework.org/schema/beans"  
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop"  
    xmlns:tx="http://www.springframework.org/schema/tx" xmlns:context="http://www.springframework.org/schema/context"  
    xsi:schemaLocation="http://www.springframework.org/schema/beans     
    http://www.springframework.org/schema/beans/spring-beans-2.5.xsd     
    http://www.springframework.org/schema/context     
    http://www.springframework.org/schema/context/spring-context-2.5.xsd  
    http://www.springframework.org/schema/tx  
    http://www.springframework.org/schema/tx/spring-tx-2.5.xsd  
    http://www.springframework.org/schema/aop  
    http://www.springframework.org/schema/aop/spring-aop-2.5.xsd">  
  
    <context:annotation-config />  
    <!-- 扫描com.eric 下所有的包-->  
    <context:component-scan base-package="com.eric" />  
  
    <bean id="testAdvice" class="com.eric.aop.aspect.MyAspect" />  
    <aop:config>  
       <aop:advisor pointcut="execution(* com.eric.aop.*.*Service.*(..))"  
            advice-ref="testAdvice" />  
    </aop:config>  
</beans>

测试类

package com.eric.aop.test;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.eric.aop.service.VOService;

public class AopTest {
	public static void main(String[] args) throws InterruptedException {
		ApplicationContext ac = new ClassPathXmlApplicationContext(
				"applicationContext.xml");
		int t = 9;
		for (int i = 0; i < t; i++) {
			new Thread(new ThreadTest(ac)).start();
		}
	}
}
class ThreadTest implements Runnable {
	private ApplicationContext ac;

	public ThreadTest(ApplicationContext ac) {
		this.ac = ac;
	}
	public void run() {
		VOService vo = (VOService) ac.getBean("vOService");
		vo.print();
	}
}

输出结果

我是VO
我是VO
我是VO
我是VO
我是VO
我是VO
我是VO
我是VO
我是VO
Thread-7>>>本次耗时>>>292ms
Thread-2>>>本次耗时>>>1,387ms
Thread-5>>>本次耗时>>>1,707ms
Thread-1>>>本次耗时>>>2,686ms
Thread-9>>>本次耗时>>>4,874ms
Thread-3>>>本次耗时>>>5,173ms
Thread-6>>>本次耗时>>>6,033ms
Thread-8>>>本次耗时>>>9,379ms
Thread-4>>>本次耗时>>>9,740ms

Spring AOP的案例