SpringAOP学习

duyiwuer

浏览: 121873 次
性别:
来自: 陕西

最近访客更多访客>>

zjocole

ballball0603

zhanghteye

xuwx

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

博客分类：

Spring

AOP Bean Spring log4j 正则表达式

      理解spring aop的路径：最初级的做法是通过使用代理将业务代码和系统代码分离，也就是在向代理类中注入业务接口实现类，然后在调用业务接口代码时调用系统代码；
JAVAd代码：
Java代码
1. //******* TimeBook.java**************
2. import org.apache.log4j.Level;
3. import org.apache.log4j.Logger;
4. public class TimeBook {
5.          private Logger logger = Logger.getLogger(this.getClass().getName());
6.          //审核数据的相关程序
7.          public void doAuditing(String name) {
8.                   logger.log(Level.INFO, name + " 开始审核数据....");
9.                   //审核数据的相关程序
10.                   ……
11.                   logger.log(Level.INFO, name + " 审核数据结束....");
12.          }
13. }
14. //******* TestHelloWorld.java**************
15. package com.gc.test;
16. import com.gc.action.TimeBook;
17. public class TestHelloWorld {
18.          public static void main(String[] args) {
19.                    TimeBook timeBook = new TimeBook();
20.                    timeBook.doAuditing("张三");
21.     }
22. }
23. //******* TimeBookInterface.java**************
24. package com.gc.impl;
25. import org.apache.log4j.Level;
26. //通过面向接口编程实现日志输出
27. public interface TimeBookInterface
28. {
29.          public void doAuditing(String name);
30. }
31. //******* TimeBook.java**************
32. package com.gc.action;
33. import com.gc.impl.TimeBookInterface;
34. public class TimeBook implements TimeBookInterface
35. {
36. public void doAuditing(String name) {
37. //审核数据的相关程序
38. ……
39. }
40. }
41. //******* TimeBookProxy.java**************
42. package com.gc.action;
43. import org.apache.log4j.Level;
44. import org.apache.log4j.Logger;
45. import com.gc.impl.TimeBookInterface;
46. public class TimeBookProxy
47. {
48.    private Logger logger = Logger.getLogger(this.getClass().getName());
49.    private TimeBookInterface timeBookInterface;
50.    //在该类中针对前面的接口TimeBookInterface编程，而不针对具体的类
51.      public TimeBookProxy(TimeBookInterface timeBookInterface)
52.      {
53.          this.timeBookInterface = timeBookInterface;
54.      }
55.           //实际业务处理
56.           public void doAuditing(String name)
57.            {
58.                    logger.log(Level.INFO, name + " 开始审核数据....");
59.                    timeBookInterface.doAuditing(name);    //调用方法
60.                    logger.log(Level.INFO, name + " 审核数据结束....");
61.           }
62. }
63. //******* TestHelloWorld.java**************
64. package com.gc.test;
65. import com.gc.action.TimeBook;
66. import com.gc.action.TimeBookProxy;
67. public class TestHelloWorld {
68.          public static void main(String[ ] args)
69.              {
70.                      //这里针对接口进行编程
71.                      TimeBookProxy timeBookProxy = new TimeBookProxy(new TimeBook());
72.                      timeBookProxy .doAuditing("张三");
73.              }
74. }

