java中mysql悲观锁和乐观锁的使用技巧

  • Post author:
  • Post category:java




一,悲观锁

悲观锁,正如其名,具有强烈的独占和排他特性。它指的是对数据被外界(包括本系统当前的其他事务,以及来自外部系统的事务处理)修改持保守态度。因此,在整个数据处理过程中,将数据处于锁定状态。悲观锁的实现,往往依靠数据库提供的锁机制(也只有数据库层提供的锁机制才能真正保证数据访问的排他性,否则,即使在本系统中实现了加锁机制,也无法保证外部系统不会修改数据)。

之所以叫做悲观锁,是因为这是一种对数据的修改抱有悲观态度的并发控制方式。我们一般认为数据被并发修改的概率比较大,所以需要在修改之前先加锁。



二、乐观锁

乐观锁是相对悲观锁而言的,乐观锁假设数据一般情况下不会造成冲突,所以在数据进行提交更新的时候,才会正式对数据的冲突与否进行检测,如果发现冲突了,则返回给用户错误的信息,让用户决定如何去做



三,实现方式


悲观锁


是先通过for update的方式进行加锁,然后再进行修改。这是比较典型的悲观锁策略

如果以上修改库存的代码发生并发,同一时间只有一个线程可以开启事务并获得id=1的锁,其它的事务必须等本次事务提交之后才能执行。这样可以保证当前的数据不会被其它事务修改。

上面提到,使用select… for update会把数据给锁住,不过需要注意一些锁的级别,

MySQL InnoDB默认行级锁。行级锁都是基于索引的,如果一条SQL语句用不到索引是不会使用行级锁的,会使用表级锁把整张表锁住,这点需要注意

//service中
@Transactional(rollbackFor = Exception.class)
    public void updateBalanceById() {
        User user = userMapper.selectUserById(1);
        userMapper.updateBalanceById(1,new BigDecimal("100"));
    }
    
//UserMapper中
     User selectUserById(@Param("id") int id);
     int updateBalanceById(@Param("id") int id, @Param("balance") BigDecimal balance);
      
//userMapper.xml中的写法      
   <select id="selectUserById" resultType="com.myspringboot.springbootstudy.model.User">
           SELECT * FROM user WHERE id = #{id} for update
     </select>
        
   <update id="updateBalanceById">
        update user
        <set>
            balance = balance + #{balance}
        </set>
        where id = #{id}
    </update> 


乐观锁


乐观锁一般是用版本号和时间戳来实现的,具体写法如下

//service中写法
@Transactional(rollbackFor = Exception.class)
    public void updateBalanceByIdOptimistic() throws Exception{
        User user = userMapper.selectUserByIdOptimistic(1);
        int res = userMapper.updateBalanceByIdOptimistic(1,new BigDecimal("101"), user.getPubts());
        if(res <= 0){
            throw new Exception("更新数据失败!");
        }
    }

//mapper写法
User selectUserById(@Param("id") int id);
int updateBalanceByIdOptimistic(@Param("id") int id, @Param("balance") BigDecimal balance, @Param("pubts") Date pubts);

//xml中的写法
<select id="selectUserById" resultType="com.myspringboot.springbootstudy.model.User">
        SELECT * FROM user WHERE id = #{id} 
</select>
<update id="updateBalanceByIdOptimistic">
        update user
        <set>
            balance = balance + #{balance}
        </set>
        where id = #{id} and pubts = #{pubts}
 </update>


    

也可以用version 来控制

update user set balance = balance + #{balance}, version = version+1 where id = #{id} and version = #{version }

悲观锁优点:加锁能够保证数据安全,不至于出现逻辑混乱的情况,缺点:加锁可能会出现把整个表锁住的风 险,并发性能差,不能应对大的并发量

乐观锁的优点 :并发性能好,缺点容易出现更新失败的情况



版权声明:本文为m0_37937394原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。