@Transactional注解方法中事务何时提交？如何确保提交后再推送Redis队列？

首先明确核心：你当前的写法绝对不会先提交数据库事务再执行finally块的逻辑，实际执行顺序完全和你的预期相反。
Spring 的 @Transactional 注解是基于AOP代理机制实现的，事务的开启、提交、回滚动作全部是在你编写的目标方法的外层代理逻辑中执行，和方法内部的代码流完全解耦。真实的执行链路是：

• 代理层拦截方法调用，先开启数据库事务
• 完整执行你写的方法内部的所有代码：包括try块的数据库保存、catch块的异常日志、finally块的Redis推送，这一整个阶段事务一直处于开启未提交的状态
• 等你编写的整个方法完全执行完毕、正常返回后，代理层才会判断要不要提交事务
• 只有代理层完成事务提交后，整个事务的生命周期才结束

也就是说，finally块里的Redis推送逻辑执行时，数据库事务还处于挂起未提交的状态，如果后续事务提交失败（比如数据库死锁、连接中断、约束校验不通过），已经推送到Redis的消息就会和数据库实际状态不一致，产生脏数据。
另外这种写法还有额外的风险：Redis推送执行时数据库连接一直被事务占用，如果Redis推送逻辑耗时较长、甚至卡住，会直接拉长事务的持有时间，严重时会造成数据库连接池耗尽。
你当前代码还有一个隐藏问题：catch块捕获异常后只打印日志没有重新抛出，Spring的事务代理感知不到方法抛出的异常，哪怕数据库保存出错，事务依然会正常提交，完全达不到异常回滚的预期效果。

方案1：注册事务提交后执行的回调（最小改动适配现有代码） #

Spring 提供了事务同步机制，可以在当前线程的活动事务中注册回调，指定只有事务真正完成提交后才触发指定逻辑，事务回滚时不会执行该回调。
示例改造代码：

@Transactional
public void save(Entity t) {
    try {
         entityRepository.save(t);
         // 注册事务提交后的回调
         if (TransactionSynchronizationManager.isSynchronizationActive()) {
             TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
                 @Override
                 public void afterCommit() {
                     // 这里放原finally块中的Redis推送逻辑
                     pushEntityToRedis(t);
                 }
             });
         } else {
             // 兼容无事务的调用场景，避免逻辑丢失
             pushEntityToRedis(t);
         }
    } catch(Exception ex) {
         log.error("Error while executing transaction", ex);
    }
}

这个方案的好处是改动量极小，逻辑完全贴合原有结构，afterCommit 方法触发时数据库事务已经完成持久化提交，不存在脏推送的问题。

方案2：拆分事务边界和非事务逻辑 #

把数据库写操作的事务逻辑和Redis推送的非事务逻辑拆到不同的方法边界，从结构上保证事务先完成提交，再执行后续的Redis推送。
注意要避免同类内部自调用导致的事务失效问题，建议拆分到不同的类中：

// 专门承载事务逻辑的Service
@Service
public class EntityTransactionService {
    @Autowired
    private EntityRepository entityRepository;

    @Transactional
    public void saveToDb(Entity t) {
        entityRepository.save(t);
    }
}

// 业务编排层Service
@Service
public class EntityService {
    @Autowired
    private EntityTransactionService entityTransactionService;
    @Autowired
    private RedisTemplate redisTemplate;

    public void save(Entity t) {
        try {
            // 调用事务方法，等该方法返回时，事务已经完全提交
            entityTransactionService.saveToDb(t);
            // 事务提交完成后再执行Redis推送
            pushEntityToRedis(t);
        } catch (Exception ex) {
            log.error("Error while executing save flow", ex);
        }
    }
}

这个方案的优势是逻辑边界清晰，Redis推送的耗时操作不会长期占用数据库事务的连接资源，从根源上避免事务超时、数据库连接池耗尽的风险。

内容的提问来源于stack exchange，提问作者Sriram