为了更加通用，引入java的动态代理机制来解除代理类注入的业务类必须实现指定接口的限制，这个要将前面所说的代理类进行修改，让其实现InvocationHandler 接口，该接口有两个方法:bind and invoke methods；在bind方法中和前面一样用来注入业务类（只不过该业务类不在是特定的类，而是一个Object对象），在invoke中将业务逻辑调用代码和系统代码进行混合（其中也使用了反射机制）；
Java代码
1. //******* LogProxy.java**************
2. package com.gc.action;
3. import java.lang.reflect.InvocationHandler;
4. import java.lang.reflect.Method;
5. import java.lang.reflect.Proxy;
6. import org.apache.log4j.Level;
7. import org.apache.log4j.Logger;
8. //代理类实现了接口InvocationHandler
9. public class LogProxy implements InvocationHandler
10. {
11.          private Logger logger = Logger.getLogger(this.getClass().getName());
12.          private Object delegate;
13.          //绑定代理对象
14.          public Object bind(Object delegate)
15.              {
16.                      this.delegate = delegate;
17.                      return Proxy.newProxyInstance(delegate.getClass().getClassLoader(),
18.                      delegate.getClass().
19.                      getInterfaces(), this);
20.              }
21.         //针对接口编程
22.          public Object invoke(Object proxy, Method method, Object[ ] args) throws Throwable
23.              {
24.                      Object result = null;
25.                               try {
26.                                          //在方法调用前后进行日志输出
27.                                         logger.log(Level.INFO, args[0] + " 开始审核数据....");
28.                                         result = method.invoke(delegate, args); //调用绑定对象的方法
29.                                         logger.log(Level.INFO, args[0] + " 审核数据结束....");
30.                                   }
31.                             catch (Exception e)
32.                                  {
33.                                        logger.log(Level.INFO, e.toString());
34.                                  }
35.                       return result;
36.            }
37. }
38. //******* TestHelloWorld.java**************
39. package com.gc.test;
40. import com.gc.action.TimeBook;
41. import com.gc.action.TimeBookProxy;
42. import com.gc.impl.TimeBookInterface;
43. import com.gc.action.LogProxy;
44. public class TestHelloWorld {
45.          public static void main(String[ ] args)
46.                 {
47.                       //实现了对日志类的重用
48.                       LogProxy logProxy = new LogProxy();
49.                       TimeBookInterface timeBookProxy = (TimeBookInterface)logProxy.bind(new TimeBook());
50.                       timeBookProxy.doAuditing("张三");
51.                 }
52. }

spring 的aop实现正是建立在java的动态代理机制上。要理解aop还必须理解几个概念，第一个就是PointCut（切入点），可以将其理解为所有要进行代理的业务对象及其方法的集合（也可以理解为JoinPoint的集合，说穿了就是注入业务代码的位置，而这个位置就是JoinPoint），这一点可以从Spring AOP的PointCut接口定义中看出来：
Java代码
1. package org.springframework.aop;
2. public interface Pointcut
3. {
4.          //用来将切入点限定在给定的目标类中
5.          ClassFilter getClassFilter();
6.          //用来判断切入点是否匹配目标类给定的方法
7.          MethodMatcher getMethodMatcher();
8.          Pointcut TRUE = TruePointcut.INSTANCE;
9. }

跟PointCut对应的是JoinPoint（连接点），也就是插入系统代码的方法调用、异常抛出等
最后一个概念就是通知（Advice）也就是用来放系统代码的地方，而Advisor ＝ Advise＋PointCut（这里是指的具体的位置，比如指定的方法名）
常用的Advisor是org.springframework.aop.support.RegexpMethodPointcutAdvisor
这个需要理解正则表达式的一些概念：
引用

（1）"."，可以用来匹配任何一个字符。比如：正则表达式为"g.f"，它就会匹配"gaf"、"g1f"、"g*f"和"g #f"等。
（2）"[]"，只有[]里指定的字符才能匹配。比如：正则表达式为"g[abc]f"，它就只能匹配"gaf"、"gbf"和"gcf"，而不会匹配"g1f"、"g*f"和"g#f"等。
（3）"*"，表示匹配次数，可以任意次，用来确定紧靠该符号左边的符号出现的次数。比如：正则表达式为"g.*f"，它能匹配"gaf"、"gaaf"、"gf"和"g*f"等。
（4）"?"，可以匹配0或1次，用来确定紧靠该符号左边的符号出现的次数。比如：正则表达式为"g.?f"，它能匹配"gaf""g*f"等。
（5）"\"，是正则表达式的连接符。比如：正则表达式为"g.\-f"，它能匹配"g-f"、"ga-f"和"g*-f"等。

Xml代码
1. <?xml version="1.0" encoding="UTF-8"?>
2. <!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN"
3. "http://www.springframework.org/dtd/spring-beans.dtd">
4. <beans>
5. <bean id="log" class="com.gc.action.LogAround"/>
6. <bean id="timeBook" class="com.gc.action.TimeBook"/>
7. 
8. <bean id="logAdvisor"class="org.springframework.aop.support.RegexpMethodPointcutAdvisor">
9.         <property name="advice">
10.             <ref bean="log"/>
11.         </property>
12.                
13.         <property name="patterns">
14.             <value>.*doAuditing.* </value>
15.         </property>
16.     </bean>
17. 
18. <bean id="logProxy" class="org.springframework.aop.framework.ProxyFactoryBean">
19.         <property name="proxyInterfaces">
20.             <value>com.gc.impl.TimeBookInterface</value>
21.         </property>
22.         <property name="target">
23.             <ref bean="timeBook"/>
24.         </property>
25.         <property name="interceptorNames">
26.             <list>
27.                 <value>logAdvisor</value>
28.             </list>
29.         </property>
30.     </bean>
31. </beans>

