问题背景
当我们在事务提交的过程中对一些缓存的数据操作时,例如更新了某个对象,需要删除改对象对应的redis缓存,才能保证下次查询得到的数据与数据库一致;
但是在事务未提交之前执行了删除缓存的操作,数据库是还未更新,如果此时有高并发请求,就会造成缓穿透,造成缓存的数据与数据库的数据不一致导致问题,所以解决该问题就一定得保证对缓存的更新得在数据入库(事务完成)之后;
最简单的实现方案就是代码自己控制,在调用时一定确保了事务已提交再统一更新缓存,但是这样做无疑增加了开发的复杂性,把实际业务和更新缓存分开了,那有没有更好的实现方案呢?
解决方案
TransactionEventListener
-在Spring4.2+，有一种TransactionEventListener的方式，能够控制在事务的时候Event事件的处理方式。
我们知道，Spring的发布订阅模型实际上并不是异步的，而是同步的来将代码进行解耦。而TransactionEventListener仍是通过这种方式，只不过加入了回调的方式来解决，这样就能够在事务进行Commited，Rollback...等的时候才会去进行Event的处理。 具体的解决思路就是在事务中当我们更新缓存时不直接更新,而是发布一个事件,在事务提交之后监听这个事件,再统一更新缓存,这时就可确保数据已入库
定义event
继承ApplicationEvent
定义监听
事务提交之后事件监听
在事务中不直接更新缓存,而是发布事件,注入ApplicationEventPublisher eventPublisher
发布事件
ps.因为看起来事件发布和事件监听并没有强关联，会不会出现其他事务也提交事件干扰的现象呢？
首先TransactionalEventListener本质上是一个@EventListener
TransactionalEventListenerFactory类会对将每一个扫描到的注解有TransactionalEventListener包装成ApplicationListenerMethodTransactionalAdapter对象；
通过ApplicationListenerMethodTransactionalAdapter的onApplicationEvent方法可以看到,是向TransactionSynchronizationManager中注册了一个TransactionSynchronization,就是将这个event注册到与事务向关联的管理器中,当事务执行到不同的阶段,会通过TransactionSynchronizationManager获取不同的同步事件,从而完成事件的回调.
所以综上,@TransactionalEventListener监听的事件其实是会被绑定给当前事务的,只有当前事务执行到指定过程才会去回调事件,并不会被其他事务影响.
网友评论