zoukankan      html  css  js  c++  java
  • 高并发下乐观锁实现

    目前有业务并发更新某业务表,比如用户账户表,可考虑利用数据库乐观锁的办法解决。

    1、表设计

         需要在表中新增version字段,可定义为bigint类型,初始值可设置为0

    2、更新语句mybatis的实现

    <update id="updateConsumeStarWithLook">
            update sys_user_consume_star 
                set current_consume_star_amount = #{currentConsumeStarAmount},
                    update_time = #{updateTime, jdbcType=TIMESTAMP},
                    version = version + 1
                where id = #{id} and version = #{version}
        </update>

    3、业务逻辑层,实现思路:可定义一个更新方法,先查询出当前记录,根据业务进行调用乐观锁实现的updateConsumeStarWithLook,如果更新成功,即该返回值为1时,表示更新成功,当返回值为0时,表示未成功更新,可再次递归调用该更新方法。

    private void updateUserConsumeStarWithLook(String userId,Long starAmount) {
            
            Wrapper<SysUserConsumeStar> wrapper = new QueryWrapper<SysUserConsumeStar>()
                    .eq("user_id", userId);
            
            SysUserConsumeStar sysUserConsumeStar = sysUserConsumeStarService.getOne(wrapper);
            
            Long oldStartAmount = sysUserConsumeStar.getCurrentConsumeStarAmount();
                     
            Long newStartAmount = oldStartAmount + starAmount;
    
            sysUserConsumeStar.setCurrentConsumeStarAmount(newStartAmount).setUpdateTime(LocalDateTime.now());
                    
            Integer result =  sysUserConsumeStarService.updateConsumeStarWithLook(sysUserConsumeStar);
            
            //如果更新失败则继续尝试直到成功为止
            if(result == 0) {
                
                updateUserConsumeStarWithLook(userId,flowType,starAmount);
                
            }
        }

    4、在具体调用上述方法的方法上如果需要加上事务,则需要将事务的隔离级别定义为读已提交,不然在查询的时候会出现脏读,更新无法成功,导致死循环

    @Transactional(rollbackFor = Exception.class,isolation=Isolation.READ_COMMITTED,propagation=Propagation.REQUIRED)

     5、测试,可使用JMater,相关教程可参考:https://blog.csdn.net/u010481688/article/details/81032259

  • 相关阅读:
    DB2开发系列之三——SQL函数
    DB2开发系列之二——SQL过程
    DB2开发系列之一——基本语法
    优化的“真谛”
    DB2性能调优
    AIX分页(交换)空间的监控
    AIX5L内存监控和调整
    直接删除undo及temp表空间文件后的数据库恢复一例
    【LeetCode】 -- 68.Text Justification
    关于linux下的.a文件与 .so 文件
  • 原文地址:https://www.cnblogs.com/conswin/p/10724343.html
Copyright © 2011-2022 走看看