Spring Aop Step-By-Step
学习笔记(上)
最近由于工作需要，要求掌握关于
Spring
方面的东西。所以花了两个星期的时间来学习
Spring
的基本知识，主要包括
Ioc
和
Aop
两方面。
本文为笔者的
Spring
在
Aop
方面的学习笔记，主要结合了
Spring In Action
第三章
和
Spring-Reference
第五章
为学习向导。根据自己的理解和书中的实例来一步一步完成对于在
Spring
中
Aop
方面的编程。其中基础部分
Ioc
需要读者自己参考资料了解，本文将不做描述。
说明：我将尽量缩短程序长度，在程序部分将减少注释说明，重点要读者自己根据上下文和程序结果理解体会，具体
api
信息请读者自己参考
Spring-api
文档和相关资料。
一.
准备工作：
1.
开发环境：
l
适合人群：
要了解
Spring Ioc
，对
Spring- Aop
可以不了解或者仅仅熟悉
Aop
概念，未参与
Spring Aop
开发实战的初学者。同时也希望高手对于本文的不足或理解错误之处给予指点，谢谢。
l
开发环境：
JDK 1.4_2
l
开发工具：
Eclipse 3.12
（未采用任何插件，主要是为初学者熟悉和理解
xml
文档的配置）
l
所需组件：
Spring-Framework-1.2.8
下载地址：
2.
建立工程：
首先用
Eclpse
建立一个普通
java
项目，导入
jar
文件到编译环境中，如下：
a)
Spring.jar
为
Spring
的核心
jar
文件，必须；
b)
Commons-loggin.jar
日志文件，必须；
c)
Cglib.jar
动态代理文件，不是必须（本文需要）；
d)
Jak-oro.jar
使用
Perl
和
Awk
正则表达式进行文本解析工具，不是必须（本文需要）；
建立工程如下：
好了，下来我们开始我们的
Spring-aop
之旅；
二.
Spring -Aop
入门
AOP
全名
Aspect-oriented programming
。
Spring framework
是很有前途的
AOP
技术。作为一种非侵略性的，轻型的
AOP framework
，你无需使用预编译器或其他的元标签，便可以在
Java
程序中使用它。这意味着开发团队里只需一人要对付
AOP framework
，其他人还是像往常一样编程。
关键性概念：
1)
Advice
是代码的具体实现，例如一个实现日志记录的代码。
2)
Pointcut
是在将
Advice
插入到程序的条件。
3)
advisor
是把
pointcut
和
advice
的组合在一起装配器。
图例：
你的程序可能如上，现在要在三个流程上同时加入日志控制和权限控制，如下：
你的程序可能如上，现在要在三个流程上同时加入日志控制和权限控制，如下：
其中拿日志为例，日志控制和流程之间的穿插点处叫做连接点（
Joinpoint
），而
Advice
就是我们日志处理的具体代码，
Pointcut
就是定义一个规则，对三个和业务有关的连接点进行过滤和匹配（例如我们对于业务
1
不做日志处理）。
Advisor
就是将符合的规则的剩下的两个连接点和具体的日志记录代码组合在一起。
三.
Spring-Aop
前置通知、后置通知、环绕通知、异常通知实现
我以
Spring In Action
提供的例子进行二次改造，完成我们自己的流程。业务流程很简单，顾客到商店买东西，店员根据顾客的需要给于顾客提供服务。实现方法前插入，方法后插入，环绕，异常四种。
代码：
建立一个用户类；
public class Customer {
private String name = "
悠~游!";
public String getName() {
return name;
}
}
三个产品
public class Cheese {
public String toString(){
return "
奶酪!";
}
}
public class Pepper {
public String toString(){
return "
胡椒粉!";
}
}
public class Squish {
public String toString(){
return "
果酱!";
}
}
建立一个接口；
public interface KwikEMart {
Squish buySquish(Customer customer) throws KwikEMartException;
Pepper buyPepper(Customer customer) throws KwikEMartException;
Cheese buyCheese(Customer customer) throws KwikEMartException;
}
实现这个接口，我们实现三个方法，买奶酪，买胡椒粉，买果酱；
public class ApuKwikEMart implements KwikEMart {
private boolean cheeseIsEmpty = false;
private boolean pepperIsEmpty = false;
private boolean squishIsEmpty = false;
public Cheese buyCheese(Customer customer) throws NoMoreCheeseException{
if (cheeseIsEmpty) {
throw new NoMoreCheeseException();
}
Cheese s = new Cheese();
System.out.println("--
我想买:" + s);
return s;
}
public Pepper buyPepper(Customer customer) throws NoMorePepperException{
if (pepperIsEmpty) {
throw new NoMorePepperException();
}
Pepper s = new Pepper();
System.out.println("--
我想买:" + s);
return s;
}
public Squish buySquish(Customer customer) throws NoMoreSquishException{
if (squishIsEmpty) {
throw new NoMoreSquishException();
}
Squish s = new Squish();
System.out.println("--
我想买:" + s);
return s;
}
public void setCheeseIsEmpty(boolean cheeseIsEmpty) {
this.cheeseIsEmpty = cheeseIsEmpty;
}
public void setPepperIsEmpty(boolean pepperIsEmpty) {
this.pepperIsEmpty = pepperIsEmpty;
}
public void setSquishIsEmpty(boolean squishIsEmpty) {
this.squishIsEmpty = squishIsEmpty;
}
}
环绕通知的实现，必须实现invoke方法，通过调用invoke.proceed()手工调用对象方法：
public class OnePerCustomerInterceptor implements MethodInterceptor {
private Set customers=new HashSet();
public Object invoke(MethodInvocation invoke) throws Throwable {
Customer customer=(Customer)invoke.getArguments()[0];
if(customers.contains(customer)){
throw new KwikEMartException("One per customer.");
}
System.out.println("
店员:"+customer.getName() + " ,Can I help you ?");
Object squishee=invoke.proceed(); //
手工调用对象方法;
System.out.println("
店员:OK! " + customer.getName() + ".give you! " );
customers.add(squishee);
return squishee;
}
}
前置通知的实现；
public class WelcomeAdvice implements MethodBeforeAdvice {
public void before(Method method, Object[] args, Object target) throws Throwable {
Customer customer = (Customer) args[0];
System.out.println("
店员::Hello " + customer.getName() + " . How are you doing?");
}
}
public class Customer {
private String name = "
悠~游!";
public String getName() {
return name;
}
}
后置通知实现；
public class ThankYouAdvice implements AfterReturningAdvice {
public void afterReturning(Object returnValue, Method method, Object[] args, Object target) throws Throwable {
Customer customer = (Customer) args[0];
System.out.println("
店员:Thank you " + customer.getName() + " . Come again! " );
}
}
系统异常处理通知实现；
public class KwikEmartExceptionAdvice implements ThrowsAdvice {
public void afterThrowing(NoMoreSquishException e) {
System.out.println("
系统:NoMoreSquisheesException异常截获了: " + e.getMessage());
}
public void afterThrowing(NoMoreCheeseException e) {
System.out.println("
系统:NoMoreCheeseException异常截获了: " + e.getMessage());
}
public void afterThrowing(NoMorePepperException e) {
System.out.println("
系统:NoMorePepperException异常截获了: " + e.getMessage());
}
}
自定义的异常接口；
public class KwikEMartException extends Exception {
private static final long serialVersionUID = -3962577696326432053L;
String retValue = "KwikEMartException
异常!";
public KwikEMartException(String name) {
retValue = name;
}
public KwikEMartException() {
}
public String getMessage() {
return retValue;
}
}
没有更多的奶酪异常；
public class NoMoreCheeseException extends KwikEMartException {
private static final long serialVersionUID = -3961123496322432053L;
String retValue = "NoMoreCheeseException
异常!";
public NoMoreCheeseException() {
super();
}
public NoMoreCheeseException(String name) {
super(name);
}
public String getMessage() {
return retValue;
}
}
没有更多的胡椒粉异常；
public class NoMorePepperException extends KwikEMartException {
private static final long serialVersionUID = -3961234696322432053L;
String retValue = "NoMorePepperException
异常!";
public NoMorePepperException() {
super();
}
public NoMorePepperException(String name) {
super(name);
}
public String getMessage() {
return retValue;
}
}
没有更多的果酱异常；
public class NoMoreSquishException extends KwikEMartException {
private static final long serialVersionUID = -3121234696322432053L;
String retValue = "NoMoreSquishException
异常!";
public NoMoreSquishException() {
super();
}
public NoMoreSquishException(String name) {
super(name);
}
public String getMessage() {
return retValue;
}
}
运行实例类；
public class RunDemo {
public static void kwikEMart() {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("demo/kwikemart.xml");
//如果你想通过类来引用这个的话,就要用到CGLIB.jar了,同时在代理工厂里面设置:
//<property name="proxyTargetClass" value="true" />
KwikEMart akem = (KwikEMart) context.getBean("kwikEMart");
try {
akem.buySquish(new Customer());
akem.buyPepper(new Customer());
akem.buyCheese(new Customer());
} catch (KwikEMartException e) {
//异常已经被截获了,不信你看控制台!~;
}
}
public static void main(String[] args) {
kwikEMart();
}
}
Xml
文件配置：
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
<bean id="kwikEMartTarget" class="demo.ApuKwikEMart">
<!--
把这里注释去掉的话,程序调用的时候测试异常通知;
<property name="cheeseIsEmpty">
<value>true</value>
</property>
<property name="pepperIsEmpty">
<value>true</value>
</property>
<property name="squishIsEmpty">
<value>true</value>
</property>
-->
</bean>
<!--
方法调用前通知 -->
<bean id="welcomeAdvice" class="demo.advice.WelcomeAdvice" />
<!--
方法调用后通知 -->
<bean id="thankYouAdvice" class="demo.advice.ThankYouAdvice" />
<!--
环绕调用通知 -->
<bean id="onePerCustomerInterceptor" class="demo.advice.OnePerCustomerInterceptor" />
<!--
异常调用通知 -->
<bean id="kwikEmartExceptionAdvice" class="demo.advice.KwikEmartExceptionAdvice" />
<bean id="kwikEMart" class="org.springframework.aop.framework.ProxyFactoryBean">
<property name="proxyInterfaces" value="demo.KwikEMart" />
<property name="interceptorNames">
<list>
<value>welcomeAdvice</value>
<value>thankYouAdvice</value>
<value>onePerCustomerInterceptor</value>
<value>kwikEmartExceptionAdvice</value>
</list>
</property>
<property name="target">
<ref bean="kwikEMartTarget" />
</property>
</bean>
</beans>
这个例子东西很多，不过每个类的代码都不大。如果你对
org.springframework.aop.framework.ProxyFactoryBean
不是很了解的话可以看我下篇尾处的介绍。
读清楚之后，我们运行RunDemo 类，查看控制台结果，如下：
店员::Hello 悠~游! . How are you doing?
店员:悠~游! ,Can I help you ?
--
我想买:果酱!
店员:OK! 悠~游!.give you!
店员:Thank you 悠~游! . Come again!
店员::Hello 悠~游! . How are you doing?
店员:悠~游! ,Can I help you ?
--
我想买:胡椒粉!
店员:OK! 悠~游!.give you!
店员:Thank you 悠~游! . Come again!
店员::Hello 悠~游! . How are you doing?
店员:悠~游! ,Can I help you ?
--
我想买:奶酪!
店员:OK! 悠~游!.give you!
店员:Thank you 悠~游! . Come again!
我们将
kwikEMartTarget
里面的注释去掉，测试异常实现，如下：
店员::Hello 悠~游! . How are you doing?
店员:悠~游! ,Can I help you ?
系统:NoMoreSquisheesException异常截获了: NoMoreSquishException 异常!
好好理解一下，我就不废话了，我们进行下一节。
四. Spring-Aop 之Pointcut＋advice＋Advisor 实现
我们修改我们的xml文档后如下：
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
<bean id="kwikEMartTarget" class="demo.ApuKwikEMart"></bean>
<!-- 环绕调用通知 -->
<bean id="onePerCustomerInterceptor" class="demo.advice.OnePerCustomerInterceptor" />
<!-- 使用NameMatchMethodPointcut -->
<bean id="nameMatchfilterPointcut" class="org.springframework.aop.support.NameMatchMethodPointcut">
<property name="mappedName">
<!--
buy.* 以buy开头的方法;
-->
<value>buy*</value>
</property>
</bean>
<!-- 使用Perl5RegexpMethodPointcut -->
<bean id="regexpFilterPointcut" class="org.springframework.aop.support.Perl5RegexpMethodPointcut">
<property name="pattern">
<!--
.*buy.+ 以buy开头的方法;
.*buyS.+ 以buyS开头的方法;
-->
<value>.*suy.+</value>
</property>
</bean>
<bean id="runDemofilterPointcutAdvisor" class="org.springframework.aop.support.DefaultPointcutAdvisor">
<property name="pointcut">
<ref bean="nameMatchfilterPointcut" />
</property>
<property name="advice">
<ref bean="onePerCustomerInterceptor" />
</property>
</bean>
<bean id="kwikEMart" class="org.springframework.aop.framework.ProxyFactoryBean">
<property name="proxyInterfaces" value="demo.KwikEMart" />
<property name="interceptorNames">
<list>
<value>runDemofilterPointcutAdvisor</value>
</list>
</property>
<property name="target">
<ref bean="kwikEMartTarget" />
</property>
</bean>
</beans>
运行，结果如下：
店员:悠~游! ,Can I help you ?
--我想买:果酱!
店员:OK! 悠~游!.give you!
店员:悠~游! ,Can I help you ?
--我想买:胡椒粉!
店员:OK! 悠~游!.give you!
店员:悠~游! ,Can I help you ?
--我想买:奶酪!
店员:OK! 悠~游!.give you!
在这里简单说明一下xml文档：nameMatchfilterPointcut和regexpFilterPointcut 是我们自己定义好规则的Pointcut。nameMatchfilterPointcut 根据mappedName来设置过滤规则, regexpFilterPointcut则是用pattern来设置过滤规则。runDemofilterPointcutAdvisor则将我们的Pointcut和advice组合在一起。
读者可以自己修改runDemofilterPointcutAdvisor的pointcut来切换不同的Pointcut。如果需要RegexpMethodPointcut 的子类的实现，必须要oro包支持。（注：RegexpMethodPointcut有俩个子类的实现，JdkRegexpMethodPointcut和Perl5RegexpMethodPointcut）。
但是，如果我们想让我们的Advisor同时实现多个Pointcut＋advice怎么办呢？利用Spring In Action里面的实例，我们来自己实现我们的Pointcut。
代码：
public class MyUnionPointcut implements Pointcut {
private Pointcut delegate;
public ClassFilter getClassFilter() {
return getDelegate().getClassFilter();
}
private Pointcut getDelegate() {
if (delegate == null) {
throw new AopConfigException("No pointcuts have been configured.");
}
return delegate;
}
public MethodMatcher getMethodMatcher() {
return getDelegate().getMethodMatcher();
}
public void setPointcuts(List pointcuts) {
if (pointcuts == null || pointcuts.size() == 0) {
throw new AopConfigException("Must have at least one Pointcut.");
}
delegate = (Pointcut) pointcuts.get(0);
for (int i = 1; i < pointcuts.size(); i++) {
Pointcut pointcut = (Pointcut) pointcuts.get(i);
delegate = Pointcuts.union(delegate, pointcut);
}
}
}
其实就是继承Pointcut类，实现getMethodMatcher()方法即可，接下来看我们把那两个Pointcut组合成一个，当其中一个Pointcut满足的时候就返回true，调用我们的Advice。
在xml中，加入下面代码：
<bean id="myUnionPointcut" class="demo.utils.MyUnionPointcut">
<property name="pointcuts">
<list>
<!-- 这里说明一下:动态切入点和静态切入点集合在一起的时候好像有问题? -->
<ref bean="nameMatchfilterPointcut" />
<ref bean="regexpFilterPointcut" />
</list>
</property>
</bean>
修改runDemofilterPointcutAdvisor的pointcut来加入我们组合好的Pointcut。
<bean id="runDemofilterPointcutAdvisor" class="org.springframework.aop.support.DefaultPointcutAdvisor">
<property name="pointcut">
<ref bean=”myUnionPointcut" />
</property>
<property name="advice">
<ref bean="onePerCustomerInterceptor" />
</property>
</bean>
同时在运行前，读者可以自己修改两个pointcut的匹配方法，来匹配更多的可选项。同时可以参考的一个类是org.springframework.aop.support.UnionPointcut，它实现两个pointcut的联合。如果读者想实现更加灵活的匹配，需要自己来定义自己的pointcut。（如第一个pointcut交叉第二个pointcut，联合第三个pointcut），交叉的工具类为ComposablePointcut。 运行的结果请读者自己试验。这个时候您可能在想，这些pointcut都是Spring自己的实现，我们能否自己来定义我们自己规则的pointcut呢？当然可以！～
代码：
/**
*
* 自己定义的静态切入点
* 满足条件是:当传入的数字大于1块钱的时候才可以;
*
* @author 悠~游
* @since 2006-06-22
* @link www.uusam.com
*/
public class MyPointcut extends StaticMethodMatcherPointcut implements Serializable {
private static final long serialVersionUID = -101281038294508751L;
private int money = 0;
/**
* 实现方法,业务逻辑为:根据输入的钱数和动作(必须是以buy开头的方法),来确定是否有钱购买商品,买完之后去掉商品的价格;
*/
public boolean matches(Method method, Class targetClass) {
if (method.getName().indexOf("buyCheese") == 0 && money >= 100) {
money -= 100;
return true;
} else if (method.getName().indexOf("buyPepper") == 0 && money >= 5) {
money -= 5;
return true;
} else if (method.getName().indexOf("buySquish") == 0 && money >= 10) {
money -= 10;
return true;
}
System.out.println("门卫:你要买的东西太贵，你的钱 "+money+" 太少!~ ,取消服务!");
return false;
}
public void setMoney(int money) {
this.money = money;
}
}
这个就是我们自己定义的静态Pointcut，主要实现自己的matches方法。看看如何加入到我们的ＸＭＬ文档中：
<!-- 使用自定义的切入点 -->
<bean id="myPointcut" class="demo.pointcut.MyPointcut">
<property name="money">
<value>100</value>
</property>
</bean>
很简单不是么？我们定义一个数字，就是用户的money，进入商店时候兜里的钱^_^。同样修改我们的myUnionPointcut里面的pointcuts，加入我们的pointcut。
<bean id="myUnionPointcut" class="demo.utils.MyUnionPointcut">
<property name="pointcuts">
<list>
<!—上面两个要设置成不通过哦，或者索性就去掉先。 -->
<ref bean="nameMatchfilterPointcut" />
<ref bean="regexpFilterPointcut" />
<ref bean="myPointcut" />
</list>
</property>
</bean>
当上面两个Pointcut定义的规则不通过的时候，程序开始校验我们的myPointcut。运行，结果如下：
店员:悠~游! ,Can I help you ?
--我想买:果酱!
店员:OK! 悠~游!.give you!
店员:悠~游! ,Can I help you ?
--我想买:胡椒粉!
店员:OK! 悠~游!.give you!
门卫:你要买的东西太贵，你的钱 85 太少!~ , 取消服务!
--我想买:奶酪!//服务员没了...
好了，是不是我们想要的结果呢？呵呵。
同时，Spring 提供动态Pointcut。关于动态的说明我就不在熬述了，我们这里只关心具体Spring带给我们的具体实现方法，具体应用请读者自己斟酌使用。
<!-- 定制动态接入点,来判断当前线程堆栈中是否有demo.RunDemo这个类; -->
<bean id="runDemoPointcut" class="org.springframework.aop.support.ControlFlowPointcut">
<constructor-arg>
<value>demo.RunDemo</value>
</constructor-arg>
</bean>
修改下面的引用我们的动态Pointcut； <bean id="myUnionPointcut" class="demo.utils.MyUnionPointcut">
<property name="pointcuts">
<list>
<ref bean=" runDemoPointcut " />
</list>
</property>
</bean>
运行，结果如下：
店员:悠~游! ,Can I help you ?
--我想买:果酱!
店员:OK! 悠~游!.give you!
店员:悠~游! ,Can I help you ?
--我想买:胡椒粉!
店员:OK! 悠~游!.give you!
店员:悠~游! ,Can I help you ?
--我想买:奶酪!
店员:OK! 悠~游!.give you!
动态切入点是根据当前堆栈信息进行方法匹配的一种规则，读者可以自己修改demo.RunDemo，如java.lang.Integer，来看看结果。
--我想买:果酱!
--我想买:胡椒粉!
--我想买:奶酪!
到这里能够读下来已经很不容易了，呵呵。还是站起来走动一下吧，接下来我们将搞定其他的一些东东。
posted on 2006-07-05 17:26
崛起的程序员 阅读(349)
评论(0) 编辑 收藏