Spring之AOP详解

/**
 * 定义公共接口
 * @author dpb[波波烤鸭]
 *
 */
public interface SomeService {
	String doSome();
	
	String say();
}

/**
 * 实现类
 * @author dpb[波波烤鸭]
 *
 */
public class SomeServiceImpl implements SomeService{
	@Override
	public String doSome() {
		System.out.println("doSome ...");
		return "hello";
	}

	@Override
	public String say() {
		System.out.println("say ...");
		return null;
	}
}

/**
 * 切面  前置通知
 * @author dpb[波波烤鸭]
 *
 */
public class MyMethodBeforeAdvice implements MethodBeforeAdvice {
	/**
	 * method 目标方法
	 * args 目标方法参数列表
	 * target 目标对象
	 */
	@Override
	public void before(Method method, Object[] args, Object target) throws Throwable {
		// TODO Auto-generated method stub
		System.out.println("前置通知的before方法执行...");
	}
}

<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"
	xmlns:context="http://www.springframework.org/schema/context"
	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-4.3.xsd">
	<!-- 注册目标类 -->
	<bean id="someServiceImpl" class="com.dpb.service.SomeServiceImpl" ></bean>
	<!-- 注册前置通知 -->
	<bean class="com.dpb.aspects.MyMethodBeforeAdvice" id="myMethodBeforeAdvice"></bean>

	<!-- 注册代理类 -->
	<bean id="proxyFactoryBean" class="org.springframework.aop.framework.ProxyFactoryBean">
		<!-- 指定目标对象 -->
		<property name="target" ref="someServiceImpl"/>
		<!-- 指定目标类实现的所有接口 -->
		<property name="interfaces" value="com.dpb.service.SomeService"/>
		<!-- 指定切面 -->
		<property name="interceptorNames" >
			<list>
				<value>myMethodBeforeAdvice</value>
			</list>
		</property>
	</bean>
</beans>

public class Test {

	public static void main(String[] args) {
		ApplicationContext ac = new ClassPathXmlApplicationContext("application.xml");
		// 注意通过getBean获取增强的代理类！！！
		SomeService some = ac.getBean("proxyFactoryBean",SomeService.class);
		some.doSome();
		some.say();
	}

}

/**
 * 后置通知切面类
 * @author dpb[波波烤鸭]
 *
 */
public class MyAfterRunningAdvice implements AfterReturningAdvice{

	/**
	 * @param returnValue 目标方法返回值
	 * @param method 目标方法
	 * @param args 目标方法参数
	 * @param target 目标对象
	 */
	@Override
	public void afterReturning(Object returnValue, Method method, Object[] args, Object target) throws Throwable {
		System.out.println("后置方法执行了..."+returnValue);
	}
}

/**
 * 环绕通知 切面类
 * @author dpb[波波烤鸭]
 *
 */
public class MyMethodInterceptor implements MethodInterceptor {
	/**
	 * @param invocation 方法调用器
	 */
	@Override
	public Object invoke(MethodInvocation invocation) throws Throwable {
		System.out.println("环绕通知 --- 1");
		Object res = invocation.proceed();
		if(res !=null){
			// 增强返回结果
			res = ((String)res).toUpperCase();
		}
		System.out.println("环绕通知---2");
		return res;
	}
}

/**
 * 异常通知切面类
 *    
 * @author dpb[波波烤鸭]
 *
 */
public class MyThrowsAdvice implements ThrowsAdvice {

	public void afterThrowing(Exception ex){
		System.out.println("异常发生了...");
	}
}

@Aspect // 表示是一个切面类
public class MyAspect {

	@Before("execution(* com.dpb.service.*.doSome(..))")
	public void beforeMethod(){
		System.out.println("前置通知");
	}
}

<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xmlns:p="http://www.springframework.org/schema/p"
	xmlns:context="http://www.springframework.org/schema/context"
	xmlns:aop="http://www.springframework.org/schema/aop"
	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-4.3.xsd
		http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.3.xsd">
	<!-- 注册目标类 -->
	<bean id="someServiceImpl" class="com.dpb.service.SomeServiceImpl" />
	<!-- 注册切面类 -->
	<bean class="com.dpb.aspect.MyAspect" id="myAspect"/>
	<!-- 注册自动代理 -->
	<aop:aspectj-autoproxy/>
</beans>

@Aspect // 表示是一个切面类
public class MyAspect {

	/*@Before("execution(* com.dpb.service.*.doSome(..))")
	public void beforeMethod(){
		System.out.println("前置通知");
	}*/
	/**
	 * 后置通知
	 */
	@AfterReturning(value="execution(* com.dpb.service.*.doSome(..))",returning="msg")
	public void beforeMethod(Object msg){
		System.out.println("后置通知..."+msg);
	}
}

@Aspect // 表示是一个切面类
public class MyAspect {

	/*@Before("execution(* com.dpb.service.*.doSome(..))")
	public void beforeMethod(){
		System.out.println("前置通知");
	}*/
	/**
	 * 后置通知
	 * @throws Throwable 
	 */
	/*@AfterReturning(value="execution(* com.dpb.service.*.doSome(..))",returning="msg")
	public void beforeMethod(Object msg){
		System.out.println("后置通知..."+msg);
	}*/
	
