手写@Transational事务注解

手写事务注解的思路:

1,定义事务注解
2,封装手动事务
3,扫包--定义一个事务扫包AOP
4,拦截方法的时候,使用反射判断该方法是否加了事务注解,有就开启事务

1. 定义事务注解

/**
 * 手写事务注解:
 *  1,定义事务注解
 *  
 *  @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声明
 *  
 *  @Retention
 *  表示需要在什么级别保存该注释信息，用于描述注解的生命周期（即：被描述的注解在什么范围内有效）
 */
@Target({ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
public @interface LpTransactional {
    
}

2. 封装手动事务

/**
 * 手写事务注解:
 *  2,封装手动事务
 */
@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 transactionStatus) {
        dataSourceTransactionManager.commit(transactionStatus);
    }

    // 回滚事务
    public void rollback() {
        dataSourceTransactionManager.rollback(transactionStatus);
    }

}

3. 扫包拦截加事务

/**
 * 手写事务注解:
 *  3,扫包--定义一个事务扫包AOP
 *  4,拦截方法的时候,使用反射判断该方法是否加了事务注解,有就开启事务
 */
@Aspect
@Component
public class LpAopTransaction {
    @Autowired
    private TransactionUtils transactionUtils;

    //异常通知
    @AfterThrowing("execution(* com.pliu.service.*.*.*(..))")
    public void afterThrowing() {
        System.out.println("---回滚事务---");
        transactionUtils.rollback();
    }




    //环绕通知 在方法之前和之后处理事情
    @Around("execution(* com.pliu.service.*.*.*(..))")
    public void around(ProceedingJoinPoint pjp) throws Throwable {

        TransactionStatus transactionStatus = begin(pjp);
        //调用目标代理对象方法
        pjp.proceed();

        commit(transactionStatus);

    }


    /**
     * 判断事务状态,提交事务
     * @param transactionStatus
     */
    private void commit(TransactionStatus transactionStatus) {
        if (transactionStatus != null) {
            System.out.println("---提交事务---");
            transactionUtils.commit(transactionStatus);
        }
    }



    /**
     * 判断是否有@LpTransactional事务注解,有的话开启事务
     * @param pjp
     * @return null或事务状态transactionStatus
     * @throws NoSuchMethodException
     */
    private TransactionStatus begin(ProceedingJoinPoint pjp) throws NoSuchMethodException {
        //1,获取代理对象的方法
        LpTransactional lpTransactional = getLpTransactional(pjp);
        TransactionStatus transactionStatus = null;
        if (lpTransactional != null) {
            //3,加了的话开始事务
            System.out.println("---开启事务---");
            transactionStatus = transactionUtils.begin();
        }
        return transactionStatus;
    }

    /**
     * 获取代理对象的方法,判断是否有@LpTransactional事务注解
     * @param pjp
     * @return null或者LpTransactional对象
     * @throws NoSuchMethodException
     */
    private LpTransactional getLpTransactional(ProceedingJoinPoint pjp) throws NoSuchMethodException {
        // 获取方法名称
        String methodName = pjp.getSignature().getName();
        // 获取目标对象
        Class<?> classTarget = pjp.getTarget().getClass();
        // 获取目标对象类型
        Class<?>[] par = ((MethodSignature) pjp.getSignature()).getParameterTypes();
        // 获取目标对象方法
        Method objMethod = classTarget.getMethod(methodName, par);
        LpTransactional lpTransactional = objMethod.getDeclaredAnnotation(LpTransactional.class);
        return lpTransactional;
    }
}

4. 配置类和测试类

• 配置类

/**
 * @Description: 声明式事务配置类
 * 笔记:注解方式的声明式事务使用步骤:
 *      1,导入相关依赖(数据源、数据库驱动、Spring-jdbc模块)
 *      2,配置数据源、JdbcTemplate（Spring提供的简化数据库操作的工具）操作数据
 *      3,给方法上标注@Transactional 表示当前方法是一个事务方法；
 *      4,@EnableTransactionManagement 开启基于注解的事务管理功能；
 *      5,配置事务管理器来控制事务;
 *          @Bean
 *          public PlatformTransactionManager/DataSourceTransactionManager transactionManager()
 *      以上5步;
 */
@EnableAspectJAutoProxy        //开启AOP代理自动配置
@EnableTransactionManagement   //基于注解的事务管理
@ComponentScan({"com.pliu"})     //扫包路径
@Configuration
public class TxConfig {

    @Bean
    public DataSource dataSource() throws Exception {
        ComboPooledDataSource dataSource = new ComboPooledDataSource();
        //数据源请更换成你自己的
        dataSource.setUser("xxxx");
        dataSource.setPassword("xxxxxxxx");
        dataSource.setDriverClass("com.mysql.jdbc.Driver");
        dataSource.setJdbcUrl("jdbc:mysql://47.98.216.253:3306/pliu?useUnicode=true&characterEncoding=UTF-8");
        return dataSource;
    }
    @Bean
    public JdbcTemplate jdbcTemplate() throws Exception {
        //spring对@Configuration配置类有特殊处理,不会重复创建数据源对象
        return new JdbcTemplate(dataSource());
    }

    //注册事务管理器
    @Bean
    public DataSourceTransactionManager platformTransactionManager() throws Exception {
        return new DataSourceTransactionManager(dataSource());
    }


}

• 测试类

public class mainTest {

    public static void main(String[] args) {

        AnnotationConfigApplicationContext applicationContext =
                new AnnotationConfigApplicationContext(TxConfig.class);
        UserService userService = (UserService) applicationContext.getBean("userServiceImpl");
        userService.add();
    }


}

完整demo地址: https://gitee.com/hellopliu/transactionalDemo/tree/master