您的位置:首页 > 运维架构

Srping AOP基于注解和配置文件方式实现前通知,后通知,环绕通知,异常通知,最终通知

2017-11-15 21:21 591 查看
Srping AOP基于注解和配置文件方式实现前通知,后通知,环绕通知,异常通知,最终通知

注解方式:

1、切面类

package cn.sz.aspect;

import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.After;
import org.aspectj.lang.annotation.AfterReturning;
import org.aspectj.lang.annotation.AfterThrowing;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Before;
import org.springframework.stereotype.Component;

//这是一个横向抽取非主要业务方法的类
@Component
@Aspect
public class MyAspect {
@Before(value = "execution(* cn.sz.dao.impl.*.*(..))")
public void login(JoinPoint jp) {
// 获取连接点的信息
Object o = jp.getThis();
System.out.println(o);
// ((UserDao)o).delete();

System.out.println("login.......");
}

@AfterReturning(value = "execution(* cn.sz.dao.impl.*.*(..))")
public void log4j() {
System.out.println("log4j......");
}

@Around(value = "execution(* cn.sz.dao.impl.*.*(..))")
public void rou(ProceedingJoinPoint pjp) throws Throwable {
System.out.println("round......1");

pjp.proceed();

System.out.println("round......2");
}

@AfterThrowing(value = "execution(* cn.sz.dao.impl.*.*(..))")
public void exception() {
System.out.println("exception......");
}

@After(value = "execution(* cn.sz.dao.impl.*.*(..))")
public void finallyF() {
System.out.println("finallyF......");
}
}


2、主配置文件

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:user="http://www.springframework.org/schema/p"
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/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd
">
<!-- 扫描:当前包中的类和子包中的类 -->
<context:component-scan base-package="com.sz"></context:component-scan>
<aop:aspectj-autoproxy/>
<bean id="userDao" class="com.sz.dao.impl.UserDaoImpl"></bean>
</beans>


3、测试接口 UserDAO

package cn.sz.dao;

public interface UserDAO {
public void save();
}


4.接口实现类

package cn.sz.dao.impl;

import cn.sz.dao.UserDAO;

//主要业务功能类
public class UserDAOImpl implements UserDAO {

@Override
public void save() {
// 测试出异常
// String a = null;
// a.length();
System.out.println("save...");
}

}


5、测试类

package cn.sz.test;

import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import cn.sz.dao.UserDAO;

public class AopTest {

@Test
public void test1() {
ApplicationContext ac = new ClassPathXmlApplicationContext("applicationContext.xml");
UserDAO userDAO = ac.getBean("userDao", UserDAO.class);
userDAO.save();
}
}


配置文件方式:

1、切面类

package cn.sz.aspect;

import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.After;
import org.aspectj.lang.annotation.AfterReturning;
import org.aspectj.lang.annotation.AfterThrowing;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Before;
import org.springframework.stereotype.Component;

//这是一个横向抽取非主要业务方法的类

public class MyAspect {

public void login(JoinPoint jp) {
// 获取连接点的信息
Object o = jp.getThis();
System.out.println(o);
// ((UserDao)o).delete();

System.out.println("login.......");
}

public void log4j() {
System.out.println("log4j......");
}

public void rou(ProceedingJoinPoint pjp) throws Throwable {
System.out.println("round......1");

pjp.proceed();

System.out.println("round......2");
}

public void exception() {
System.out.println("exception......");
}

public void finallyF() {
System.out.println("finallyF......");
}
}


2、主配置文件

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:user="http://www.springframework.org/schema/p"
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/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd
">
<!-- 创建非主要业务方法类的对象:切面 -->
<bean id="myAspect" class="com.sz.aspect.MyAspect"></bean>

<bean id="userDao" class="com.sz.dao.impl.UserDaoImpl"></bean>
<!-- 实现将非主要业务方法切入到主要业务方法中去 -->
<aop:config>
<!-- 将切面对象引入 -->
<aop:aspect ref="myAspect" id="my">
<!-- 定义切入点:在哪些地方实现切入 -->
<aop:pointcut expression="execution(* com.sz.dao.impl.UserDaoImpl.*(..))" id="p1"/>
<!-- 配置前通知 -->
<!-- method配置非主要业务方法/通知/关注点 -->
<aop:before method="login" pointcut-ref="p1"/>

<!-- 配置后通知 -->
<aop:after-returning method="log4j" pointcut-ref="p1"/>

<!-- 配置环绕通知 -->
<aop:around method="rou" pointcut-ref="p1"/>

<!-- 配置异常后通知 -->
<aop:after-throwing method="exception" pointcut-ref="p1"/>

<!-- 配置最终通知 -->
<aop:after method="finallyF" pointcut-ref="p1"/>
</aop:aspect>
</aop:config>
</beans>



3、测试接口UserDAO

package cn.sz.dao;

public interface UserDAO {
public void save();
}


4.接口实现类

package cn.sz.dao.impl;

import cn.sz.dao.UserDAO;

//主要业务功能类
public class UserDAOImpl implements UserDAO {

@Override
public void save() {
// 测试出异常
// String a = null;
// a.length();
System.out.println("save...");
}

}


5、测试类

package cn.sz.test;

import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import cn.sz.dao.UserDAO;

public class AopTest {

@Test
public void test1() {
ApplicationContext ac = new ClassPathXmlApplicationContext("applicationContext.xml");
UserDAO userDAO = ac.getBean("userDao", UserDAO.class);
userDAO.save();
}
}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: