如果用Java设计MySQL中表级锁、行级锁和间歇锁会是怎么的？

在 MySQL 中，锁机制是确保数据一致性和并发控制的重要手段。MySQL 支持多种锁类型，包括表级锁、行级锁等，每种锁的适用场景、影响范围和实现机制各不相同。我们将逐一介绍它们，并通过模拟代码展示不同锁的实现。

1. 锁类型及其影响范围

1.1 表级锁（Table Lock）

范围：锁定整个表，其他事务不能对表进行任何修改。
使用场景：
- ALTER TABLE、DROP TABLE 等 DDL 操作。
- 全表扫描查询需要保证一致性时，如备份或批量数据导入。
锁定失败的情况：如果另一个事务已经持有锁（读/写锁），则需要等待或报错，具体取决于是否允许等待。

表级锁指令示例：

LOCK TABLES table_name WRITE; -- 写锁，其他事务无法读写
UNLOCK TABLES; -- 解锁

1.2 行级锁（Row Lock）

范围：锁定特定的行，不影响其他行的操作。
使用场景：
- 高并发环境中，多个事务可以同时操作不同的行。
- 适用于需要频繁读写操作的场景。
锁定失败的情况：在高并发环境中，如果两个事务试图同时更新同一行，会发生锁等待，最终可能出现死锁。

行级锁指令示例：

SELECT * FROM table_name WHERE id=1 FOR UPDATE; -- 行锁，锁定特定行

1.3 意向锁（Intention Lock）

范围：一种表级锁的扩展，用于行级锁的意图声明。不会阻塞其他事务对不同行的操作，但会声明事务对特定行的操作意图。
使用场景：
- InnoDB 引擎自动实现，不需要显式声明。
- 用于协调行级锁和表级锁之间的冲突。
锁定失败的情况：当表锁与行锁发生冲突时，意向锁会协调操作，避免事务死锁。

1.4 间隙锁（Gap Lock）

范围：锁定行之间的“间隙”，防止插入操作。
使用场景：
- 避免“幻读”，适用于REPEATABLE READ隔离级别。
锁定失败的情况：如果有其他事务试图在锁定范围内插入新行，插入会被阻塞或失败。

间隙锁指令示例：

SELECT * FROM table_name WHERE id > 10 FOR UPDATE; -- 间隙锁，锁定 id > 10 的范围，禁止插入

2. 不同锁的设计实现逻辑模拟

2.1 表级锁模拟（Java 示例）

