国内优秀网站赏析/百度风云榜

Spring事务原理分析-部分二

说明：这是我在蚂蚁课堂学习了余老师Spring手写框架的课程的一些笔记，部分代码代码会用到余老师的课件代码。这不是广告，是我听了之后觉得很好。

课堂链接：Spring手写框架

手写Spring事务框架

编程事务实现

概述

所谓编程式事务指的是通过编码方式实现事务，即类似于JDBC编程实现事务管理。管理使用TransactionTemplate或者直接使用底层的PlatformTransactionManager。对于编程式事务管理，spring推荐使用TransactionTemplate。

使用编程事务实现手动事务

使用编程事务实现，手动事务 begin、commit、rollback

@Component
public class TransactionUtils {@Autowiredprivate DataSourceTransactionManager dataSourceTransactionManager;// 开启事务public TransactionStatus begin() {TransactionStatus transaction = dataSourceTransactionManager.getTransaction(new DefaultTransactionAttribute());return transaction;}// 提交事务public void commit(TransactionStatus transactionStatus) {dataSourceTransactionManager.commit(transactionStatus);}// 回滚事务public void rollback(TransactionStatus transactionStatus) {dataSourceTransactionManager.rollback(transactionStatus);}
}@Service
public class UserService {@Autowiredprivate UserDao userDao;@Autowiredprivate TransactionUtils transactionUtils;public void add() {TransactionStatus transactionStatus = null;try {transactionStatus = transactionUtils.begin();userDao.add("wangmazi", 27);int i = 1 / 0;System.out.println("我是add方法");userDao.add("zhangsan", 16);transactionUtils.commit(transactionStatus);} catch (Exception e) {e.printStackTrace();} finally {if (transactionStatus != null) {transactionStatus.rollbackToSavepoint(transactionStatus);}}}}

AOP技术封装手动事务

@Component
@Aspect
public class AopTransaction {@Autowiredprivate TransactionUtils transactionUtils;// // 异常通知@AfterThrowing("execution(* com.itmayiedu.service.UserService.add(..))")public void afterThrowing() {System.out.println("程序已经回滚");// 获取程序当前事务 进行回滚TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();}// 环绕通知@Around("execution(* com.itmayiedu.service.UserService.add(..))")public void around(ProceedingJoinPoint proceedingJoinPoint) throws Throwable {System.out.println("开启事务");TransactionStatus begin = transactionUtils.begin();proceedingJoinPoint.proceed();transactionUtils.commit(begin);System.out.println("提交事务");}}

使用事务注意事项

事务是程序运行如果没有错误,会自动提交事物,如果程序运行发生异常,则会自动回滚。

如果使用了try捕获异常时.一定要在catch里面手动回滚。

事务手动回滚代码

TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();

声明事务实现

概述

管理建立在AOP之上的。其本质是对方法前后进行拦截，然后在目标方法开始之前创建或者加入一个事务，在执行完目标方法之后根据执行情况提交或者回滚事务。声明式事务最大的优点就是不需要通过编程的方式管理事务，这样就不需要在业务逻辑代码中掺杂事务管理的代码，只需在配置文件中做相关的事务规则声明(或通过基于@Transactional注解的方式)，便可以将事务规则应用到业务逻辑中。

​ 显然声明式事务管理要优于编程式事务管理，这正是spring倡导的非侵入式的开发方式。

声明式事务管理使业务代码不受污染，一个普通的POJO对象，只要加上注解就可以获得完全的事务支持。和编程式事务相比，声明式事务唯一不足地方是，后者的最细粒度只能作用到方法级别，无法做到像编程式事务那样可以作用到代码块级别。但是即便有这样的需求，也存在很多变通的方法，比如，可以将需要进行事务管理的代码块独立为方法等等。

XML实现声明

注解版本声明

<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" xmlns:tx="http://www.springframework.org/schema/tx"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context.xsdhttp://www.springframework.org/schema/aophttp://www.springframework.org/schema/aop/spring-aop.xsdhttp://www.springframework.org/schema/txhttp://www.springframework.org/schema/tx/spring-tx.xsd"><!-- 开启注解 --><context:component-scan base-package="com.itmayiedu"></context:component-scan><!-- 1. 数据源对象: C3P0连接池 --><bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"><property name="driverClass" value="com.mysql.jdbc.Driver"></property><property name="jdbcUrl" value="jdbc:mysql://localhost:3306/test"></property><property name="user" value="root"></property><property name="password" value="root"></property></bean><!-- 2. JdbcTemplate工具类实例 --><bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"><property name="dataSource" ref="dataSource"></property></bean><!-- 配置事物 --><bean id="dataSourceTransactionManager"class="org.springframework.jdbc.datasource.DataSourceTransactionManager"><property name="dataSource" ref="dataSource"></property></bean><!-- 开启注解事物 --><tx:annotation-driven transaction-manager="dataSourceTransactionManager" />
</beans>

用法

@Transactionalpublic void add() {userDao.add("wangmazi", 27);int i = 1 / 0;System.out.println("我是add方法");userDao.add("zhangsan", 16);}

手写Spring注解版本事务

注解

Jdk1.5新增新技术，注解。很多框架为了简化代码，都会提供有些注解。可以理解为插件，是代码级别的插件，在类的方法上写：@XXX，就是在代码上插入了一个插件。

注解不会也不能影响代码的实际逻辑，仅仅起到辅助性的作用。

注解分类：内置注解(也成为元注解 jdk 自带注解)、自定义注解（Spring框架）

什么是内置注解

（1） @SuppressWarnings 再程序前面加上可以在javac编译中去除警告–阶段是SOURCE
（2） @Deprecated 带有标记的包，方法，字段说明其过时----阶段是SOURCE
（3）@Overricle 打上这个标记说明该方法是将父类的方法重写–阶段是SOURCE

@Overricle 案例演示

@Overridepublic String toString() {return null;}

@Deprecated案例演示

