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

embedded/2024/10/19 18:24:56/

在 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 示例）

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 示例）

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 示例）

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

模拟锁冲突的 Java 代码示例

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);}
}

代码解析

  1. simulateTransaction1：

    • 开启事务，更新 test_table 表中的 id = 1 行并持有锁不提交。
    • 持有锁 10 秒钟，模拟长时间占用锁。

  2. simulateTransaction2：

    • 在事务1未提交的情况下，尝试更新同一行的数据。
    • 由于事务1尚未提交，事务2会被锁定等待直到事务1释放锁。

模拟结果

  1. 事务1 会首先锁定 id = 1 的行，并在持有锁的 10 秒钟内执行更新操作，但不提交事务。
  2. 事务2 在事务1未提交前，尝试获取锁进行更新，会因为锁冲突被阻塞，直到事务1释放锁（即提交或回滚事务）。
  3. 当事务1释放锁后，事务2才会获取到锁，并执行更新操作。

运行效果

  • 当你运行这段代码时，控制台会先输出Transaction 1: Row locked, holding lock for 10 seconds...，然后 10 秒钟后，Transaction 1 提交。
  • 此时，Transaction 2 才会获得锁，进行更新并提交。

锁冲突的场景与解决方法

  1. 场景：多个事务并发访问同一行数据时，事务间的冲突会导致等待或阻塞。
  2. 解决方法：
    • 减少事务持有锁的时间：避免长时间占用锁，尽快提交事务。
    • 优化锁策略：通过使用行锁代替表锁，减少锁冲突的概率。
    • 锁等待超时：设置锁等待时间，避免无限等待。

这种锁冲突的场景非常常见于高并发的数据库应用程序中，因此了解如何控制和优化锁机制是提高系统并发性能的关键之一。

4. 总结与优化场景

  • 表级锁：适合批量操作或结构修改时，需谨慎使用以避免阻塞过多操作。
  • 行级锁：适合高并发环境，提升并发操作性能。
  • 间隙锁：适合防止幻读，尤其在事务隔离级别较高时使用。

通过这些锁机制，MySQL 能够在不同的并发场景中灵活管理数据一致性与性能。


http://www.ppmy.cn/embedded/128804.html

相关文章

文心智能体：我的旅游小助手

文心智能体：我的旅游小助手

文章目录 一、全球旅游推荐官&#xff08;旅游小帮手介绍&#xff09;二、为什么会创建全球旅游推荐官呢&#xff1f;1.创意灵感2.实现思路 三、开发步骤和方法四、调试方法和总结五、探索AI未来&#xff0c;开启无限可能&#xff1a;文心智能体平台&#xff0c;智能创新的领航…
阅读更多...
PHP $ _FILES [‘userfile‘] [‘name‘ ] 和 $ _FILES [‘userfile‘] [‘tmp_name‘] 有什么区别

PHP $ _FILES [‘userfile‘] [‘name‘ ] 和 $ _FILES [‘userfile‘] [‘tmp_name‘] 有什么区别

在PHP中&#xff0c;当你通过HTML表单上传文件时&#xff0c;PHP会将与上传文件相关的所有信息存储在全局数组$_FILES中。这个数组是一个多维数组&#xff0c;其中包含了关于每个上传文件的详细信息。$_FILES[userfile]是这个多维数组中的一个元素&#xff0c;它代表了名为user…
阅读更多...
《OpenCV计算机视觉》——人脸检测__Haar特征、级联分类器

《OpenCV计算机视觉》——人脸检测__Haar特征、级联分类器

文章目录 Haar特征一、定义与原理二、分类三、计算方法四、应用五、优缺点 级联分类器一、定义与原理二、结构与组成三、举例说明 Haar特征 Haar特征是一种在计算机视觉和图像处理中常用的特征描述方法&#xff0c;特别适用于物体识别&#xff0c;尤其是人脸检测。以下是对Haa…
阅读更多...
HDFS开启审计日志

HDFS开启审计日志

文章目录 HDFS开启审计日志修改 HDFS log4j.properties修改 HDFS hdfs-site.xml修改 HDFS hadoop-env.sh分发配置到NN节点重启NN节点评估 HDFS 审计日志大小 HDFS开启审计日志 修改 HDFS log4j.properties 修改文件大小及保留个数、日志存储目录 vim /opt/apache/hadoop/etc…
阅读更多...
openlayers 测量功能实现（测距测面）- vue3

openlayers 测量功能实现（测距测面）- vue3

一、配置openlayer环境 借鉴&#xff1a;Vue 3 OpenLayers 的简单使用_vue3 openlayers-CSDN博客 二、代码如下&#xff08;测距、测面和清除&#xff09; measurs.js: import {ref} from vue; import Draw from ol/interaction/Draw import VectorSource from ol/source/…
阅读更多...
红队攻防之隐匿真实IP

红队攻防之隐匿真实IP

0x01 前言 安全态势日益严峻&#xff0c;各大组织普遍采用了综合的安全产品&#xff0c;如态势感知系统、WAF和硬件防火墙等&#xff0c;这些措施加大了渗透测试和攻防演练的难度。即使是一些基本的漏洞验证、端口扫描&#xff0c;也可能导致测试IP被限制&#xff0c;从而阻碍…
阅读更多...
VGG16

VGG16

文章目录 VGG161. **图像分类**2. **特征提取**3. **迁移学习**4. **其他应用**5. **结构简单且深度较大**总结&#xff1a; 流程流程总结&#xff1a; 具体介绍1. **特征提取部分 (features)**2. **自适应池化层 (avgpool)**3. **分类器部分 (classifier)**4. **总结** VGG( (…
阅读更多...
[论文阅读]Deep Depth Completion of a Single RGB-D Image

[论文阅读]Deep Depth Completion of a Single RGB-D Image

摘要 我们的工作目标是完成RGB-D图像的深度通道。商用级深度摄像头通常无法捕捉光滑、明亮、透明和远处表面的深度信息。为了解决这个问题&#xff0c;我们训练了一个深度网络&#xff0c;该网络以RGB图像作为输入&#xff0c;并预测稠密的表面法线和遮挡边界。然后&#xff0…
阅读更多...
最新文章

Copyright @ 2022~2023