当前位置: 首页 > article >正文

【悲观锁和乐观锁有什么区别】以及在Spring Boot、MybatisPlus、PostgreSql中使用

悲观锁和乐观锁是两种常见的并发控制方式,它们在处理并发数据访问时的策略和实现方式有很大的不同。下面是这两者的主要区别:

1. 锁的策略

悲观锁(Pessimistic Locking):

假设并发冲突频繁发生,因此在操作数据之前就会加锁,确保其他事务无法同时操作这条数据,避免数据的并发修改。只有获得锁的事务才能对数据进行修改,其他事务会被阻塞,直到当前事务完成。

  • 特点:乐观地认为数据可能会被同时修改,因此采取悲观的做法,强制加锁。
  • 实现方式:通过 SELECT FOR UPDATE 或数据库的锁机制(例如行锁、表锁)来实现。
  • 适用场景:适用于高并发情况下需要保证数据一致性的业务场景,例如资金转账、库存扣减等。

乐观锁(Optimistic Locking):

假设并发冲突较少,事务并不会立刻加锁,而是在更新时验证数据是否被其他事务修改。如果数据在事务操作期间没有被其他事务修改(通常通过版本号等机制检查),就可以提交更新;如果数据已经被其他事务修改,则会回滚或抛出异常。

  • 特点:乐观地认为数据不会被并发修改,因此不加锁,只在更新时进行冲突检查。
  • 实现方式:通常通过在数据表中添加 version 字段或时间戳字段,每次更新时检查版本号是否一致来实现。
  • 适用场景:适合读多写少的业务场景。适用于并发冲突较少,且更新操作不频繁的场景,例如普通的查询和更新操作。

2. 锁的粒度

悲观锁:
会对数据进行实际的加锁,其他事务在该数据的锁释放之前无法访问或修改数据。锁的粒度通常为行锁或表锁,具体取决于数据库的实现。

乐观锁:
不会对数据加锁,只是在数据修改时检查版本号或时间戳等信息,以判断数据是否被其他事务修改过。它的粒度通常为数据记录的版本字段

3. 性能与开销

悲观锁:
由于加锁机制,它的性能开销较大。多个事务竞争同一数据时,其他事务需要等待锁释放,可能导致性能瓶颈,尤其在高并发的情况下。

乐观锁:
由于没有加锁,它的性能较高,适合读取操作多、写入操作少的场景。它的开销主要在于更新时的版本检查,性能损耗较低。

4. 适用场景

悲观锁:
适用于数据竞争较为激烈的场景,例如银行转账、库存更新等高并发操作。
适用于对数据一致性要求极高的业务场景,需要强制保证同一时间只有一个事务能修改数据。

乐观锁:
适用于数据竞争较少的场景,例如用户资料更新、普通的库存查询等。
适用于不频繁更新的场景,可以减少数据库的锁竞争,提高系统的吞吐量。

5. 事务阻塞

悲观锁:
由于加锁,其他事务在等待锁释放期间会被阻塞,可能会引起性能下降或死锁。

乐观锁:
不会导致阻塞,多个事务可以同时读取数据,只有在提交时检查数据是否被修改。若数据被修改,则需要回滚或重新尝试更新,但不会影响其他事务的执行。

6. 死锁风险

悲观锁:
在并发高的情况下,悲观锁可能导致死锁(特别是当事务顺序不一致时),因为多个事务可能会相互等待对方释放锁。

乐观锁:
乐观锁不会产生死锁,因为它没有显式的锁操作。它依赖版本号来解决并发问题,即使并发冲突发生,也只是简单的版本检查或回滚。

7. 在Spring Boot中悲观锁的实现

使用 MyBatis-Plus 实现悲观锁,实际上就是通过 SQL 查询语句 来加锁。在 MyBatis 中,可以通过 FOR UPDATE 来实现悲观锁。

1.修改数据库查询,使用悲观锁:

使用 FOR UPDATE 来锁定查询到的行。你可以在 Mapper 中自定义 SQL 查询,指定 FOR UPDATE

假设你有一个 gift 表,表结构如下:

CREATE TABLE gift (id BIGINT PRIMARY KEY,name VARCHAR(255),quantity INT
);

在 Mapper 接口中,定义一个查询方法,使用 FOR UPDATE

