MQ监听器流程中Hibernate save()仅在监听器执行完成后持久化问题

当前数据延迟落库的核心原因是Spring默认会为@JmsListener修饰的消息监听器方法绑定统一的事务边界：整个receiveMessage方法执行过程处于同一个数据库事务内。Hibernate的save()方法仅会将实体对象加入持久化上下文，不会立刻执行SQL写入磁盘，只有当整个方法执行完毕、事务提交时，数据才会真正写入数据库，因此耗时较长的sendAPNS()执行期间，用户数据始终不会落库。

方案1：拆分持久化逻辑到独立事务（最推荐，一致性风险最低） #

利用Spring事务传播机制，把持久化操作放到独立事务中，和外层监听器的事务解绑，持久化方法执行完立刻提交事务刷库，不等待后续APNS逻辑执行。

1. 将持久化逻辑抽到单独的Spring托管Bean中，给方法添加@Transactional注解，指定传播级别为REQUIRES_NEW：该级别会在方法执行时挂起外层事务，新开独立事务，方法返回即提交事务。

   @Service
   public class UserPersistService {
       @Autowired
       private UserDao userDao;
   
       // 独立事务，执行完立刻提交
       @Transactional(propagation = Propagation.REQUIRES_NEW)
       public String persistUserDetails(UserDetailsVO userObject) {
           userDao.save(userObject);
           return "success";
       }
   }
   

   注意：该方法不能和监听器方法写在同一个类中，否则Spring AOP事务拦截会因内部类调用失效；如果一定要放在同类，需要注入自身代理对象调用方法。
2. 在MQ监听器中注入独立Bean调用持久化方法即可，原有APNS逻辑不需要调整：

   @Autowired
   private UserPersistService userPersistService;
   
   @JmsListener(destination = "${mq.queue.name}")
   public void receiveMessage(String user) throws IOException {
       try {
           UserDetailsVO userObject = mapper.readValue(user, UserDetailsVO.class);
           // 该行执行完就会提交事务，数据立刻落库
           String result = userPersistService.persistUserDetails(userObject);           
           if(result.equalsIgnoreCase("success")) {
               userService.sendAPNS(); // 发通知逻辑不会阻塞数据持久化
           }
       } catch(Exception e) {
           // 修复原代码日志语法错误
           logger.error("Error processing MQ message", e);      
       }
   }
   

方案2：手动控制事务提交（适合不想拆分Bean的场景） #

如果不想拆分Service类，可以注入事务管理器手动控制事务提交，代码侵入性更强：

@Autowired
private PlatformTransactionManager transactionManager;

public String persistUserDetails(UserDetailsVO userObject) {
    TransactionStatus txStatus = transactionManager.getTransaction(new DefaultTransactionDefinition());
    try {
        userDao.save(userObject);
        transactionManager.commit(txStatus); // 手动提交事务，数据立刻落库
    } catch (Exception e) {
        transactionManager.rollback(txStatus);
        throw e;
    }
    return "success";
}

方案3：关闭JMS监听器默认事务（不推荐，存在一致性风险） #

可以通过配置关闭JMS监听器的默认事务绑定，让数据库操作走自身默认事务，但该配置会导致APNS发送抛异常时，已落库的数据无法随消息回滚，容易出现数据不一致、重复发通知的问题，生产环境不建议使用。配置项如下：

spring.jms.listener.session-transacted = false

• 仅在save()后调用entityManager.flush()或者使用JPA的saveAndFlush()方法无法解决问题：flush操作只是把持久化上下文的变更发送到数据库，只要事务未提交，记录对其他事务不可见，连接断开就会回滚，必须配合事务提交才能完成真正的持久化。

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