MySQL死锁排查指南

// 事务A：用户A给B转账10元
@Transactional
public void transferAtoB(String aId, String bId, int amount) {
    // 1. 锁定A的账户（更新操作会加行锁）
    accountMapper.updateBalance(aId, -amount);
    // 2. 尝试锁定B的账户（若B此时正在操作A，就会等待）
    accountMapper.updateBalance(bId, +amount);
}
// 事务B：用户B给A转账20元
@Transactional
public void transferBtoA(String bId, String aId, int amount) {
    // 1. 锁定B的账户
    accountMapper.updateBalance(bId, -amount);
    // 2. 尝试锁定A的账户（此时A已被事务A锁定，陷入等待）
    accountMapper.updateBalance(aId, +amount);
}

SHOW ENGINE INNODB STATUS;

@Service
public class TransferService {
    @Autowired
    private AccountMapper accountMapper;
    // 统一的转账方法（无论谁转谁，都按ID大小顺序加锁）
    @Transactional
    public void transfer(String fromId, String toId, int amount) {
        // 步骤1：确定加锁顺序（全局统一规则）
        String lockFirstId; // 先锁这个ID
        String lockSecondId; // 后锁这个ID
        if (fromId.compareTo(toId) < 0) {
            lockFirstId = fromId;
            lockSecondId = toId;
        } else {
            lockFirstId = toId;
            lockSecondId = fromId;
        }
        // 步骤2：按统一顺序加锁（先锁小ID，再锁大ID）
        // 先锁定第一个账户（无论它是转出方还是转入方）
        if (lockFirstId.equals(fromId)) {
            accountMapper.deductBalance(lockFirstId, amount); // 转出
        } else {
            accountMapper.addBalance(lockFirstId, amount); // 转入
        }
        // 再锁定第二个账户
        if (lockSecondId.equals(fromId)) {
            accountMapper.deductBalance(lockSecondId, amount); // 转出
        } else {
            accountMapper.addBalance(lockSecondId, amount); // 转入
        }
    }
}

// 坏例子：事务包含RPC调用（加长锁持有时间）
@Transactional
public void badTransfer(String fromId, String toId, int amount) {
    accountMapper.updateBalance(fromId, -amount);
    rpcClient.notifyThirdParty(fromId, toId, amount); // 非DB操作，加长事务
    accountMapper.updateBalance(toId, +amount);
}
// 好例子：事务仅包含DB操作
@Transactional
public void goodTransfer(String fromId, String toId, int amount) {
    accountMapper.updateBalance(fromId, -amount);
    accountMapper.updateBalance(toId, +amount);
}
// 非DB操作放在事务外
public void transferWithNotify(String fromId, String toId, int amount) {
    goodTransfer(fromId, toId, amount);
    rpcClient.notifyThirdParty(fromId, toId, amount);
}