@Mapper
public interface GiftMapper extends BaseMapper<Gift> {@Select("SELECT * FROM gift WHERE id = #{id} FOR UPDATE")Gift selectForUpdate(Long id);
}

2.服务层调用悲观锁:

在服务层使用 @Transactional 注解,确保事务的原子性。

@Service
public class GiftService {@Autowiredprivate GiftMapper giftMapper;@Transactionalpublic boolean redeemGift(Long giftId) {Gift gift = giftMapper.selectForUpdate(giftId);if (gift == null) {return false;}// 检查库存if (gift.getQuantity() > 0) {gift.setQuantity(gift.getQuantity() - 1);giftMapper.updateById(gift);return true;} else {return false;}}
}

在上述代码中,selectForUpdate 查询会加锁,确保只有一个事务可以操作该记录。如果其他事务尝试访问该记录,它们会被阻塞,直到当前事务完成。

3.数据库配置:

默认情况下,PostgreSQL 的隔离级别是 READ COMMITTED,它支持 FOR UPDATE 锁。如果你需要更高的隔离级别,可以配置事务隔离级别为 SERIALIZABLE,但是对于大多数场景,READ COMMITTED 就足够了。

可以在 application.properties 文件中配置事务隔离级别:

spring.datasource.hikari.transaction-isolation=TRANSACTION_READ_COMMITTED

8. 在Spring Boot中乐观锁的实现

<!--mybatis 官方-->
<dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId><version>2.2.0</version>
</dependency><!--mybatis plus 非官方-->
<dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifactId><version>3.5.1</version>
</dependency>

乐观锁通常通过版本号机制来实现。每次更新数据时,会验证数据是否被其他事务修改过。如果数据被修改,则抛出 OptimisticLockException 异常,提示并发冲突。

1.在config包中添加乐观锁配置类:

package com.ckm.ball.config;import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.OptimisticLockerInnerInterceptor;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
@MapperScan("com.ckm.ball.mapper") // 扫描你的 Mapper 包
public class MyBatisPlusConfig {@Beanpublic MybatisPlusInterceptor mybatisPlusInterceptor() {// 注册乐观锁插件MybatisPlusInterceptor mybatisPlusInterceptor = new MybatisPlusInterceptor();mybatisPlusInterceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());return mybatisPlusInterceptor;}
}

2.在实体类中添加版本字段:

在实体类中添加 version 字段,并使用 MyBatis-Plus 提供的 @Version 注解来标识该字段为版本号字段。

import com.baomidou.mybatisplus.annotation.*;@TableName("gift")
public class Gift {@TableIdprivate Long id;private String name;private Integer quantity;@Versionprivate Long version;  // 版本字段// getters and setters
}

在这个例子中,version 字段会随着每次更新而自动递增。

3.更新时使用乐观锁:

MyBatis-Plus 会自动处理乐观锁的更新。你只需在更新时,确保在实体类中包含 @Version 注解的字段。

例如,在服务层进行更新操作时,MyBatis-Plus 会自动比较版本号,确保数据没有被其他事务修改。

@Service
public class GiftService {@Autowiredprivate GiftMapper giftMapper;@Transactionalpublic boolean redeemGift(Long giftId) {Gift gift = giftMapper.selectById(giftId);if (gift == null) {return false;}// 检查库存if (gift.getQuantity() > 0) {gift.setQuantity(gift.getQuantity() - 1);// 更新时会自动检查版本号int rows = giftMapper.updateById(gift);if (rows == 0) {// 如果更新失败,说明版本号不匹配,表示并发冲突return false;}//在这里处理里的其他逻辑//如扣除相应积分,存储兑换记录等return true;} else {return false;}}
}

在更新时,MyBatis-Plus 会自动检查 version 字段。如果数据的版本号与当前数据库中的版本号不一致,则更新失败,返回 0,表示发生了并发冲突。

4.配置乐观锁:

如果使用 MyBatis-Plus,乐观锁只需要在实体类中标记 @Version 注解,不需要其他特殊配置。

总结

