Java中用MySQL的SELECT...FOR UPDATE实现悲观锁，需InnoDB引擎、显式事务、索引WHERE条件；SQL必须命中索引加行锁，JDBC或Spring@Transactional中执行，确保锁在同事务内释放。
在 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 终端节点、同步与异步等。
立即学习“Java免费学习笔记（深入）”；
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和事务属性