spring提供了四种Advice：
第1种：在需要调用方面的方法前后都调用处理方面的代码
第2种：在需要调用方面的方法之前调用处理方面的代码
第3种：在需要调用方面的方法之后都调用处理方面的代码
第4种：在需要调用方面的方法发生异常时调用处理方面的代码
示例配置代码如下
Xml代码
1. <?xml version="1.0" encoding="UTF-8"?>
2. <!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN"
3. "http://www.springframework.org/dtd/spring-beans.dtd">
4. <beans>
5. <bean id="log" class="com.gc.action.LogAop"/>
6. <bean id="timeBook" class="com.gc.action. timeBook "/>
7. <bean id="logProxy" class="org.springframework.aop.framework.ProxyFactor
8. yBean">
9.     <property name="proxyInterfaces">
10.         <value>com.gc.impl.TimeBookInterface</value>
11.     </property>
12.     <property name="target">
13.         <ref bean="timeBook"/>
14.     </property>
15.     <property name="interceptorNames">
16.          <list>
17.               <value>log</value>
18.          </list>
19.     </property>
20. </bean>
21. </beans>

所有的配置都一样，只是Advice不同而已：
Java代码
1. import org.aopalliance.intercept.MethodInterceptor;
2. import org.aopalliance.intercept.MethodInvocation;
3. import org.apache.log4j.Level;
4. import org.apache.log4j.Logger;
5.
6. public class LogAround implements MethodInterceptor{
7.       private Logger logger = Logger.getLogger(this.getClass().getName());
8.
9.     public Object invoke(MethodInvocation methodInvocation) throws Throwable {
10.            logger.log(Level.INFO, methodInvocation.getArguments()[0] + " 开始审核数据....");
11.         try {
12.           Object result = methodInvocation.proceed();
13.           return result;
14.         }
15.         finally {
16.                  logger.log(Level.INFO, methodInvocation.getArguments()[0] + " 审核数据结束....");
17.         }
18.    }
19. }
20.
21. import java.lang.reflect.Method;
22.
23. import org.apache.log4j.Level;
24. import org.apache.log4j.Logger;
25. import org.springframework.aop.MethodBeforeAdvice;
26.
27. public class LogBefore implements MethodBeforeAdvice {
28.        private Logger logger = Logger.getLogger(this.getClass().getName());
29.
30.     public void before(Method method, Object[] args, Object target) throws Throwable {
31.               logger.log(Level.INFO, args[0] + " 开始审核数据....");
32.    }
33. }
34.
35. import java.lang.reflect.Method;
36.
37. import org.apache.log4j.Level;
38. import org.apache.log4j.Logger;
39. import org.springframework.aop.AfterReturningAdvice;
40.
41. public class LogAfterReturning implements AfterReturningAdvice {
42.        private Logger logger = Logger.getLogger(this.getClass().getName());
43.
44.     public void afterReturning(Method method, Object[] args, Object target) throws Throwable {
45.               logger.log(Level.INFO, args[0] + " 开始审核数据....");
46.    }
47. }
48.
49. import java.lang.reflect.Method;
50.
51. import org.apache.log4j.Level;
52. import org.apache.log4j.Logger;
53. import org.springframework.aop.ThrowsAdvice;
54.
55. public class LogThrow implements ThrowsAdvice {
56.        private Logger logger = Logger.getLogger(this.getClass().getName());
57.
58.     public void afterThrowing(Method method, Object[] args, Object target,Throwable subclass) throws Throwable {
59.               logger.log(Level.INFO, args[0] + " 开始审核数据....");
60.    }
61. }
除了使用ProxyFactoryBean来创建AOP代理外，还可以使用DefaultAdvisorAutoProxyCreator来创建自动代理，当在配置文件中包括DefaultAdvisorAutoProxyCreator bean定义，那么在Bean定义档被读取完之后， DefaultAdvisorAutoProxyCreator会自动搜寻所有的Advisor（因为DefaultAdvisorAutoProxyCreator实现了BeanProcessor接口），并自动将Advisor应用至符合Pointcut的目标业务类上。实际上这是一个偷懒的做法，将advisor和具体业务类的关联管理处理交给spring去处理了。

