首页 > 代码库 > Spring AOP的案例
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
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。