本文共 10482 字，大约阅读时间需要 34 分钟。

编程事务实现:

   	
    	
     
    	
    	
    		
     		
     		
     		
     	
    	
    	
    		
     	
    	
    	
    		
     	
    	
    	
    />
   

@Componentpublic class TransactionUtils {
   	@Autowired	private 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);	}}

public class UserDao {
   	@Autowired	private JdbcTemplate jdbcTemplate;	public void add(String name, Integer age) {
   		String sql = "INSERT INTO users(NAME, age) VALUES(?,?);";		int update = jdbcTemplate.update(sql, name, age);		System.out.println("insertResult:" + update);	}}

@Servicepublic class UserService {
   	@Autowired	private UserDao userDao;	@Autowired	private 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@Aspectpublic class AopTransaction {
   	@Autowired	private 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里面手动回滚。

声明事务实现:

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

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

配置：

用法:@Transactional

手写Spring注解版本事务:

实现自定义注解

@Target

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

2.@Retention

自定义注解案例:

/** * 自定义注解 * * @author 孙一鸣 on 2020/2/27 * @interface 定义注解 */@Target(ElementType.METHOD)@Retention(RetentionPolicy.RUNTIME)public @interface MyAnnotation {
       int userId() default 0;    String userName() default "默认名称";    String[] arrs();}

如何通过反射获取注解信息：

/** * @author 孙一鸣 on 2020/2/27 * 测试注解 */public class User {
       @MyAnnotation(userId = 1, userName = "孙一", arrs = {
   "1"})    public void add() {
       }    public void del() {
       }    public static void main(String[] args) throws ClassNotFoundException {
           //如何获取注解信息？ --- 反射        Class
    UserClass = Class.forName("Annotation.User");        //获取当前类 不包括父类的所有方法        Method[] methods = UserClass.getDeclaredMethods();        for (Method method : methods) {
               //获取该方法是否有注解            MyAnnotation myAnnotation = method.getDeclaredAnnotation(MyAnnotation.class);            if (myAnnotation == null) {
                   System.out.println(method.getName() + "该方法上没有注解...");                continue;            }            System.out.println("userID " + myAnnotation.userId());            System.out.println("userName " + myAnnotation.userName());            System.out.println("arrs " + myAnnotation.arrs().toString());        }    }}

手写Spring事务注解思路：

代码实现:

   
       
    
     4.0.0
        
    
     newSpring
        
    
     Annotation
        
    
     1.0-SNAPSHOT
        
            
                 
      
       org.springframework
                  
      
       spring-core
                  
      
       4.3.7.RELEASE
              
             
                 
      
       org.springframework
                  
      
       spring-beans
                  
      
       4.3.7.RELEASE
              
             
                 
      
       org.springframework
                  
      
       spring-context
                  
      
       4.3.7.RELEASE
              
             
                 
      
       org.springframework
                  
      
       spring-aspects
                  
      
       4.3.7.RELEASE
              
             
                 
      
       org.springframework
                  
      
       spring-jdbc
                  
      
       4.3.7.RELEASE
              
             
                 
      
       mysql
                  
      
       mysql-connector-java
                  
      
       5.1.41
              
             
                 
      
       com.mchange
                  
      
       c3p0
                  
      
       0.9.5.1
              
         
    
   

package com.sym.aop;import java.lang.annotation.ElementType;import java.lang.annotation.Retention;import java.lang.annotation.RetentionPolicy;import java.lang.annotation.Target;//自定义事务注解@Target(value = {
    ElementType.METHOD })@Retention(RetentionPolicy.RUNTIME)public @interface ExtTransaction {
   }

package com.sym.aop;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.context.annotation.Scope;import org.springframework.jdbc.datasource.DataSourceTransactionManager;import org.springframework.stereotype.Component;import org.springframework.transaction.TransactionStatus;import org.springframework.transaction.interceptor.DefaultTransactionAttribute;//编程事务（需要手动begin 手动回滚  手都提交）@Component()@Scope("prototype") // 设置成原型解决线程安全public class TransactionUtils {
   	private TransactionStatus transactionStatus;	// 获取事务源	@Autowired	private 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);	}}

package com.sym.aop;import java.lang.reflect.Method;import org.aspectj.lang.ProceedingJoinPoint;import org.aspectj.lang.annotation.AfterThrowing;import org.aspectj.lang.annotation.Around;import org.aspectj.lang.annotation.Aspect;import org.aspectj.lang.reflect.MethodSignature;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.stereotype.Component;import org.springframework.transaction.TransactionStatus;import org.springframework.transaction.interceptor.TransactionAspectSupport;@Component@Aspectpublic class AopExtTransaction {
   	@Autowired	private TransactionUtils transactionUtils;	@AfterThrowing("execution(public void com.sym.dao.UserDao.*(..))")	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(public void com.sym.dao.UserDao.*(..))")	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;		}	}}

转载地址：http://zmthn.baihongyu.com/