在指定业务对象的同时还需要指定业务对象所实现的接口（面向接口编程），如果业务对象没有实现接口就需要借助cglib（这个一般是针对那些不能修改源代码的遗留系统的做法），对应的配置文件应该这样写：
Xml代码
1. <?xml version="1.0" encoding="UTF-8"?>
2. <!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN"
3. "http://www.springframework.org/dtd/spring-beans.dtd">
4. <beans>
5. <bean id="log" class="com.gc.action.LogAop"/>
6. <bean id="timeBook" class="com.gc.action. timeBook "/>
7. <bean id="logProxy" class="org.springframework.aop.framework.ProxyFactor
8. yBean">
9. //增加如下属性，就表示使用的是CGLIB代理（对目标类直接代理）
10.     <property name="proxyTargetClass">
11.         <value>true</value>
12.     </property>
13.    /*然后去掉下面的属性，也就是说此种方法不需要面向接口，或不需要指出接口
14. <property name="proxyInterfaces">
15.         <value>com.gc.impl.TimeBookInterface</value>
16.     </property>*/
17.     <property name="target">
18.         <ref bean="timeBook"/>
19.     </property>
20.     <property name="interceptorNames">
21.          <list>
22.               <value>log</value>
23.          </list>
24.     </property>
25. </bean>
26. </beans>
在spring2.0之后，提供了基于schema的aop配置，与以前的配置相比，它对spring的一些aop实现细节做了进一步的屏蔽（比如代理和拦截器），对spring aop的使用者来说更简单了。

基于schema的aop借用了一些AspectJ中的一些做法，如果对AspectJ比较熟悉的话，使用起来是非常容易的。
首先对里面的一些aop元素进行一下说明：
aop:config是aop配置中的一个顶级元素，所有的aop的配置定义都必须包含在该元素中

aop:aspect类似于以前spring2.0以前配置中那个Advisor（但是又不完全是，因为还有一个aop:advisor元素与之对应），它包含了PointCut和Advice信息，它会有一个对应的bean，许多advice信息也包含在里面，不过不用在象以前那样实现指定的BeforeXxx， AroundXxxx之类的接口了，可以直接通过 org.aspectj.lang.ProceedingJoinPoint来调用指定切面对象的方法。
比如：
Xml代码
1. <aop:aspect id="aroundExample" ref="aBean">
2.     <aop:around
3.       pointcut-ref="businessService"
4.       method="doBasicProfiling"/>
5.     ...
6. </aop:aspect>

方法doBasicProfiling就是aBean中定义的一个方法，它的定义是这样的：
Java代码
1. public Object doBasicProfiling(ProceedingJoinPoint pjp) throws Throwable {
2.     // start stopwatch
3.     Object retVal = pjp.proceed();
4.     // stop stopwatch
5.     return retVal;
6. }

aop:pointcut 是切入点定义，跟以前的切入点定义没有什么区别，不过象以前那种正则表达式定义放到了expression属性中，而且使用了AspectJ的语法。它可以定义在aop:aspect中，也可以定义在aop:config中

aop:after-returning(before, after-throwing, after, around)这个是Advice的定义，它里面指定了要跟已定义的哪个切入点关联（pointcut-ref属性），并且使用aspect中定义的哪个方法（method属性）。

一个简单的Spring的AOP例子
      经过这段日子的学习和使用Spring,慢慢地体会到Spring的优妙之处，正在深入地吸收Spring的精华，呵呵。现在写的这个只是个简单AOP例子,包括前置通知，后置通知,环绕通知,和目标对象。写这个例子的主要目标只是想让想学AOP的能更快地入门，了解一下如何去配置AOP里面的东东。
