下 被标记为事务的方法互相调用的坑

参考:
上一节,主要分析了 被标记为事务的方法互相调用,事务失效的原因,思考比较多,这一节主要说说解决方案,思考会少一些 。
####解决方案的核心: 通过代理对象去调用方法
1.把方法放到不同的类:
我们需要新建一个接口:
public interface OtherService {void insertCodeMonkey();}
再定义一个类去实现这个接口:
@Servicepublic class OtherServiceImpl implements OtherService {@AutowiredAccountMapper mapper;@Override@Transactional(propagation=Propagation.REQUIRES_NEW)public void insertCodeMonkey() {Account account = new Account();account.setAccount("CodeMonkey");account.setPassword("CodeMonkey");mapper.insert(account);int a = 1 / 0;}}
修改原本的实现类:
@Servicepublic class AccountSerivceImpl implements AccountService {@AutowiredAccountMapper mapper;@AutowiredOtherService otherService;@Transactional@Overridepublic void insertCodeBear() {try {otherService.insertCodeMonkey();} catch (Exception e) {e.printStackTrace();}Account account = new Account();account.setAccount("CodeBear");account.setPassword("CodeBear");mapper.insert(account);}}
【下被标记为事务的方法互相调用的坑】运行,查看数据库:
只有一条数据,方法执行成功了,执行失败,并且回滚了 。
让我们再看看控制台的日志:

下  被标记为事务的方法互相调用的坑

文章插图
可以看到是开了两个事务去执行的 。
这种解决方案最简单,不需要了解其他东西,但是这种方案需要修改代码结构,本来两个方法都是属于同一个类的,现在需要强行把它们拆开 。
2. :
我们的目标是要在实现类中获取本类的代理对象,提供了Aop上下文,即:,通过,可以很方便的获取到代理对象:
@Servicepublic class AccountSerivceImpl implements AccountService {@AutowiredAccountMapper mapper;@Transactional@Overridepublic void insertCodeBear() {try {((AccountService)AopContext.currentProxy()).insertCodeMonkey();} catch (Exception ex) {ex.printStackTrace();}Account account = new Account();account.setAccount("CodeBear");account.setPassword("CodeBear");mapper.insert(account);}@Transactional(propagation = Propagation.REQUIRES_NEW)@Overridepublic void insertCodeMonkey() {Account account = new Account();account.setAccount("CodeMonkey");account.setPassword("CodeMonkey");mapper.insert(account);int a = 1 / 0;}}
当写好代码,很愉快的去测试,发现竟然报错了:
下  被标记为事务的方法互相调用的坑

文章插图
翻译下:不能找到当前的代理,需要设置属性为 true使其可以 。
字面意思就是 暴露 。也就是说 我们需要允许暴露代理 。
我们需要在 Boot启动类上+一个注解:
@EnableAspectJAutoProxy(exposeProxy = true)@SpringBootApplication@MapperScan(basePackages = "com.codebear.Dao")public class SpringbootApplication {public static void main(String[] args) throws Exception {SpringApplication.run(SpringbootApplication.class, args);}}
再次运行:
下  被标记为事务的方法互相调用的坑

文章插图
确实是开启了两个事务去执行的 。
再看看数据库,也没有问题 。
3. :
@Servicepublic class AccountSerivceImpl implements AccountService {@AutowiredAccountMapper mapper;@AutowiredApplicationContext context;AccountService service;@PostConstructprivate void setSelf() {service = context.getBean(AccountService.class);}@Transactional@Overridepublic void insertCodeBear() {try {service.insertCodeMonkey();} catch (Exception e) {e.printStackTrace();}Account account = new Account();account.setAccount("CodeBear");account.setPassword("CodeBear");mapper.insert(account);}@Transactional(propagation = Propagation.REQUIRES_NEW)@Overridepublic void insertCodeMonkey() {Account account = new Account();account.setAccount("CodeMonkey");account.setPassword("CodeMonkey");mapper.insert(account);int a = 1 / 0;}}
验证的图片就省略了 。
此方法不适用于
在这里,我用了一个@注解,在初始化的时候,会调用被@标记的方法(注意,仅仅是初始化的时候,才会被调用 。以后都不会被调用了,大家可以打个断点试一下),这里这么做的目的就是为了提升一下效率,不用每次都 。所以如果这个类是的,就不适用这个方法了 。如果是的话,就在方法中使用方法吧 。
上两种方法比较方便,没有新建其他的接口或者是类,但是没有很好的封装获得Aop代理对象的过程,也不是很符合 迪比特法则,也就是最少知识原则 。
4. 重写接口:
关于这个接口是做什么的,这里就不详细阐述了,简单的来说这是提供的接口,我们可以通过重写它,在初始化Bean之前或者之后,自定义一些额外的逻辑 。
首先,我们需要定义一个接口:
public interface WeavingSelfProxy {void setSelfProxy(Object bean);}
要获得代理对象的类,需要去实现它:
@Servicepublic class AccountSerivceImpl implements AccountService, WeavingSelfProxy {@AutowiredAccountMapper mapper;AccountService service;@Overridepublic void setSelfProxy(Object bean) {System.out.println("进入到setSelfProxy方法");service = (AccountService) bean;}@Transactional@Overridepublic void insertCodeBear() {try {service.insertCodeMonkey();} catch (Exception e) {e.printStackTrace();}Account account = new Account();account.setAccount("CodeBear");account.setPassword("CodeBear");mapper.insert(account);}@Transactional(propagation = Propagation.REQUIRES_NEW)@Overridepublic void insertCodeMonkey() {Account account = new Account();account.setAccount("CodeMonkey");account.setPassword("CodeMonkey");mapper.insert(account);int a = 1 / 0;}}
重写接口:
@Componentpublic class SetSelfProxyProcessor implements BeanPostProcessor {@Overridepublic Object postProcessBeforeInitialization(Object bean, String beanName) throws BeansException {return bean;}@Overridepublic Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException {if(bean instanceof WeavingSelfProxy){System.out.println("实现了WeavingSelfProxy接口");((WeavingSelfProxy) bean).setSelfProxy(bean);}return bean;}}
这样就可以了,验证的图片也省略了 。
以上就是四种解决方案,可以说 各有千秋,没有哪个好,哪个坏,只有适不适合 。