手写事务注解的思路:
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