	/**
	 * 环绕通知
	 * @param pjp
	 * @return
	 * @throws Throwable
	 */
	@Around("execution(* *..service.*.*(..))")
	public Object around(ProceedingJoinPoint pjp) throws Throwable{
		System.out.println("环绕通知...1");
		Object res = pjp.proceed();
		System.out.println("环绕通知...2"+res);
		res = res+" ... aaa";
		return res;
	}
}

	@AfterThrowing("execution(* *..service.*.*(..))")
	public void throwsMethod(){
		System.out.println("异常触发了...");
	}

	/**
	 * 最终通知
	 */
	@After("execution(* *..service.*.*(..))")
	public void after(){
		System.out.println("最终通知...");
	}

/**
 * 切面类
 * @author dpb[波波烤鸭]
 *
 */
public class MyAspect {

	/**
	 * 前置通知
	 */
	public void beforeMethod(){
		System.out.println("前置通知");
	}
	/**
	 * 后置通知
	 */
	public void afterMethod(Object msg){
		System.out.println("后置通知..."+msg);
	}
	
	/**
	 * 环绕通知
	 */
	public Object around(ProceedingJoinPoint pjp) throws Throwable{
		System.out.println("环绕通知...1");
		Object res = pjp.proceed();
		System.out.println("环绕通知...2"+res);
		res = res+" ... aaa";
		return res;
	}
	/**
	 * 异常通知
	 */
	public void throwsMethod(Exception e){
		System.out.println("异常触发了...");
	}
	
	/**
	 * 最终通知
	 */
	public void after(){
		System.out.println("最终通知...");
	}
}

<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xmlns:p="http://www.springframework.org/schema/p"
	xmlns:context="http://www.springframework.org/schema/context"
	xmlns:aop="http://www.springframework.org/schema/aop"
	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-4.3.xsd
		http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.3.xsd">
	<!-- 注册目标类 -->
	<bean id="someServiceImpl" class="com.dpb.service.SomeServiceImpl" />
	<!-- 注册切面类 -->
	<bean class="com.dpb.aspect.MyAspect" id="myAspect"/>
	<aop:config>
		<!-- 配置切入点 -->
		<aop:pointcut expression="execution(* *..service.*.*(..))" id="pointcut"/>
		<!-- 配置切面类 -->
		<aop:aspect ref="myAspect">
			<!-- 前置通知 -->
			<aop:before method="beforeMethod" pointcut-ref="pointcut"/>
		</aop:aspect>
	</aop:config>
</beans>

<!-- 配置数据源 -->
<bean class="org.springframework.jdbc.datasource.DriverManagerDataSource" id="dataSource">
	<!-- 配置数据库的相关信息 -->
	<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
	<property name="url" value="jdbc:mysql://localhost:3306/pms?characterEncoding=utf-8"/>
	<property name="username" value="root"/>
	<property name="password" value="123456"/>
</bean>

public class TestJdbc {

	JdbcTemplate jdbcTemplate;
	// Oracle的相关配置信息
	@Before
	public void beforeMethod(){
		DriverManagerDataSource ds = new DriverManagerDataSource();
		ds.setUrl("jdbc:oracle:thin:@localhost:1521:orcl");
		ds.setDriverClassName("oracle.jdbc.driver.OracleDriver");
		ds.setUsername("pms");
		ds.setPassword("pms");
		jdbcTemplate = new JdbcTemplate(ds);
	}
	
	/**
	 * 添加数据
	 */
	@Test
	public void add(){
		jdbcTemplate.update("insert into t_sysuser(id,uname,nickname)values(?,?,?)",133,"aaa","测试");
		//System.out.println("111");
	}
	/**
	 * 修改数据
	 */
	@Test
	public void udpate(){
		jdbcTemplate.update("update t_sysuser set uname=? ,nickname=? where id=?","bbb","呵呵",133);
		//System.out.println("111");
	}
	/**
	 * 删除数据
	 */
	@Test
	public void delete(){
		jdbcTemplate.update("delete from t_sysuser where id=?",133);
		//System.out.println("111");
	}
	
	/**
	 * 查询数据第一种方式
	 */
	@Test
	public void query(){
		List<User> list = jdbcTemplate.query("select * from t_sysuser", new RowMapper<User>() {

			@Override
			public User mapRow(ResultSet rs, int index) throws SQLException {
				User u = new User();
				u.setId(rs.getInt("id"));
				u.setUname(rs.getString("uname"));
				u.setNickname(rs.getString("nickname"));
				return u;
			}
			
		});
		for (User user : list) {
			System.out.println(user);
		}
		//System.out.println("111");
	}
	
	/**
	 * 查询数据第二种方式
	 */
	@Test
	public void query1(){
		List<User> list = jdbcTemplate.query("select * from t_sysuser", new BeanPropertyRowMapper<User>(User.class));
		for (User user : list) {
			System.out.println(user);
		}
	}
}