	new Date().parse("");

@SuppressWarnings 案例演示

@SuppressWarnings({ "all" })public void save() {java.util.List list = new ArrayList();}

实现自定义注解

元注解的作用就是负责注解其他注解。Java5.0定义了4个标准的meta-annotation类型，它们被用来提供对其它 annotation类型作说明。Java5.0定义的元注解：
@Target

@Target说明了Annotation所修饰的对象范围：Annotation可被用于 packages、types（类、接口、枚举、Annotation类型）、类型成员（方法、构造方法、成员变量、枚举值）、方法参数和本地变量（如循环变量、catch参数）。在Annotation类型的声明中使用了target可更加明晰其修饰的目标。

\1. CONSTRUCTOR:用于描述构造器

\2. FIELD:用于描述域

\3. LOCAL_VARIABLE:用于描述局部变量

\4. METHOD:用于描述方法

\5. PACKAGE:用于描述包

\6. PARAMETER:用于描述参数

\7. TYPE:用于描述类、接口(包括注解类型) 或enum声明

2.@Retention

表示需要在什么级别保存该注释信息，用于描述注解的生命周期（即：被描述的注解在什么范围内有效）
3.@Documented 4.@Inherited

使用@interface 定义注解。

@Target(value = { ElementType.METHOD })
@Retention(RetentionPolicy.RUNTIME)
public @interface AddAnnotation {int userId() defaultt 0;String userName() default "默认名称";String[]arrays();
}
反射读取注解信息public static void main(String[] args) throws ClassNotFoundException {Class classInfo = Class.forName("com.itmayiedu.entity.User");// 获取到所有方法Method[] methods = classInfo.getDeclaredMethods();for (Method method : methods) {System.out.println(method);AddAnnotation declaredAnnotation = method.getDeclaredAnnotation(AddAnnotation.class);if (declaredAnnotation == null) {// 结束本次循环continue;}// 获取userIdint userId = declaredAnnotation.userId();System.out.println("userId:" + userId);// 获取userNameString userName = declaredAnnotation.userName();System.out.println("userName:" + userName);// 获取arraysString[] arrays = declaredAnnotation.arrays();for (String str : arrays) {System.out.println("str:" + str);}}}

自定义事务注解

//编程事务（需要手动begin 手动回滚  手都提交）
@Component()
@Scope("prototype") // 设置成原型解决线程安全
public class TransactionUtils {private TransactionStatus transactionStatus;// 获取事务源@Autowiredprivate DataSourceTransactionManager dataSourceTransactionManager;// 开启事务public TransactionStatus begin() {transactionStatus = dataSourceTransactionManager.getTransaction(new DefaultTransactionAttribute());return transactionStatus;}// 提交事务public void commit(TransactionStatus transaction) {dataSourceTransactionManager.commit(transaction);}// 回滚事务public void rollback() {System.out.println("rollback");dataSourceTransactionManager.rollback(transactionStatus);}}注解类@Autowiredprivate TransactionUtils transactionUtils;@AfterThrowing("execution(* com.itmayiedu.service.*.*.*(..))")public void afterThrowing() throws NoSuchMethodException, SecurityException {// isRollback(proceedingJoinPoint);System.out.println("程序发生异常");// TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();// TransactionStatus currentTransactionStatus =// TransactionAspectSupport.currentTransactionStatus();// System.out.println("currentTransactionStatus:" +// currentTransactionStatus);transactionUtils.rollback();}// // 环绕通知 在方法之前和之后处理事情@Around("execution(* com.itmayiedu.service.*.*.*(..))")public void around(ProceedingJoinPoint proceedingJoinPoint) throws Throwable {// 调用方法之前执行TransactionStatus transactionStatus = begin(proceedingJoinPoint);proceedingJoinPoint.proceed();// 代理调用方法 注意点： 如果调用方法抛出异常不会执行后面代码// 调用方法之后执行commit(transactionStatus);}public TransactionStatus begin(ProceedingJoinPoint pjp) throws NoSuchMethodException, SecurityException {// // 判断是否有自定义事务注解ExtTransaction declaredAnnotation = getExtTransaction(pjp);if (declaredAnnotation == null) {return null;}// 如果有自定义事务注解，开启事务System.out.println("开启事务");TransactionStatus transactionStatu = transactionUtils.begin();return transactionStatu;}public void commit(TransactionStatus transactionStatu) {if (transactionStatu != null) {// 提交事务System.out.println("提交事务");transactionUtils.commit(transactionStatu);}}public ExtTransaction getExtTransaction(ProceedingJoinPoint pjp) throws NoSuchMethodException, SecurityException {// 获取方法名称String methodName = pjp.getSignature().getName();// 获取目标对象Class<?> classTarget = pjp.getTarget().getClass();// 获取目标对象类型Class<?>[] par = ((MethodSignature) pjp.getSignature()).getParameterTypes();// 获取目标对象方法Method objMethod = classTarget.getMethod(methodName, par);// // 判断是否有自定义事务注解ExtTransaction declaredAnnotation = objMethod.getDeclaredAnnotation(ExtTransaction.class);if (declaredAnnotation == null) {System.out.println("您的方法上,没有加入注解!");return null;}return declaredAnnotation;}// 回滚事务public void isRollback(ProceedingJoinPoint pjp) throws NoSuchMethodException, SecurityException {// // 判断是否有自定义事务注解ExtTransaction declaredAnnotation = getExtTransaction(pjp);if (declaredAnnotation != null) {System.out.println("已经开始回滚事务");// 获取当前事务 直接回滚TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();return;}}使用自定义注解@ExtTransaction
public void add() {
userDao.add("test001", 20);
int i = 1 / 0;
System.out.println("################");
userDao.add("test002", 21);
}