Spring Boot+Hibernate+PostgreSQL悲观锁失效问题排查求助

1. Hibernate锁模式自动降级 #

Hibernate的PESSIMISTIC_WRITE锁会根据操作自动选择锁语句：当更新操作不涉及主键或唯一索引字段时，Hibernate会生成FOR NO KEY UPDATE而非FOR UPDATE。PostgreSQL中FOR NO KEY UPDATE属于弱排他锁，无法阻塞普通SELECT的快照读，后续请求能读到事务提交前的旧数据（STOCK_IN状态），表现为锁失效。本地调试单实例下事务执行快，问题不易复现；生产多实例高并发场景下，事务执行时间差会放大这个问题。

2. 事务边界与锁生命周期不匹配 #

如果锁获取逻辑不在事务范围内，或者事务传播行为配置错误（比如用了SUPPORTS而非默认的REQUIRED），锁会被提前释放，后续请求自然能读到未更新的数据。

3. PostgreSQL隔离级别影响 #

默认的READ COMMITTED隔离级别下，PostgreSQL允许读取事务开始前的快照数据，若前一个事务未提交，后续请求会直接读取旧快照，FOR NO KEY UPDATE无法阻止这种行为。

1. 强制指定FOR UPDATE锁类型 #

在查询中显式配置锁参数，避免Hibernate自动降级锁类型：

// JPA原生查询方式
Stock stock = entityManager.createQuery(
    "SELECT s FROM Stock s WHERE s.id = :id", Stock.class
)
.setParameter("id", stockId)
.setLockMode(LockModeType.PESSIMISTIC_WRITE)
.setHint("javax.persistence.lock.timeout", 5000) // 设置锁超时时间，避免死锁
.setHint("org.hibernate.lock.mode", "PESSIMISTIC_WRITE") // 强制触发FOR UPDATE
.getSingleResult();

// Spring Data JPA注解方式
@Lock(LockModeType.PESSIMISTIC_WRITE)
@QueryHints({
    @QueryHint(name = "org.hibernate.lock.mode", value = "PESSIMISTIC_WRITE"),
    @QueryHint(name = "javax.persistence.lock.timeout", value = "5000")
})
Stock findByIdForUpdate(Long id);

2. 确保锁在事务内获取 #

所有涉及锁的业务逻辑必须包裹在事务中，保持事务传播行为为REQUIRED：

@Service
@Transactional(propagation = Propagation.REQUIRED)
public class StockService {
    public void updateStockStatus(Long stockId) {
        Stock stock = stockRepository.findByIdForUpdate(stockId);
        if (StockStatus.STOCK_IN.equals(stock.getStatus())) {
            stock.setStatus(StockStatus.STOCK_OUT);
            stockRepository.save(stock);
        }
    }
}

3. 调整事务隔离级别（可选） #

若业务需要强一致性，可将事务隔离级别设为REPEATABLE READ，配合FOR UPDATE锁，确保后续请求无法读取旧快照：

@Transactional(isolation = Isolation.REPEATABLE_READ)
public void updateStockStatus(Long stockId) {
    // 业务逻辑代码
}

4. 前端辅助防重复提交 #

从源头减少重复请求，比如按钮点击后置灰、添加防抖逻辑：

const submitBtn = document.getElementById('stock-submit-btn');
submitBtn.addEventListener('click', async () => {
    submitBtn.disabled = true;
    try {
        await fetch('/api/stock/update', { method: 'POST', body: JSON.stringify({ stockId: 1 }) });
    } finally {
        submitBtn.disabled = false;
    }
});

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