HOME 首页
SERVICE 服务产品
XINMEITI 新媒体代运营
CASE 服务案例
NEWS 热点资讯
ABOUT 关于我们
CONTACT 联系我们
创意岭
让品牌有温度、有情感
专注品牌策划15年

    mysql乐观锁怎么实现(mysql乐观锁实现原理)

    发布时间:2023-04-19 10:10:53     稿源: 创意岭    阅读: 80        

    大家好!今天让创意岭的小编来大家介绍下关于mysql乐观锁怎么实现的问题,以下是小编对此问题的归纳整理,让我们一起来看看吧。

    开始之前先推荐一个非常厉害的Ai人工智能工具,一键生成原创文章、方案、文案、工作计划、工作报告、论文、代码、作文、做题和对话答疑等等

    只需要输入关键词,就能返回你想要的内容,越精准,写出的就越详细,有微信小程序端、在线网页版、PC客户端

    官网:https://ai.de1919.com

    创意岭作为行业内优秀的企业,服务客户遍布全球各地,如需了解SEO相关业务请拨打电话175-8598-2043,或添加微信:1454722008

    本文目录:

    mysql乐观锁怎么实现(mysql乐观锁实现原理)

    一、关于mySql 中乐观锁与读已提交(事务隔离级别)的搭配使用问题!!求大神带飞!

    术式之后皆为逻辑,一切皆为需求和实现。希望此文能从需求、现状和解决方式的角度帮大家理解隔离级别。

    隔离级别的产生

    在串型执行的条件下,数据修改的顺序是固定的、可预期的结果,但是并发执行的情况下,数据的修改是不可预期的,也不固定,为了实现数据修改在并发执行的情况下得到一个固定、可预期的结果,由此产生了隔离级别。

    所以隔离级别的作用是用来平衡数据库并发访问与数据一致性的方法。

    事务的4种隔离级别

    READ UNCOMMITTED       未提交读,可以读取未提交的数据。READ COMMITTED         已提交读,对于锁定读(select with for update 或者 for share)、update 和 delete 语句,                       InnoDB 仅锁定索引记录,而不锁定它们之间的间隙,因此允许在锁定的记录旁边自由插入新记录。                       Gap locking 仅用于外键约束检查和重复键检查。REPEATABLE READ        可重复读,事务中的一致性读取读取的是事务第一次读取所建立的快照。SERIALIZABLE           序列化

    在了解了 4 种隔离级别的需求后,在采用锁控制隔离级别的基础上,我们需要了解加锁的对象(数据本身&间隙),以及了解整个数据范围的全集组成。

    数据范围全集组成

    SQL 语句根据条件判断不需要扫描的数据范围(不加锁);

    SQL 语句根据条件扫描到的可能需要加锁的数据范围;

    以单个数据范围为例,数据范围全集包含:(数据范围不一定是连续的值,也可能是间隔的值组成)

    1. 数据已经填充了整个数据范围:(被完全填充的数据范围,不存在数据间隙)

    • 整形,对值具有唯一约束条件的数据范围 1~5 ,

      已有数据1、2、3、4、5,此时数据范围已被完全填充;

    • 整形,对值具有唯一约束条件的数据范围 1 和 5 ,

      已有数据1、5,此时数据范围已被完全填充;

    • 2. 数据填充了部分数据范围:(未被完全填充的数据范围,是存在数据间隙)

    • 整形的数据范围 1~5 ,

      已有数据 1、2、3、4、5,但是因为没有唯一约束,

      所以数据范围可以继续被 1~5 的数据重复填充;

    • 整形,具有唯一约束条件的数据范围 1~5 ,

      已有数据 2,5,此时数据范围未被完全填充,还可以填充 1、3、4 ;

    • 3. 数据范围内没有任何数据(存在间隙)

      如下:

    • 整形的数据范围 1~5 ,数据范围内当前没有任何数据。

    • 在了解了数据全集的组成后,我们再来看看事务并发时,会带来的问题。

      无控制的并发所带来的问题

      并发事务如果不加以控制的话会带来一些问题,主要包括以下几种情况。

      1. 范围内已有数据更改导致的:

    • 更新丢失:当多个事务选择了同一行,然后基于最初选定的值更新该行时,

      由于每个事物不知道其他事务的存在,最后的更新就会覆盖其他事务所做的更新;

    • 脏读: 一个事务正在对一条记录做修改,这个事务完成并提交前,这条记录就处于不一致状态。

      这时,另外一个事务也来读取同一条记录,如果不加控制,

      第二个事务读取了这些“脏”数据,并据此做了进一步的处理,就会产生提交的数据依赖关系。

      这种现象就叫“脏读”。

    • 2. 范围内数据量发生了变化导致:

    • 不可重复读:一个事务在读取某些数据后的某个时间,再次读取以前读过的数据,

      却发现其读出的数据已经发生了改变,或者某些记录已经被删除了。

      这种现象就叫“不可重复读”。

    • 幻读:一个事务按相同的查询条件重新读取以前检索过的数据,

      却发现其他事务插入了满足其查询条件的新数据,这种现象称为“幻读”。

      可以简单的认为满足条件的数据量变化了。

    • 因为无控制的并发会带来一系列的问题,这些问题会导致无法满足我们所需要的结果。因此我们需要控制并发,以实现我们所期望的结果(隔离级别)。

      MySQL 隔离级别的实现

      InnoDB 通过加锁的策略来支持这些隔离级别。

      行锁包含:

    • Record Locks

      索引记录锁,索引记录锁始终锁定索引记录,即使表中未定义索引,

      这种情况下,InnoDB 创建一个隐藏的聚簇索引,并使用该索引进行记录锁定。

    • Gap Locks

      间隙锁是索引记录之间的间隙上的锁,或者对第一条记录之前或者最后一条记录之后的锁。

      间隙锁是性能和并发之间权衡的一部分。

      对于无间隙的数据范围不需要间隙锁,因为没有间隙。

    • Next-Key Locks

      索引记录上的记录锁和索引记录之前的 gap lock 的组合。

      假设索引包含 10、11、13 和 20。

      可能的next-key locks包括以下间隔,其中圆括号表示不包含间隔端点,方括号表示包含端点:

    • (负无穷大, 10]    (10, 11]    (11, 13]    (13, 20]    (20, 正无穷大)        对于最后一个间隔,next-key将会锁定索引中最大值的上方,

    • 左右滑动进行查看

      "上确界"伪记录的值高于索引中任何实际值。

      上确界不是一个真正的索引记录,因此,实际上,这个 next-key 只锁定最大索引值之后的间隙。

      基于此,当获取的数据范围中,数据已填充了所有的数据范围,那么此时是不存在间隙的,也就不需要 gap lock。

      对于数据范围内存在间隙的,需要根据隔离级别确认是否对间隙加锁。

      默认的 REPEATABLE READ 隔离级别,为了保证可重复读,除了对数据本身加锁以外,还需要对数据间隙加锁。

      READ COMMITTED 已提交读,不匹配行的记录锁在 MySQL 评估了 where 条件后释放。

      对于 update 语句,InnoDB 执行 "semi-consistent" 读取,这样它会将最新提交的版本返回到 MySQL,

      以便 MySQL 可以确定该行是否与 update 的 where 条件相匹配。

      总结&延展:

      唯一索引存在唯一约束,所以变更后的数据若违反了唯一约束的原则,则会失败。

      当 where 条件使用二级索引筛选数据时,会对二级索引命中的条目和对应的聚簇索引都加锁;所以其他事务变更命中加锁的聚簇索引时,都会等待锁。

      行锁的增加是一行一行增加的,所以可能导致并发情况下死锁的发生。

      例如,

      在 session A 对符合条件的某聚簇索引加锁时,可能 session B 已持有该聚簇索引的 Record Locks,而 session B 正在等待 session A 已持有的某聚簇索引的 Record Locks。

      session A 和 session B 是通过两个不相干的二级索引定位到的聚簇索引。

      session A 通过索引 idA,session B通过索引 idB 。

      当 where 条件获取的数据无间隙时,无论隔离级别为 rc 或 rr,都不会存在间隙锁。

      比如通过唯一索引获取到了已完全填充的数据范围,此时不需要间隙锁。

      间隙锁的目的在于阻止数据插入间隙,所以无论是通过 insert 或 update 变更导致的间隙内数据的存在,都会被阻止。

      rc 隔离级别模式下,查询和索引扫描将禁用 gap locking,此时 gap locking 仅用于外键约束检查和重复键检查(主要是唯一性检查)。

      rr 模式下,为了防止幻读,会加上 Gap Locks。

      事务中,SQL 开始则加锁,事务结束才释放锁。

      就锁类型而言,应该有优化锁,锁升级等,例如rr模式未使用索引查询的情况下,是否可以直接升级为表锁。

      就锁的应用场景而言,在回放场景中,如果确定事务可并发,则可以考虑不加锁,加快回放速度。

      锁只是并发控制的一种粒度,只是一个很小的部分:

      从不同场景下是否需要控制并发,(已知无交集且有序的数据的变更,MySQL 的 MTS 相同前置事务的多事务并发回放)

      并发控制的粒度,(锁是一种逻辑粒度,可能还存在物理层和其他逻辑粒度或方式)

      相同粒度下的优化,(锁本身存在优化,如IX、IS类型的优化锁)

      粒度加载的安全&性能(如获取行锁前,先获取页锁,页锁在执行获取行锁操作后即释放,无论是否获取成功)等多个层次去思考并发这玩意。

    二、乐观锁的一个实现细节,求解答

    悲观锁就是数据库里面锁住 类似for update查询

    乐观锁不是在数据库端锁住的

    而是程序控制的

    你说的那Mybatis我不知道是什么

    但是乐观锁一般是这样

    比如你数据库中有一条记录

    你可以给他加上一个版本号

    这样

    如果同时有2个人查询出那个数据要修改

    第一个人先查出来有事走了

    第二个人查出来给改了

    这时候你看

    第一个人查出来的数据版本号比如是1

    第二个人查出来也是1 但是他改了数据以后版本号变成2

    这时候第一个人回来了继续修改数据

    他的版本号是1 比2低

    这时候就告诉他数据过期

    乐观锁大概就是这个意思

    是一种思路!

    三、Java如何实现对Mysql数据库的行锁

    下面通过一个例子来说明

    场景如下:

    用户账户有余额,当发生交易时,需要实时更新余额。这里如果发生并发问题,那么会造成用户余额和实际交易的不一致,这对公司和客户来说都是很危险的。

    那么如何避免:

    网上查了下,有以下两种方法:

    1、使用悲观锁

    当需要变更余额时,通过代码在事务中对当前需要更新的记录设置for update行锁,然后开始正常的查询和更新操作

    这样,其他的事务只能等待该事务完成后方可操作

    当然要特别注意,如果使用了Spring的事务注解,需要配置一下:

    <!-- (事务管理)transaction manager, use JtaTransactionManager for global tx -->

    <bean id="transactionManager"

    class="org.springframework.jdbc.datasource.DataSourceTransactionManager">

    <property name="dataSource" ref="dataSource" />

    </bean>

    <!-- 使用annotation定义事务 -->

    <tx:annotation-driven transaction-manager="transactionManager" />

    在指定代码处添加事务注解

    @Transactional

    @Override

    public boolean increaseBalanceByLock(Long userId, BigDecimal amount)

    throws ValidateException {

    long time = System.currentTimeMillis();

    //获取对记录的锁定

    UserBalance balance = userBalanceDao.getLock(userId);

    LOGGER.info("[lock] start. time: {}", time);

    if (null == balance) {

    throw new ValidateException(

    ValidateErrorCode.ERRORCODE_BALANCE_NOTEXIST,

    "user balance is not exist");

    }

    boolean result = userBalanceDao.increaseBalanceByLock(balance, amount);

    long timeEnd = System.currentTimeMillis();

    LOGGER.info("[lock] end. time: {}", timeEnd);

    return result;

    }

    MyBatis中的锁定方式,实际测试该方法确实可以有效控制,不过在大并发量的情况下,可能会有性能问题吧

    <select id="getLock" resultMap="BaseResultMap" parameterType="java.lang.Long">

    <![CDATA[

    select * from user_balance where id=#{id,jdbcType=BIGINT} for update;

    ]]>

    </select>

    2、使用乐观锁

    这个方法也同样可以解决场景中描述的问题(我认为比较适合并不频繁的操作):

    设计表的时候增加一个version(版本控制字段),每次需要更新余额的时候,先获取对象,update的时候根据version和id为条件去更新,如果更新回来的数量为0,说明version已经变更

    需要重复一次更新操作,如下:sql脚本

    update user_balance set Balance = #{balance,jdbcType=DECIMAL},Version = Version+1 where Id = #{id,jdbcType=BIGINT} and Version = #{version,jdbcType=BIGINT}

    这是一种不使用数据库锁的方法,解决方式也很巧妙。当然,在大量并发的情况下,一次扣款需要重复多次的操作才能成功,还是有不足之处的。不知道还有没有更好的方法。

    四、mysql 乐观锁怎么解决并发

    mysql的最大连接数默认是100, 这个数值对于并发连接很多的数据库应用是远远不够的,当连接请求大于默认连接数后,就会出现无法连接数据库的错误,因此我们需要把它适当调大一些。

    调节方法为:

    1.linux服务器中:改my.cnf中的值就行了

    2.Windows服务器中(我用的):

    在文件“my.ini”中找到段 [mysqld],在其中添加一行

    max_connections=200 ### 200可以更改为想设置成的值.

    然后重启"mysql"服务。

    /mysqladmin所在路径/mysqladmin -uroot -p variables

    输入root数据库账号的密码后可看到

    | max_connections | 1000 |

    以上就是关于mysql乐观锁怎么实现相关问题的回答。希望能帮到你,如有更多相关问题,您也可以联系我们的客服进行咨询,客服也会为您讲解更多精彩的知识和内容。


    推荐阅读:

    mysql查询优化的几种方法(mysql查询优化的几种方法有哪些)

    MySQL数据库恢复(mysql数据库恢复到某个时间)

    girl排行榜(ohmygirl排名)

    抖音自媒体运营(抖音自媒体运营方案)

    牡丹江装修公司哪家好谁知道(牡丹江装修公司口碑排行)