zoukankan      html  css  js  c++  java
  • sql server对并发的处理乐观锁和悲观锁

    假如两个线程同时修改数据库同一条记录,就会导致后一条记录覆盖前一条,从而引发一些问题。

    例如:

      一个售票系统有一个余票数,客户端每调用一次出票方法,余票数就减一。

    情景: 

      总共300张票,假设两个售票点,恰好在同一时间出票,它们做的操作都是先查询余票数,然后减一。

    一般的sql语句:

      

    1
    2
    3
    4
    5
    6
    7
    8
    9
    declare @count as int
     
    begin tran
        select @count=count from ttt
        WAITFOR DELAY '00:00:05' --模拟并发,故意延迟5秒
        update ttt set count=@count-1
    commit TRAN
     
    SELECT FROM ttt

      

      问题就在于,同一时间获取的余票都为300,每个售票点都做了一次更新为299的操作,导致余票少了1,而实际出了两张票。

      打开两个查询窗口,分别快速运行以上代码即可看到效果。

    定义解释:

      悲观锁:相信并发是绝大部分的,并且每一个线程都必须要达到目的的。

      乐观锁:相信并发是极少数的,假设运气不好遇到了,就放弃并返回信息告诉它再次尝试。因为它是极少数发生的。

    悲观锁解决方案:

      

    1
    2
    3
    4
    5
    6
    7
    declare @count as int
     
    begin tran
        select @count=count from tb WITH(UPDLOCK)
       WAITFOR DELAY '00:00:05' --模拟并发,故意延迟5秒
        update tb set count=@count-1
    commit tran

      

      在查询的时候加了一个更新锁,保证自查询起直到事务结束不会被其他事务读取修改,避免产生脏数据。

      从而可以解决上述问题。

    乐观锁解决方案:

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    --首先给表加一列timestamp
     
    ALTER TABLE ttt ADD timesFlag TIMESTAMP NOT null
     
    然后更新时判断这个值是否被修改
    declare @count as int
    DECLARE @flag AS TIMESTAMP
    DECLARE @rowCount AS int
    begin tran
        select @count=COUNT,@flag=timesflag from ttt
        WAITFOR DELAY '00:00:05'
        update ttt set count=@count-1 WHERE timesflag=@flag --这里加了条件
        SET @rowcount=@@ROWCOUNT  --获取被修改的行数
    commit TRAN
     
    --对行数进行判断即可
     
    IF @rowCount=1
        PRINT '更新成功'
    ELSE
        PRINT '更新失败'

      这便是乐观锁的解决方案,可以解决并发带来的数据错误问题,但不保证每一次调用更新都成功,可能会返回'更新失败'

    悲观锁和乐观锁

      悲观锁一定成功,但在并发量特别大的时候会造成很长堵塞甚至超时,仅适合小并发的情况。

      乐观锁不一定每次都修改成功,但能充分利用系统的并发处理机制,在大并发量的时候效率要高很多。


     补充:

    乐观锁通过自定义行版本号字段方式

    更新操作时候,防止同一条数据,同时被多人修改,为每条数据添加一个version字段

    //防止同一条数据,同时被多人修改,为每条数据添加一个version字段
    1、更新数据之前现获取该条数据的版本号 version字段,version字段设置成默认值0 类型long
    select version from your_table where id = #{id};


    2、更新的时候,要将之前查询出来的version具体值作为条件,同时更新version字段+1
    update your_table set user_name = #{userName}, version = version+1 where id = #{id} and version = #{version};

    作者:阿笨

          【官方QQ一群:跟着阿笨一起玩NET(已满)】:422315558跟着阿笨一起玩NET

          【官方QQ二群:跟着阿笨一起玩C#(已满)】:574187616跟着阿笨一起玩C#

          【官方QQ三群:跟着阿笨一起玩ASP.NET(已满)】:967920586跟着阿笨一起玩ASP.NET

          【官方QQ四群:Asp.Net Core跨平台技术开发(可加入)】:829227829阿笨NET(三群)

          【官方QQ五群:.NET Core跨平台开发技术(可加入)】:647639415阿笨NET(四群)

          【网易云课堂】:https://study.163.com/provider/2544628/index.htm?share=2&shareId=2544628

          【腾讯课堂】:https://abennet.ke.qq.com

          【51CTO学院】:https://edu.51cto.com/sd/66c64

          【微信公众号】:http://dwz.cn/ABenNET

  • 相关阅读:
    python学习笔记(十一)处理json
    python学习笔记(十)常用模块
    python学习笔记(九)内置函数
    python学习笔记(八)函数return多个值,列表推导式和交换两个变量的值
    BZOJ 3675 [Apio2014]序列分割 (斜率优化DP)
    BZOJ 3126 [USACO2013 Open]Photo (单调队列优化DP)
    POJ 1821 Fence (单调队列优化DP)
    BZOJ 3326 [SCOI2013]数数 (数位DP)
    HDU 6148 Valley Numer (数位DP)
    BZOJ 2741 L (可持久化01Trie+分块)
  • 原文地址:https://www.cnblogs.com/51net/p/15780930.html
Copyright © 2011-2022 走看看