SqlSession的线程安全问题源码分析

🎮 作者主页:点击
🎁 完整专栏和代码:点击
🏡 博客主页:点击

文章目录

  • SqlSession 是线程安全的吗?
  • 为什么说是线程不安全的?
      • 事务管理问题
    • 数据库连接的共享问题
  • 一级缓存线程安全问题
  • 一级缓存占位符EXECUTION_PLACEHOLDER线程安全问题分析
  • 如何避免线程安全问题?
  • Spring是如何解决这个问题的?

SqlSession 是线程安全的吗?

SqlSession 本身并不是线程安全的。这意味着,不同线程不应当共享同一个 SqlSession 实例。如果在多线程环境下共享 SqlSession,可能会引发并发问题。
MyBatis 官方文档明确指出,SqlSession 是 非线程安全的,并且推荐每个线程都应该拥有独立的 SqlSession 实例。通常做法是为每个请求创建一个 SqlSession,并在操作完成后关闭它。
在这里插入图片描述

为什么说是线程不安全的?

事务管理问题

SqlSession 中包含了对事务的管理,事务在数据库连接上下文中是绑定的。如果多个线程同时使用同一个 SqlSession,就有可能在同一个事务中执行不同的操作,造成不可预知的结果。例如:

SqlSession sqlSession = sqlSessionFactory.openSession();
Thread thread1 = new Thread(() -> {sqlSession.update("update User set name = 'zhangsan' where id = 1");sqlSession.commit();  // 提交事务
});
Thread thread2 = new Thread(() -> {sqlSession.delete("delete from User where id = 2");sqlSession.commit();  // 提交事务
});thread1.start();
thread2.start();

在上述例子中,thread1 和 thread2 会同时操作同一个 SqlSession 实例,执行不同的 SQL 操作。如果 SqlSession 是线程安全的,两个线程的事务提交应该不会互相干扰,但实际上,由于事务是由同一个数据库连接维护的,在并发环境下会出现事务不一致、提交顺序错误等问题。因此,SqlSession 必须是每个线程独立的。

数据库连接的共享问题

SqlSession 会持有数据库连接,这些连接是不可共享的。多个线程如果共享同一个 SqlSession,就可能在同一时刻使用同一个数据库连接,这会导致连接池中的连接竞争,进而引发连接池溢出、死锁等问题。

一级缓存线程安全问题

MyBatis 支持缓存机制,包括一级缓存和二级缓存。一级缓存是 SqlSession 局部的缓存,它的生命周期与 SqlSession 一致。二级缓存是跨 SqlSession 的缓存,与 SqlSessionFactory 绑定。虽然二级缓存是线程安全的,但一级缓存的设计并没有考虑到并发情况下的安全性。
假设有两个线程同时使用同一个 SqlSession 查询数据,并且 SqlSession 内部的一级缓存被修改:

SqlSession sqlSession = sqlSessionFactory.openSession();
Thread thread1 = new Thread(() -> {User user1 = sqlSession.selectOne("select * from Users where id = 1");System.out.println(user1);
});
Thread thread2 = new Thread(() -> {User user2 = sqlSession.selectOne("select * from Users where id = 2");System.out.println(user2);
});thread1.start();
thread2.start();

这里,两个线程可能在同一个 SqlSession 中同时操作数据,SqlSession 内部的一级缓存会被并发修改,导致缓存中的数据不一致。一个线程查询缓存的数据可能是另一个线程未提交的内容,从而引发数据错误。

一级缓存占位符EXECUTION_PLACEHOLDER线程安全问题分析

