背景

消息中间件为activeMq

事务回滚时消息无法回滚

有频繁的查询缓存操作

场景1

@Transactionalvoid xxxMethod(){    clearCache();------#1    dealData();------#2    sendMessage();}复制代码

以上代码会出现缓存和数据库不一致情况

原因分析

在#1、#2操作之间 有查询缓存操作，把脏数据写入缓存，导致缓存和数据库数据不一致

场景2

处理完数据以后再清除缓存，保证缓存和数据库的最终一致性

@Transactionalvoid xxxMethod(){    dealData();------#1    clearCache();------#2    sendMessage();    ....}------#4@Overridepublic void handleMessage(MessageVO messageVO) {   ....   getCache();------#3}复制代码

为场景1的进阶版本，依旧会出现缓存和数据库不一致情况

原因分析

在#2、#4之间有缓存的查询操作，可能为消息处理类的操作#3，也可能为外部查询请求。 由于事务未提交，数据库的数据为更新，导致缓存加载的依旧是旧数据，从而导致缓存和数据库的数据不一致。

解决方案

void xxxMethod(){    xxxMethod();    clearCache();    sendMessage();}@Transactionalvoid xxxMethod(){    dealData();    ....}复制代码

只能保证缓存和数据库的最终一致性，高并发情况下可能有瞬间的数据错误。