Spring JPA+Postgres转账场景的事务隔离级别选型及并发处理疑问

先明确核心问题：并发转账时，转出账户余额校验通过后被其他请求抢先扣减，导致最终余额不足却完成转账，出现数据不一致。下面针对你的疑问逐一解答，并给出可行方案：

1. 默认的ReadCommitted隔离级别可行吗？ #

不行。ReadCommitted仅能避免脏读（读取未提交的事务数据），但无法解决不可重复读问题——也就是你担心的场景：当前事务第一次读取转出账户余额足够，在执行更新前，其他已提交的事务修改了该余额，而你的代码只做了一次校验，后续更新不会再检查，最终导致余额超扣。

2. 必须用Serializable隔离级别吗？ #

不需要。Serializable是最严格的隔离级别，通过强制事务串行执行避免所有并发问题，但会带来极大的性能开销，高并发场景下会导致大量事务等待，完全没必要用在转账这类场景。

3. 用Java手动读写锁靠谱吗？ #

仅适用于单节点应用，如果是集群部署（多JVM实例），JVM级别的读写锁无法跨实例生效，会出现锁不住的情况。而且数据库本身提供了更可靠的锁机制，没必要在应用层重复造轮子。

最优解决方案推荐 #

针对转账场景，推荐以下三种方案，按性能和适用场景排序：

方案一：数据库原子更新语句（最推荐） #

放弃先查询再更新的逻辑，直接用一条带条件的SQL完成余额校验和扣减，数据库会保证这个操作的原子性：

// 在Repository中定义方法
@Modifying
@Query("UPDATE Account a SET a.balance = a.balance - :amount WHERE a.id = :fromAccountId AND a.balance >= :amount")
int deductBalance(@Param("amount") double amount, @Param("fromAccountId") long fromAccountId);

// Service中调用
int affectedRows = repository.deductBalance(amount, fromAccountId);
if (affectedRows == 0) {
    throw new IllegalStateException("余额不足");
}
// 执行转入操作
repository.updateBalance(amount, toAccountId);
// 记录交易日志

这种方式把校验和更新合并为一个原子操作，完全避免并发问题，性能最优。

方案二：悲观锁 #

在查询转出账户时加写锁，锁住该账户直到当前事务提交，其他事务无法修改：

// 在Repository中添加带锁的查询方法
@Lock(LockModeType.PESSIMISTIC_WRITE)
Optional<Account> findByIdWithLock(Long id);

// Service中调用
Account fromAccount = repository.findByIdWithLock(fromAccountId).orElseThrow();
if (fromAccount.getBalance() < amount) {
    throw new IllegalStateException();
}
fromAccount.setBalance(fromAccount.getBalance() - amount);
repository.save(fromAccount);

// 转入操作同理，也可加锁（可选，防止转入时被其他操作修改）
Account toAccount = repository.findByIdWithLock(toAccountId).orElseThrow();
toAccount.setBalance(toAccount.getBalance() + amount);
repository.save(toAccount);

悲观锁适合并发冲突频繁的场景，但会增加锁等待时间，性能略低于方案一。

方案三：乐观锁 #

给Account实体添加版本字段，利用数据库的乐观锁机制避免并发更新：

@Entity
public class Account {
    @Id
    private Long id;
    private double balance;
    @Version // 乐观锁版本字段
    private Integer version;
}

// Service中执行逻辑，更新时若版本不一致会抛出OptimisticLockingFailureException
try {
    Account fromAccount = repository.findById(fromAccountId).orElseThrow();
    if (fromAccount.getBalance() < amount) {
        throw new IllegalStateException();
    }
    fromAccount.setBalance(fromAccount.getBalance() - amount);
    repository.save(fromAccount);
    
    Account toAccount = repository.findById(toAccountId).orElseThrow();
    toAccount.setBalance(toAccount.getBalance() + amount);
    repository.save(toAccount);
} catch (OptimisticLockingFailureException e) {
    // 捕获乐观锁异常，可选择重试或返回错误
    throw new IllegalStateException("转账失败，请重试");
}

乐观锁适合并发冲突不频繁的场景，性能较好，无需显式加锁，通过版本号冲突检测并发更新。

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