SpringBoot RabbitMQ监听器手动事务下乐观锁失效问题求助

问题现象 #

使用SpringBoot 1.5.18.RELEASE开发的应用，Web请求通过@Version实现的Hibernate乐观锁功能正常，但RabbitMQ监听器调用标注@Transactional的服务方法更新实体时，乐观锁失效：即使在更新过程中其他Web请求修改了数据库版本号，当前更新仍会成功覆盖数据，未抛出预期的ObjectOptimisticLockException。

问题根源 #

从示例代码来看，核心问题在于错误的实体保存逻辑：
在updateViaRabbitMQ方法中，虽然从数据库加载了最新的托管态persistedLead并更新了属性，但最终调用leadRepo.save(lead)保存的是从消息反序列化而来的游离态Lead对象。这个游离态对象的版本号是消息生成时的旧版本，Hibernate处理游离对象更新时，不会自动对比数据库当前版本，直接用旧版本覆盖数据，导致乐观锁机制失效。

此外，RabbitMQ场景没有OpenEntityManagerInViewInterceptor维持EntityManager生命周期，实体的托管状态完全依赖事务，若操作游离态对象，Hibernate无法跟踪版本变化，进一步加剧了问题。

解决方案 #

方案1：修正实体保存逻辑（优先推荐） #

修改服务方法，确保更新并保存的是从数据库加载的托管态实体：

@org.springframework.transaction.annotation.Transactional
public void updateViaRabbitMQ(Lead lead){
    // 从数据库加载最新的托管态实体
    Lead persistedLead = leadRepo.get(lead.id);
    // 将传入对象的属性更新到托管态实体（可按需使用BeanUtils.copyProperties简化）
    persistedLead.setName(lead.getName());
    persistedLead.setPhone(lead.getPhone());
    // 保存托管态实体，事务提交时Hibernate自动执行版本校验
    leadRepo.save(persistedLead);
}

此时Hibernate会在事务提交时执行带版本条件的UPDATE语句：

UPDATE lead SET name = ?, phone = ?, version = version + 1 WHERE id = ? AND version = ?

如果数据库版本已被其他请求修改，该语句会返回0行影响，Hibernate自动抛出ObjectOptimisticLockException，实现乐观锁校验。

方案2：手动校验版本号（适用于强依赖消息版本的场景） #

若业务要求必须基于消息中的版本号进行更新，可在加载实体后手动对比版本：

@org.springframework.transaction.annotation.Transactional
public void updateViaRabbitMQ(Lead lead){
    Lead persistedLead = leadRepo.get(lead.id);
    // 手动校验传入版本与数据库最新版本是否一致
    if (!persistedLead.getVersion().equals(lead.getVersion())) {
        throw new ObjectOptimisticLockException(persistedLead, "数据已被其他请求修改，版本不匹配");
    }
    // 更新属性并保存托管态实体
    persistedLead.setName(lead.getName());
    leadRepo.save(persistedLead);
}

方案3：确保事务配置生效 #

检查以下配置，避免事务失效导致的乐观锁问题：

• 确保LeadService被@Service/@Component标注，且被Spring容器扫描到；
• 确认Spring事务管理器配置正确（SpringBoot 1.5默认自动配置JpaTransactionManager/HibernateTransactionManager）；
• 避免在updateViaRabbitMQ方法上使用Propagation.NOT_SUPPORTED等禁用事务的传播属性，保证事务正常开启。

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