目标对象的接口:IStudent.java
1    /**
2   *
3    */
4 package com.dragon.study;
5
6    /**
7   * @author dragon
8   *
9    */
10   public   interface IStudent {
11
12       public   void addStudent(String name);
13 }
14
目标类:StudentImpl.java
1    /**
2   *
3    */
4 package com.dragon.study.Impl;
5
6 import com.dragon.study.IStudent;
7
8    /**
9   * @author dragon
10   *
11    */
12   public   class StudentImpl implements IStudent {
13
14         public   void addStudent(String name) {
15           System.out.println( " 欢迎 " + name + " 你加入Spring家庭! " );
16       }
17 }
18
前置通知:BeforeAdvice.java
1    /**
2   *
3    */
4 package com.dragon.Advice;
5
6 import java.lang.reflect.Method;
7
8 import org.springframework.aop.MethodBeforeAdvice;
9
10    /**
11   * @author dragon
12   *
13    */
14   public   class BeforeAdvice implements MethodBeforeAdvice {
15
16         public   void before(Method method,Object[] args, Object target)
17                   throws Throwable {
18
19            System.out.println( " 这是BeforeAdvice类的before方法. " );
20
21        }
22 }
23

后置通知:AfterAdvice.java
1 /**
2 *
3 */
4 package com.dragon.Advice;
5
6 import java.lang.reflect.Method;
7
8 import org.springframework.aop.AfterReturningAdvice;
9
10 /**
11 * @author dragon
12 *
13 */
14 public class AfterAdvice implements AfterReturningAdvice{
15
16     public void afterReturning(Object returnValue ,Method method,
17                     Object[] args,Object target) throws Throwable{
18         System.out.println("这是AfterAdvice类的afterReturning方法.");
19     }
20
21
22 }
23

环绕通知:CompareInterceptor.java
1 /**
2 *
3 */
4 package com.dragon.Advice;
5
6 import org.aopalliance.intercept.MethodInterceptor;
7 import org.aopalliance.intercept.MethodInvocation;
8
9
10 /**
11 * @author dragon
12 *
13 */
14 public class CompareInterceptor implements MethodInterceptor{
15
16        public Object invoke(MethodInvocation invocation) throws Throwable{
17           Object result = null;
18          String stu_name = invocation.getArguments()[0].toString();
19           if ( stu_name.equals("dragon")){
20              //如果学生是dragon时,执行目标方法,
21               result= invocation.proceed();
22
23           } else{
24              System.out.println("此学生是"+stu_name+"而不是dragon,不批准其加入.");
25          }
26
27           return result;
28       }
29 }
30

配置文件applicationContext.xml
1 <?xml version="1.0" encoding="UTF-8"?>
2 <!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
3
4 <beans>
5
6 <bean id="beforeAdvice" class="com.dragon.Advice.BeforeAdvice"></bean>
7 <bean id="afterAdvice" class="com.dragon.Advice.AfterAdvice"></bean>
8 <bean id="compareInterceptor" class="com.dragon.Advice.CompareInterceptor"></bean>
9 <bean id="studenttarget" class="com.dragon.study.Impl.StudentImpl"></bean>
10
11 <bean id="student" class="org.springframework.aop.framework.ProxyFactoryBean">
12   <property name="proxyInterfaces">
13     <value>com.dragon.study.IStudent</value>
14   </property>
15   <property name="interceptorNames">
16     <list>
17      <value>beforeAdvice</value>
18      <value>afterAdvice</value>
19     <value>compareInterceptor</value>
20     </list>
21   </property>
22   <property name="target">
23     <ref bean="studenttarget"/>
24   </property>
25
26 </bean>
27
28
29
30
31 </beans>
现在开始写测试类,Test.java
1 /**
2 *
3 */
4 package com;
5
6 import org.springframework.context.ApplicationContext;
7 import org.springframework.context.support.FileSystemXmlApplicationContext;
8
9 import com.dragon.study.IStudent;
10
11 /**
12 * @author dragon
13 *
14 */
15 public class Test {
16
17      /**
18      * @param args
19      */
20      public static void main(String[] args) {
21         // TODO Auto-generated method stub
22       ApplicationContext ctx =
23           new FileSystemXmlApplicationContext("/com/dragon/applicationContext.xml");
24
25       IStudent person = (IStudent)ctx.getBean("student");
26       person.addStudent("dragon");
27
28 //      person.addStudent("javadragon");
29     }
30
31 }
32