  • 悲观锁:通过 FOR UPDATE 锁定查询的行,适用于高并发的情况下,确保同一时刻只有一个事务修改数据。你可以通过 MyBatis 的@Select 注解配合 FOR UPDATE 来实现。
  • 乐观锁:通过版本号机制,确保数据在更新时没有被其他事务修改。MyBatis-Plus 支持通过 @Version 注解来实现乐观锁。

相关文章:

【悲观锁和乐观锁有什么区别】以及在Spring Boot、MybatisPlus、PostgreSql中使用

悲观锁和乐观锁是两种常见的并发控制方式&#xff0c;它们在处理并发数据访问时的策略和实现方式有很大的不同。下面是这两者的主要区别&#xff1a; 1. 锁的策略 悲观锁&#xff08;Pessimistic Locking&#xff09;&#xff1a; 假设并发冲突频繁发生&#xff0c;因此在操作…...

《Linux运维实战:Ubuntu 22.04配置pam实现密码复杂度策略》

总结&#xff1a;整理不易&#xff0c;如果对你有帮助&#xff0c;可否点赞关注一下&#xff1f; 更多详细内容请参考&#xff1a;Linux运维实战总结 一、背景信息 由于安全方面的考虑&#xff0c;先要求Ubuntu 22.04系统需配置密码复杂度策略&#xff0c;先要求如下&#xff1…...

域名解析:从基础概念到安全风险全面指南

目录 什么是域名&#xff1f; 域名在哪里注册&#xff1f; 域名层级解析&#xff1a;二级与多级域名 域名发现对安全测试的意义 二到多级域名面临的网络安全风险 如何加强域名安全管理 总结 什么是域名 域名(Domain Name)是互联网上用于标识和定位计算机、网络服务的字…...

从代码学习深度学习 - 使用块的网络(VGG)PyTorch版

文章目录 前言一、VGG网络简介1.1 VGG的核心特点1.2 VGG的典型结构1.3 优点与局限性1.4 本文的实现目标二、搭建VGG网络2.1 数据准备2.2 定义VGG块2.3 构建VGG网络2.4 辅助工具2.4.1 计时器和累加器2.4.2 准确率计算2.4.3 可视化工具2.5 训练模型2.6 运行实验总结前言 深度学习…...

Java课程设计(双人对战游戏)持续更新......

少废话&#xff0c;当然借助了ai&#xff0c;就这么个实力&#xff0c;后续会逐渐完善...... 考虑添加以下功能&#xff1a; 选将&#xff0c;选图&#xff0c;技能&#xff0c;天赋&#xff0c;道具&#xff0c;防反&#xff0c;反重力&#xff0c;物理反弹&#xff0c;击落…...

Windows 安装多用户和其它一些问题 VMware Onedrive打不开

以下以win10家庭版为例&#xff0c;win11、专业版类似。 Onedrive相关问题参看我的其他文章&#xff1a; Windows如何同时登录两个OneDrive个人版账号_onedrive登录两个账号-CSDN博客 win10 win11 设置文件权限以解决Onedrive不能同步问题_onedrive没有同步权限-CSDN博客 O…...

深入解析:MySQL 中 NULL 值是否占用 1 bit 存储空间?

在 MySQL 的存储机制中,关于 NULL 值是否占用 1 bit 的存储空间,存在一个常见的理解误区。许多人认为“每个 NULL 值占用 1 bit”,但这并不完全准确。本文将通过 InnoDB 引擎的存储原理,详细解释 NULL 值的实际存储开销,并澄清这一误解。 一、核心结论 允许为 NULL 的列会…...

java基础自用笔记:异常、泛型、集合框架(List、Set、Map)、Stream流

异常 异常体系 编译时异常代表程序觉得你可能会出错。 运行时异常代表已经出错 异常基本处理 异常的作用 可以在可能出现的异常的地方用返回异常来代替return&#xff0c;这样提醒程序出现异常简洁清晰 自定义异常 最好用运行时异常&#xff0c;不会像编译时异常那样烦人&a…...

深度学习中常见的专业术语汇总

本硕博都是搞机械的匠人&#xff0c;当然也想做一下交叉学科的东西&#xff0c;蹭一下人工智能的热点。虽然世界是个草台班子&#xff0c;但是来都来了&#xff0c;咱也要把这场戏演好。 记得之前网上爆料有位大学生发了很多水文&#xff0c;对&#xff0c;是交叉学科的&#x…...

Python Cookbook-4.14 反转字典

任务 给定一个字典&#xff0c;此字典将不同的键映射到不同的值。而你想创建一个反转的字典&#xff0c;将各个值反映射到键。 解决方案 可以创建一个函数&#xff0c;此函数传递一个列表推导作为dict的参数以创建需要的字典。 def invert_dict(d):return dict([(v,k) for …...

第六届 蓝桥杯 嵌入式 省赛

参考 第六届蓝桥杯嵌入式省赛程序设计题解析&#xff08;基于HAL库&#xff09;_蓝桥杯嵌入式第六届真题-CSDN博客 一、分析功能 RTC 定时 1&#xff09;时间初始化 2&#xff09;定时上报电压时间 ADC测量 采集电位器的输出电压信号。 串行功能 1&#xff09;传送要设置…...

爱普生FC-135晶振5G手机的极端温度性能守护者

在5G时代&#xff0c;智能手机不仅需要高速率与低延迟&#xff0c;更需在严寒、酷暑、振动等复杂环境中保持稳定运行。作为 5G 手机的核心时钟源&#xff0c;爱普生32.768kHz晶振FC-135凭借其宽温适应性、高精度稳定性与微型化设计&#xff0c;成为5G手机核心时钟源的理想选择&…...

C# StreamReader/StreamWriter 使用详解

总目录 前言 在 C# 开发中&#xff0c;StreamReader 和 StreamWriter 是处理文本文件的核心类&#xff0c;属于 System.IO 命名空间。它们基于流&#xff08;Stream&#xff09;操作文本数据&#xff0c;支持读写、编码设置、异步操作等&#xff0c;适用于日志记录、配置文件处…...

如何备份你的 Postman 所有 Collection?

团队合作需要、备份&#xff0c;还是迁移到其他平台&#xff0c;我们都需要在 Postman 中将这些珍贵的集合数据导出。 如何从 Postman 中导出所有集合(Collection)教程...

SQL IF(xxx, 1, 0) 窗口函数

IF(xxx, 1, 0)是SQL中的条件表达式函数&#xff0c;它的工作原理如下&#xff1a; 功能&#xff1a;如果条件xxx为真(TRUE)&#xff0c;则返回1&#xff1b;如果条件xxx为假(FALSE)&#xff0c;则返回0 参数&#xff1a; 第一个参数(xxx)&#xff1a;要评估的条件表达式 第二…...

【Qt】三种操作sqlite3的方式及其三种多表连接

一、sqlite3与MySQL数据库区别&#xff1a; 1. 数据库类型 SQLite3&#xff1a;是嵌入式数据库&#xff0c;它将整个数据库存储在单个文件中&#xff0c;不需要独立的服务器进程。这意味着它可以很方便地集成到各种应用程序中&#xff0c;如移动应用、桌面应用等。MySQL&…...

MinGW下编译ffmpeg源码时生成compile_commands.json

在前面的博文MinGW下编译nginx源码中&#xff0c;有介绍到使用compiledb工具在MinGW环境中生成compile_commands.json&#xff0c;以为compiledb是捕获的make时的输出&#xff0c;而nginx生成时控制台是有输出编译时的命令行信息的&#xff0c;笔者之前编译过ffmpeg的源码&…...

【数据结构】树与森林

目录 树的存储方法 双亲表示法 孩子表示法 孩子兄弟表示法 树、森林与二叉树的转换 树转换成二叉树 森林转换成二叉树 二叉树转换成森林 树与森林的遍历 树的遍历 森林的遍历 树的存储方法 双亲表示法 这种存储结构采用一组连续空间来存储每个结点&#xff0c;同时…...

跟着StatQuest学知识08-RNN与LSTM

一、RNN &#xff08;一&#xff09;简介 整个过程权重和偏置共享。 &#xff08;二&#xff09;梯度爆炸问题 在这个例子中w2大于1&#xff0c;会出现梯度爆炸问题。 当我们循环的次数越来越多的时候&#xff0c;这个巨大的数字会进入某些梯度&#xff0c;步长就会大幅增加&…...

【SpringCloud】Eureka的使用

3. Eureka 3.1 Eureka 介绍 Eureka主要分为两个部分&#xff1a; EurekaServer: 作为注册中心Server端&#xff0c;向微服务应用程序提供服务注册&#xff0c;发现&#xff0c;健康检查等能力。 EurekaClient: 服务提供者&#xff0c;服务启动时&#xff0c;会向 EurekaS…...

nuxt3 seo优化

在 Nuxt3 中&#xff0c;通过 nuxtjs/seo、nuxtjs/sitemap 和 nuxtjs/robots 模块可以生成包含动态链接的站点地图&#xff08;sitemap.xml&#xff09;&#xff0c;但具体是“实时生成”还是“部署时生成”&#xff0c;取决于你的配置方式和数据更新频率。以下是具体分析&…...

初识MySQL · 数据类型

目录 前言&#xff1a; 数值类型 文本、二进制数据类型 时间类型 String类型 前言&#xff1a; 对于MySQL来说&#xff0c;是一门编程语言&#xff0c;可能定义不是那么的严格&#xff0c;但是对于MySQL来说也是拥有自己的数据类型的&#xff0c;比如tinyint&#xff0c;…...

【Go】数组

数组Array 重点&#xff1a; 数组是值类型 注意点: 1. 数组&#xff1a;是同一种数据类型的固定长度的序列。2. 数组定义&#xff1a;var a [len]int&#xff0c;比如&#xff1a;var a [5]int&#xff0c;数组长度必须是常量&#xff0c;且是类型的组成部分。一旦定义&…...

QT图片轮播器(QT实操学习2)

1.项目架构 1.UI界面 2.widget.h​ #ifndef WIDGET_H #define WIDGET_H#include <QWidget>#define TIMEOUT 1 * 1000 QT_BEGIN_NAMESPACE namespace Ui { class Widget; } QT_END_NAMESPACEclass Widget : public QWidget {Q_OBJECTpublic:Widget(QWidget *parent n…...

深度解析衡石科技HENGSHI SENSE嵌入式分析能力:如何实现3天快速集成

嵌入式分析成为现代SaaS的核心竞争力 在当今SaaS市场竞争中&#xff0c;数据分析能力已成为产品差异化的关键因素。根据Bessemer Venture Partners的最新调研&#xff0c;拥有深度嵌入式分析功能的SaaS产品&#xff0c;其客户留存率比行业平均水平高出23%&#xff0c;ARR增长速…...

杂草YOLO系列数据集4000张

一份开源数据集——杂草YOLO数据集&#xff0c;该数据集适用于农业智能化、植物识别等计算机视觉应用场景。 数据集详情 ​训练集&#xff1a;3,664张高清标注图像​测试集&#xff1a;180张多样性场景样本​验证集&#xff1a;359张严格筛选数据 下载链接 杂草YOLO数据集分…...

Mybatis_Plus中常用的IService方法

查询 方法名 查询记录总数 /*** 查询总记录数** see Wrappers#emptyWrapper()*/default long count() {return count(Wrappers.emptyWrapper());} 方法实现 Testpublic void testGetCount(){long count userService.count();System.out.println("总记录数&#xff1a;&…...

​Flink/Kafka在python中的用处

一、基础概念 1. ​Apache Kafka 是什么&#xff1f; ​核心功能&#xff1a;Kafka 是一个分布式流处理平台&#xff0c;主要用于构建实时数据管道和流式应用程序。​核心概念&#xff1a; ​生产者&#xff08;Producer&#xff09;​&#xff1a;向 Kafka 发送数据的程序。…...

Vue 2 探秘:visible 和 append-to-body 是谁的小秘密?

&#x1f680; Vue 2 探秘&#xff1a;visible 和 append-to-body 是谁的小秘密&#xff1f;&#x1f914; 父组件&#xff1a;identify-list.vue子组件&#xff1a;fake-clue-list.vue 嘿&#xff0c;各位前端探险家&#xff01;&#x1f44b; 今天我们要在 Vue 2 的代码丛林…...

机器学习的一百个概念(1)单位归一化

前言 本文隶属于专栏《机器学习的一百个概念》&#xff0c;该专栏为笔者原创&#xff0c;引用请注明来源&#xff0c;不足和错误之处请在评论区帮忙指出&#xff0c;谢谢&#xff01; 本专栏目录结构和参考文献请见[《机器学习的一百个概念》 ima 知识库 知识库广场搜索&…...