import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;class Table {private final Lock tableLock = new ReentrantLock();public void lockTable(String threadName) {tableLock.lock();try {System.out.println(threadName + " has locked the table");// Simulate table operationThread.sleep(2000);} catch (InterruptedException e) {e.printStackTrace();} finally {tableLock.unlock();System.out.println(threadName + " has unlocked the table");}}
}public class TableLockSimulation {public static void main(String[] args) {Table table = new Table();new Thread(() -> table.lockTable("Thread 1")).start();new Thread(() -> table.lockTable("Thread 2")).start();}
}

2.2 行级锁模拟（Java 示例）

import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
import java.util.HashMap;
import java.util.Map;class InnoDBTable {private final Map<Integer, Lock> rowLocks = new HashMap<>(); // 每行一个锁public InnoDBTable(int rowCount) {// 初始化行锁for (int i = 0; i < rowCount; i++) {rowLocks.put(i, new ReentrantLock());}}// 模拟行级锁的查询操作public void accessRow(int rowId, String threadName) {Lock rowLock = rowLocks.get(rowId);if (rowLock != null) {rowLock.lock(); // 锁定行try {System.out.println(threadName + " acquired row-level lock on row " + rowId);// 模拟业务操作Thread.sleep(1000);System.out.println(threadName + " finished working on row " + rowId);} catch (InterruptedException e) {e.printStackTrace();} finally {rowLock.unlock(); // 释放行锁}}}
}public class InnoDBLockSimulation {public static void main(String[] args) {InnoDBTable table = new InnoDBTable(10); // 10 行数据// 启动线程，模拟多个事务操作不同的行new Thread(() -> table.accessRow(5, "Thread 1")).start();new Thread(() -> table.accessRow(5, "Thread 2")).start();new Thread(() -> table.accessRow(8, "Thread 3")).start();}
}

2.3 间隙锁模拟（Java 示例）

import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
import java.util.concurrent.locks.Condition;class GapLockSimulation {private final Lock lock = new ReentrantLock();private final Condition gapEmpty = lock.newCondition();private boolean hasGapRecord = false; // 表示间隙是否已有记录// 模拟插入操作public void insertRecord(String threadName) throws InterruptedException {lock.lock();try {while (hasGapRecord) {System.out.println(threadName + " waiting due to gap lock.");gapEmpty.await(); // 等待间隙解锁}// 模拟插入hasGapRecord = true;System.out.println(threadName + " inserted record in gap.");} finally {lock.unlock();}}// 模拟释放间隙锁public void releaseGap(String threadName) {lock.lock();try {hasGapRecord = false;gapEmpty.signalAll(); // 通知所有等待的线程System.out.println(threadName + " released gap lock.");} finally {lock.unlock();}}
}public class GapLockDemo {public static void main(String[] args) {GapLockSimulation gapLock = new GapLockSimulation();new Thread(() -> {try {gapLock.insertRecord("Thread 1");} catch (InterruptedException e) {e.printStackTrace();}}).start();new Thread(() -> {try {gapLock.insertRecord("Thread 2");} catch (InterruptedException e) {e.printStackTrace();}}).start();new Thread(() -> {try {Thread.sleep(3000);gapLock.releaseGap("Thread 1");} catch (InterruptedException e) {e.printStackTrace();}}).start();}
}

3. 锁定失败的情况

锁定失败通常发生在两种情况下：

锁冲突：一个事务已经持有锁，另一个事务需要等待，或者在某些情况下，可能会报错。
死锁：当两个事务循环依赖彼此的锁时，数据库会检测到死锁并回滚其中一个事务以打破死锁。

为了模拟锁冲突，我们可以通过创建两个线程在同一个数据库表上进行相互冲突的操作，来展示锁冲突的场景。具体来说，假设我们有一个事务在一个线程中锁定了一行数据，并且执行了更新操作，而另一个事务也试图在相同的行上执行更新操作。由于第一个事务还没有提交，第二个事务会发生锁冲突，必须等待第一个事务释放锁。

场景说明

事务1：先获取行级锁，执行更新操作，不立即提交事务。
事务2：尝试获取相同的行级锁，由于事务1还没有提交，事务2将被阻塞直到事务1提交。

模拟锁冲突的 Java 代码示例

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;public class LockConflictDemo {public static void main(String[] args) {// 启动两个线程模拟两个事务Thread transaction1 = new Thread(() -> {try {simulateTransaction1();} catch (SQLException e) {e.printStackTrace();}});Thread transaction2 = new Thread(() -> {try {simulateTransaction2();} catch (SQLException e) {e.printStackTrace();}});transaction1.start();try {// 确保事务1先启动并锁定行Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}transaction2.start();}private static void simulateTransaction1() throws SQLException {Connection connection = null;try {connection = getConnection();connection.setAutoCommit(false); // 开启事务String sql = "UPDATE test_table SET value = ? WHERE id = ?";PreparedStatement preparedStatement = connection.prepareStatement(sql);preparedStatement.setString(1, "Transaction1");preparedStatement.setInt(2, 1); // 假设锁定id为1的行preparedStatement.executeUpdate();System.out.println("Transaction 1: Row locked, holding lock for 10 seconds...");// 模拟长时间持有锁，不提交Thread.sleep(10000);connection.commit(); // 提交事务System.out.println("Transaction 1: Committed.");} catch (Exception e) {e.printStackTrace();if (connection != null) {connection.rollback(); // 回滚事务}} finally {if (connection != null) {connection.close(); // 关闭连接}}}private static void simulateTransaction2() throws SQLException {Connection connection = null;try {connection = getConnection();connection.setAutoCommit(false); // 开启事务String sql = "UPDATE test_table SET value = ? WHERE id = ?";PreparedStatement preparedStatement = connection.prepareStatement(sql);preparedStatement.setString(1, "Transaction2");preparedStatement.setInt(2, 1); // 同样尝试锁定id为1的行preparedStatement.executeUpdate();System.out.println("Transaction 2: Row locked successfully.");connection.commit(); // 提交事务System.out.println("Transaction 2: Committed.");} catch (Exception e) {e.printStackTrace();if (connection != null) {connection.rollback(); // 回滚事务}} finally {if (connection != null) {connection.close(); // 关闭连接}}}private static Connection getConnection() throws SQLException {String url = "jdbc:mysql://localhost:3306/testdb"; // 替换为实际数据库URLString user = "root"; // 替换为实际用户名String password = "password"; // 替换为实际密码return DriverManager.getConnection(url, user, password);}
}

代码解析

simulateTransaction1：
- 开启事务，更新 test_table 表中的 id = 1 行并持有锁不提交。
- 持有锁 10 秒钟，模拟长时间占用锁。
simulateTransaction2：
- 在事务1未提交的情况下，尝试更新同一行的数据。
- 由于事务1尚未提交，事务2会被锁定等待直到事务1释放锁。