Java 中 MySQL 怎么在并发读写下利用悲观锁 select for update 锁定行-java教程-PHP中文网

Java中用MySQL的SELECT...FOR UPDATE实现悲观锁，需InnoDB引擎、显式事务、索引WHERE条件；SQL必须命中索引加行锁，JDBC或Spring@Transactional中执行，确保锁在同事务内释放。

java 中 mysql 怎么在并发读写下利用悲观锁 select for update 锁定行

在 Java 中使用 MySQL 的 SELECT ... FOR UPDATE 实现悲观锁，核心是借助数据库的行级锁机制，在事务中显式锁定目标行，防止其他事务并发修改。它适用于写多读少、业务逻辑强一致性要求高（如库存扣减、账户余额更新）的场景。

前提条件：确保 InnoDB 引擎与事务隔离级别

MySQL 必须使用 InnoDB 存储引擎（MyISAM 不支持行锁），且操作需在 显式事务 中进行（不能是自动提交模式）。推荐使用默认的 REPEATABLE READ 隔离级别（InnoDB 下 SELECT ... FOR UPDATE 在该级别下加的是 next-key lock，可防幻读）。

检查表引擎：SHOW CREATE TABLE your_table;，确认为 ENGINE=InnoDB
Java 中关闭自动提交：connection.setAutoCommit(false);
事务结束后务必调用 commit() 或 rollback()，否则锁会一直持有，导致阻塞

SQL 写法：必须带 WHERE 条件且命中索引

SELECT ... FOR UPDATE 只有在 能通过索引精确定位到具体行 时才加行锁；若无索引或走全表扫描，可能升级为表锁，极大降低并发性能。

✅ 正确示例（id 是主键）：SELECT * FROM account WHERE id = 1001 FOR UPDATE;
⚠️ 危险示例（无索引字段）：SELECT * FROM account WHERE name = 'Alice' FOR UPDATE; → 若 name 无索引，会锁全表
? 建议：在 WHERE 条件字段上建立合适索引（主键、唯一索引、普通索引均可，但需确保执行计划实际使用）

Java 代码典型用法（JDBC 原生）

直接使用 JDBC 执行带 FOR UPDATE 的查询，并在同事务内完成后续更新操作：

Alibabacloud Sdk Client Initialization For Java

在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。

下载

Connection conn = dataSource.getConnection();
conn.setAutoCommit(false);
try (PreparedStatement ps = conn.prepareStatement(
        "SELECT balance FROM account WHERE id = ? FOR UPDATE")) {
    ps.setLong(1, accountId);
    ResultSet rs = ps.executeQuery();
    if (rs.next()) {
        long currentBalance = rs.getLong("balance");
        if (currentBalance >= amount) {
            // 在同一事务中更新
            try (PreparedStatement updatePs = conn.prepareStatement(
                    "UPDATE account SET balance = balance - ? WHERE id = ?")) {
                updatePs.setLong(1, amount);
                updatePs.setLong(2, accountId);
                updatePs.executeUpdate();
            }
        }
    }
    conn.commit(); // 成功则提交，释放锁
} catch (Exception e) {
    conn.rollback(); // 出错回滚，释放锁
    throw e;
} finally {
    conn.close();
}

关键点：SELECT FOR UPDATE 和后续 UPDATE 必须在同一个 Connection 和事务中
不要在 SELECT 后长时间处理业务逻辑（如远程调用、休眠），否则锁持有时间过长，影响并发
避免死锁：多个事务按相同顺序访问行（例如都先锁 id 小的再锁 id 大的）

Spring 中结合 @Transactional 使用

使用 Spring 的声明式事务更简洁，但要注意事务传播行为和锁生效时机：

@Transactional(rollbackFor = Exception.class)
public void deductBalance(Long accountId, BigDecimal amount) {
    // 查询并加锁（注意：必须是 select for update，不能用 JPA 的 find + @Lock）
    Account account = jdbcTemplate.queryForObject(
        "SELECT * FROM account WHERE id = ? FOR UPDATE", 
        new Object[]{accountId}, 
        new BeanPropertyRowMapper(Account.class));
<pre class="brush:php;toolbar:false;">if (account.getBalance().compareTo(amount) >= 0) {
    jdbcTemplate.update(
        "UPDATE account SET balance = balance - ? WHERE id = ?", 
        amount, accountId);
} else {
    throw new IllegalStateException("Insufficient balance");
}

}

必须开启事务（@Transactional），且方法不能是 private 或 final（代理失效）
JPA 用户注意：EntityManager.find() 或 JpaRepository.findById() 默认不加锁；需用 @Lock(LockModeType.PESSIMISTIC_WRITE) 或原生 SQL
MyBatis 用户：在 XML 映射文件中直接写 SELECT ... FOR UPDATE，并在 <select></select> 标签里设置 fetchSize 和事务属性

Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南