org.apache.ibatis.executor.BaseExecutor#queryFromDatabase

    private <E> List<E> queryFromDatabase(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler, CacheKey key, BoundSql boundSql) throws SQLException {List<E> list;localCache.putObject(key, ExecutionPlaceholder.EXECUTION_PLACEHOLDER);try {list = doQuery(ms, parameter, rowBounds, resultHandler, boundSql);} finally {localCache.removeObject(key);}// 存入缓存localCache.putObject(key, list);return list;}

这段代码定义了一个泛型方法 queryFromDatabase,其主要功能是从数据库查询数据并利用缓存机制优化查询性能。首先,方法通过 localCache.putObject(key, EXECUTION_PLACEHOLDER) 将查询的 key 和一个占位符存入本地缓存,表示该查询正在执行。接着,它调用 doQuery 方法进行实际的数据库查询操作,并将查询结果存入 list。查询完成后,无论成功与否,都会在 finally 代码块中移除缓存中的占位符。然后,查询结果 list 被存入缓存,以便后续相同的查询可以直接从缓存中获取,避免重复查询。若该查询为存储过程(StatementType.CALLABLE),则输出参数被存入 localOutputParameterCache。最后,方法返回查询结果列表 list。

public enum ExecutionPlaceholder {EXECUTION_PLACEHOLDER
}

【重点分析】为什么在查询数据库前将key插入缓存中,并且值是一个占位符呢?
ExecutionPlaceholder.EXECUTION_PLACEHOLDER 是一个查询标记,这个占位符可以避免在查询缓存时出现“脏读”,当多个线程同时查询同一个 key 的缓存,线程 A 还在数据库查询过程中,线程 B 也开始查询相同的 key,但此时线程 A 还没完成查询,缓存中的数据尚未更新,假设此时是同一个 SqlSession,因为cacheKey 是一模一样的,线程B会去一级缓存中取值,取出的数据就是旧的值。

MyBatis是如何解决这个问题的呢,它在执行数据库查询前,将改变缓存的值为一个“错误的标记值”,这个值是一个枚举类型,假设此时线程B过来,会经过下面的代码

 List<E> list;try {queryStack++;// 从一级缓存获取结果list = resultHandler == null ? (List<E>) localCache.getObject(key) : null;if (list != null) {handleLocallyCachedOutputParameters(ms, key, parameter, boundSql);} else {// 若缓存获取不到,从数据库获取list = queryFromDatabase(ms, parameter, rowBounds, resultHandler, key, boundSql);}} finally {queryStack--;}

在执行 (List) localCache.getObject(key) ,此时获取到是标记的值EXECUTION_PLACEHOLDER,那么就是出现类型转换异常,Mybatis是直接通过设置一个异常标记值,直接抛出异常的方式避免这种多线程同一个SqlSession问题。SqlSession不是线程安全,所以尽量不要多个线程混用一个SqlSession,应该是一个线程一个SqlSession,每个线程独立的connection。

如何避免线程安全问题?

每个线程使用独立的 SqlSession:在多线程环境下,每个线程应该创建一个独立的 SqlSession 实例,避免共享实例。

请求范围内管理 SqlSession:对于 Web 应用程序,通常在每个请求中创建并使用 SqlSession,请求结束后关闭 SqlSession。

使用 ThreadLocal:如果需要在多个方法或类中共享 SqlSession,可以使用 ThreadLocal 来确保每个线程都有自己的 SqlSession 实例。

ThreadLocal<SqlSession> threadLocalSession = new ThreadLocal<SqlSession>() {@Overrideprotected SqlSession initialValue() {return sqlSessionFactory.openSession();}
};

Spring是如何解决这个问题的?

在 Spring 中,SqlSession 是通过 Spring 提供的事务管理和依赖注入机制来管理的。Spring 通过一系列的技术(如 @Transactional 注解、@Autowired 注解、TransactionManager 等)来避免 SqlSession 的线程安全问题,确保每个线程(通常是每个请求)都能使用一个独立的 SqlSession 实例。
Spring 会为每个请求创建独立的 SqlSession,并在请求结束时自动关闭,从而避免了线程共享 SqlSession 实例的问题。
Spring 内部使用 ThreadLocal 来为每个线程提供独立的 SqlSession。ThreadLocal 是一种线程局部存储机制,它可以确保每个线程都有自己的 SqlSession 实例。
具体来说,TransactionSynchronizationManager 类通过 ThreadLocal 维护了与当前事务相关的资源(如 SqlSession)。当一个请求(或一个线程)执行时,Spring 会将该请求的 SqlSession 实例绑定到当前线程的 ThreadLocal 中,这样其他线程就无法访问同一个 SqlSession 实例,从而避免了线程安全问题。

在 Spring 中,事务的生命周期通常由 PlatformTransactionManager 管理。当事务开始时,Spring 会在当前线程上通过 TransactionSynchronizationManager 来保存当前事务的信息。这个信息包括了当前事务管理器以及任何与事务相关的资源(如 SqlSession)。

    private SqlSession getSqlSession() {// 根据当前线程的事务上下文来获取 SqlSession 实例SqlSession session = (SqlSession) TransactionSynchronizationManager.getResource(sqlSessionFactory);if (session == null) {session = sqlSessionFactory.openSession();// 将 SqlSession 绑定到当前线程TransactionSynchronizationManager.bindResource(sqlSessionFactory, session);}return session;}

当 Spring 开始一个新的事务时,SqlSession 会被绑定到当前线程的 ThreadLocal 上。这个绑定操作使得每个线程都有自己的独立 SqlSession。
当线程请求 SqlSession 时,Spring 会首先从当前线程的 ThreadLocal 中获取已经绑定的 SqlSession,如果没有绑定的 SqlSession,则会通过 SqlSessionFactory 创建新的 SqlSession。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/891448.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Unity Mesh生成Cube

1. 配置一个Cube的每个面的数据 一共是6个面&#xff0c;每个面包含的数据包括4个顶点的相对顶点坐标&#xff08;Cube的中心为原点&#xff09;&#xff0c;法线方向&#xff0c;UV坐标&#xff0c;顶点渲染顺序&#xff0c;以及这个面用到的材质&#xff0c;因为这里是Top&am…

小程序组件 —— 22 组件案例 - 轮播区域绘制

这一节我们实现轮播图最外层的盒子&#xff0c;也就是把轮播图的最外层搭好&#xff0c;先不给轮播图添加图片&#xff0c;因为图片属于新的组件&#xff0c;组件里面有一些知识点&#xff0c;需要单独分开讲&#xff1b; 回顾一下&#xff0c;在进行传统网页开发时&#xff0…

【文献精读笔记】Explainability for Large Language Models: A Survey (大语言模型的可解释性综述)(二)

****非斜体正文为原文献内容&#xff08;也包含笔者的补充&#xff09;&#xff0c;灰色块中是对文章细节的进一步详细解释&#xff01; 3.1.2 基于注意力的解释&#xff08;Attention-Based Explanation&#xff09; 注意力机制可以揭示输入数据中各个部分之间的关系&#…

【centos8 镜像修改】centos8 镜像修改阿里云

要将 CentOS 8 的镜像源修改为阿里云镜像&#xff0c;你需要编辑 /etc/yum.repos.d/ 目录下的 .repo 文件。以下是具体的步骤&#xff1a; 备份原始的 .repo 文件&#xff1a; 在编辑之前&#xff0c;建议备份原始的 .repo 文件&#xff0c;以便在出现问题时可以恢复。 sudo cp…

git reset --hard(重置到当前提交,所有未提交的更改都会被永久丢弃)

git reset --hard 是一个强大的命令&#xff0c;它会将你的工作目录、暂存区和当前分支的 HEAD 指针重置到指定的提交状态&#xff0c;所有未提交的更改都会被永久丢弃。因此&#xff0c;使用这个命令时需要非常小心。 基本用法 重置到当前提交&#xff08;丢弃所有未提交的更…

WebRTC的三大线程

WebRTC中的三个主要线程&#xff1a; signaling_thread&#xff0c;信号线程&#xff1a;用于与应用层交互worker_thread&#xff0c;工作线程&#xff08;最核心&#xff09;&#xff1a;负责内部逻辑处理network_thread&#xff0c;网络线程&#xff1a;负责网络数据包的收发…

25考研总结

11408确实难&#xff0c;25英一直接单科斩杀&#x1f62d; 对过去这一年多备考的经历进行复盘&#xff0c;以及考试期间出现的问题进行思考。 考408的人&#xff0c;政治英语都不能拖到最后&#xff0c;408会惩罚每一个偷懒的人&#xff01; 政治 之所以把政治写在最开始&am…

linux ext4文件系统

Ext4&#xff08;第四扩展文件系统&#xff0c;简称为 EXT4&#xff09;是Linux操作系统中广泛使用的日志文件系统。它是Ext3文件系统的后继者&#xff0c;提供了更多的特性和改进&#xff0c;以适应更大的存储设备和更复杂的文件系统操作。以下是Ext4文件系统的一些主要特点&a…

Singleton: WebRTC中ThreadManager中的单例模式

1. 什么是单例模式&#xff1a; 旨在确保一个类只有一个实例&#xff0c;并提供全局访问点。 应用场景&#xff1a;需要一个全局唯一的实例&#xff0c;避免资源浪费。 2. 单例模式的实现&#xff1a; Lazy Initialization&#xff08;懒汉式&#xff09;&#xff08;延迟初…

人工智能:变革时代的核心驱动力

求各位观众老爷看一看 先声明一下&#xff0c;该内容由于篇幅过长&#xff0c;可能会有一些地方存在一些小问题请大家谅解 观众老爷们&#xff0c;点个免费的赞和关注呗&#xff0c;您们的支持就是我最大的动力~ 人工智能&#xff1a;变革时代的核心驱动力 一、引言 在当今…

单元测试入门和mockup

Java 新手入门&#xff1a;Java单元测试利器&#xff0c;Mock详解_java mock-CSDN博客 这个是典型的before when assert三段式&#xff0c;学一下单测思路 这个没有动态代理&#xff0c;所以是直接class(对比下面) Jmockit使用笔记_增加代码覆盖率_覆盖try catch_使用new Mock…

数组方法 | vue修改数组

数组方法 修改原数组 push() 方法&#xff08;在数组结尾处&#xff09;向数组添加一个新的元素 var list["数学","历史"]; list.push("英语"); ["数学","历史","英语"]unshift() 方法&#xff08;在开头&…

智能化人才招聘系统是怎样的?

随着企业规模的扩大和业务范围的拓展&#xff0c;人才招聘成为了企业发展的关键环节。然而&#xff0c;市面上的人才招聘系统琳琅满目&#xff0c;质量参差不齐&#xff0c;许多企业发现&#xff0c;并非所有系统都能满足他们的需求&#xff0c;特别是智能化的需求。今天&#…

MongoDB 固定集合

MongoDB 固定集合 MongoDB中的固定集合&#xff08;Capped Collections&#xff09;是一种具有固定大小的集合&#xff0c;当集合中的数据达到其最大大小时&#xff0c;它会自动覆盖最早的文档。这种类型的集合在MongoDB中用于实现高效的、固定大小的循环缓冲区。本文将详细介…

SpringBoot 实现登录功能

目录 下发JWT 令牌依赖文件令牌生成令牌验证 统一验证技术过滤器 Filter快速使用实现登录校验 拦截器 Interceptor快速使用实现登录校验 下发JWT 令牌 全称: JSON Web Token 官网&#xff1a; https://jwt.io/ 以JSON 的数据格式安全传输信息&#xff0c;利用 base64 进行编…

PHP关键字Self、Static和parent的区别

简介 在使用PHP代码时&#xff0c;您可能经常会遇到parent::、static::和self::。但是当你第一次作为一个开发人员开始的时候&#xff0c;有时候你会很困惑&#xff0c;不知道它们是做什么的&#xff0c;以及它们之间的区别。 在我第一次作为开发人员开始工作后的很长一段时间…

Disruptor 有哪些典型的使用场景?

大家好&#xff0c;我是君哥。 Disruptor 是一款高性能的内存有界队列&#xff0c;它通过内存预分配、无锁并发、解决伪共享问题、使用 RingBuffer 取代阻塞队列等措施来大幅提升队列性能。 但开发者们往往对它的使用场景不太了解&#xff0c;到底应该在哪些场景使用呢&#…

[MySQL报错]关于发生net start mysql 服务无法启动,服务没有报告任何错误的五种解决方案。

咋直接进入主题。 我遇到的问题是net start mysql 服务无法启动&#xff0c;服务没有报告任何错误 其问题出在哪里呢 一.ini文件配置问题 在于你没有给你下载好的mysql文件中配置.ini文件。 该如何配置呢。那就是先在文件夹中创建一个文本文件&#xff0c;把下面内容复制进去…

HTML5新特性|01 音频视频

音频 1、Audio (音频) HTML5提供了播放音频文件的标准 2、control(控制器) control 属性供添加播放、暂停和音量控件 3、标签: <audio> 定义声音 <source> 规定多媒体资源,可以是多个<!DOCTYPE html> <html lang"en"> <head><…

goView二开低代码平台1.0

官网文档地址&#xff1a;GoView 说明文档 | 低代码数据可视化开发平台 简介&#xff1a;GoView 是一个拖拽式低代码数据可视化开发平台&#xff0c;通过拖拽创建数据大屏&#xff0c;使用Vue3框架&#xff0c;Ts语言和NaiveUI组件库创建的开源项目。安装步骤和地址文档里都有…