(四)库存超卖案例实战——优化redis分布式锁

news2024/11/18 17:33:05

前言

在上一节内容中，我们已经实现了使用redis分布式锁解决商品“超卖”的问题，本节内容是对redis分布式锁的优化。在上一节的redis分布式锁中，我们的锁有俩个可以优化的问题。第一，锁需要实现可重入，同一个线程不用重复去获取锁；第二，锁没有续期功能，导致业务没有执行完成就已经释放了锁，存在一定的并发访问问题。本案例中通过使用redis的hash数据结构实现可重入锁，使用Timer实现锁的续期功能，完成redis分布式锁的优化。最后，我们通过集成第三方redisson工具包，完成分布式锁以上俩点的优化内容。Redisson提供了简单易用的API，使得开发人员可以轻松地在分布式环境中使用Redis。

正文

  • 加锁的lua脚本：使用exists和hexists指令判断是否存在锁，如果不存在或者存在锁并且该锁下面的field有值，就使用hincrby指令使锁的值加1，实现可重入，否则直接返回0，加锁失败。
if redis.call('exists', KEYS[1]) == 0 or redis.call('hexists', KEYS[1], ARGV[1]) == 1 " +
"then " +
"   redis.call('hincrby', KEYS[1], ARGV[1], 1) " +
"   redis.call('expire', KEYS[1], ARGV[2]) " +
"   return 1 " +
"else " +
"   return 0 " +
"end"
  • 解锁的lua脚本: 使用hexists指令判断是否存在锁，如果为0，代表没有对应field字段的锁，直接返回nil；如果使用hincrby指令使锁field字段锁的值减少1之后值为0，代表锁已经不在占用，可以删除该锁；否则直接返回0，代表是可重入锁，锁还没有释放。
if redis.call('hexists', KEYS[1], ARGV[1]) == 0 " +
"then " +
"   return nil " +
"elseif redis.call('hincrby', KEYS[1], ARGV[1], -1) == 0 " +
"then " +
"   return redis.call('del', KEYS[1]) " +
"else " +
"   return 0 " +
"end"
  •  实现续期的lua脚本：使用hexists指令判断锁的field值是否存在，如果值为1存在，则将该锁的过期时间更新，否则直接返回0，代表没有找到该锁，续期失败。
if redis.call('hexists', KEYS[1], ARGV[1]) == 1 " +
"then " +
"   return redis.call('expire', KEYS[1], ARGV[2]) " +
"else " +
"   return 0 " +
"end";
  • 创建一个自定义的锁工具类MyRedisDistributeLock，实现加锁、解锁、续期功能

- MyRedisDistributeLock实现

package com.ht.atp.plat.util;

import org.jetbrains.annotations.NotNull;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.core.script.DefaultRedisScript;

import java.util.Arrays;
import java.util.Timer;
import java.util.TimerTask;
import java.util.UUID;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;


public class MyRedisDistributeLock implements Lock {

    public MyRedisDistributeLock(StringRedisTemplate redisTemplate, String lockName, long expire) {
        this.redisTemplate = redisTemplate;
        this.lockName = lockName;
        this.expire = expire;
        this.uuid = getId();
    }

    /**
     * redis工具类
     */
    private StringRedisTemplate redisTemplate;


    /**
     * 锁名称
     */
    private String lockName;

    /**
     * 过期时间
     */
    private Long expire;

    /**
     * 锁的值
     */
    private String uuid;

    @Override
    public void lock() {
        this.tryLock();
    }

    @Override
    public void lockInterruptibly() {

    }

    @Override
    public boolean tryLock() {
        try {
            return this.tryLock(-1L, TimeUnit.SECONDS);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return false;
    }

    @Override
    public boolean tryLock(long time, @NotNull TimeUnit unit) throws InterruptedException {
        if (time != -1) {
            this.expire = unit.toSeconds(time);
        }
        String script = "if redis.call('exists', KEYS[1]) == 0 or redis.call('hexists', KEYS[1], ARGV[1]) == 1 " +
                "then " +
                "   redis.call('hincrby', KEYS[1], ARGV[1], 1) " +
                "   redis.call('expire', KEYS[1], ARGV[2]) " +
                "   return 1 " +
                "else " +
                "   return 0 " +
                "end";
        while (!this.redisTemplate.execute(new DefaultRedisScript<>(script, Boolean.class), Arrays.asList(lockName), uuid, String.valueOf(expire))) {
            Thread.sleep(50);
        }
//        //加锁成功后，自动续期
        this.renewExpire();
        return true;
    }

    @Override
    public void unlock() {
        String script = "if redis.call('hexists', KEYS[1], ARGV[1]) == 0 " +
                "then " +
                "   return nil " +
                "elseif redis.call('hincrby', KEYS[1], ARGV[1], -1) == 0 " +
                "then " +
                "   return redis.call('del', KEYS[1]) " +
                "else " +
                "   return 0 " +
                "end";
        Long flag = this.redisTemplate.execute(new DefaultRedisScript<>(script, Long.class), Arrays.asList(lockName), uuid);
        if (flag == null) {
            throw new IllegalMonitorStateException("this lock doesn't belong to you!");
        }
    }

    @NotNull
    @Override
    public Condition newCondition() {
        return null;
    }

    /**
     * 给线程拼接唯一标识
     *
     * @return
     */
    private String getId() {
        return UUID.randomUUID() + "-" + Thread.currentThread().getId();
    }


    private void renewExpire() {
        String script = "if redis.call('hexists', KEYS[1], ARGV[1]) == 1 " +
                "then " +
                "   return redis.call('expire', KEYS[1], ARGV[2]) " +
                "else " +
                "   return 0 " +
                "end";
        new Timer().schedule(new TimerTask() {
            @Override
            public void run() {
                System.out.println("-------------------");
                Boolean flag = redisTemplate.execute(new DefaultRedisScript<>(script, Boolean.class), Arrays.asList(lockName), uuid, String.valueOf(expire));
                if (flag) {
                    renewExpire();
                }
            }
        }, this.expire * 1000 / 3);
    }
}

- 实现加锁功能

- 实现解锁功能


 - 使用Timer实现锁的续期功能

  • 使用MyRedisDistributeLock实现库存的加锁业务 

- 使用自定义MyRedisDistributeLock工具类实现加锁业务

public void checkAndReduceStock() {
        //1.获取锁
        MyRedisDistributeLock myRedisDistributeLock = new MyRedisDistributeLock(stringRedisTemplate, "stock", 10);
        myRedisDistributeLock.lock();

        try {
            // 2. 查询库存数量
            String stockQuantity = stringRedisTemplate.opsForValue().get("P0001");
            // 3. 判断库存是否充足
            if (stockQuantity != null && stockQuantity.length() != 0) {
                Integer quantity = Integer.valueOf(stockQuantity);
                if (quantity > 0) {
                    // 4.扣减库存
                    stringRedisTemplate.opsForValue().set("P0001", String.valueOf(--quantity));
                }
            } else {
                System.out.println("该库存不存在！");
            }
        } finally {
            myRedisDistributeLock.unlock();
        }
    }

- 启动服务7000、7001、7002，压测优化后的自定义分布式锁：平均访问时间362ms,吞吐量每秒246，库存扣减为0，表明优化后的分布式锁是可用的。

  • 集成redisson工具包，使用第三方工具包实现分布式锁，完成并发访问“超卖”问题案例演示
<dependency>
	<groupId>org.redisson</groupId>
	<artifactId>redisson-spring-boot-starter</artifactId>
	<version>3.11.6</version>
</dependency>
  • 创建一个redisson配置类，引入redisson客户端工具
package com.ht.atp.plat.config;

import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;


@Configuration
public class MyRedissonConfig {

    @Bean
    RedissonClient redissonClient() {
        Config config = new Config();
        config.useSingleServer()
                .setAddress("redis://192.168.110.88:6379");
        //配置看门狗的默认超时时间为30s,供续期使用
        config.setLockWatchdogTimeout(30000);
        return Redisson.create(config);
    }
}
  • 使用Redisson锁实现“超卖”业务方法 
//可重入锁
    @Override
    public void checkAndReduceStock() {
        // 1.加锁，获取锁失败重试
        RLock lock = this.redissonClient.getLock("lock");
        lock.lock();

        try {
            // 2. 查询库存数量
            String stockQuantity = stringRedisTemplate.opsForValue().get("P0001");
            // 3. 判断库存是否充足
            if (stockQuantity != null && stockQuantity.length() != 0) {
                Integer quantity = Integer.valueOf(stockQuantity);
                if (quantity > 0) {
                    // 4.扣减库存
                    stringRedisTemplate.opsForValue().set("P0001", String.valueOf(--quantity));
                }
            } else {
                System.out.println("该库存不存在！");
            }
        } finally {
            // 4.释放锁
            lock.unlock();
        }
    }
  • 开启7000、7001、7002服务，压测扣减库存接口 

- 压测结果：平均访问时间222ms，吞吐量为384每秒

- 库存扣减结果为0

结语

综上所述，无论是自定义分布式锁还是使用redisson工具类，都能实现分布式锁解决并发访问的“超卖问题”，redisson工具使用集成更加方便简洁，推荐使用redisson工具包。本节内容到这里就结束了，我们下期见。。。。。。

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

Linux 应用程序CPU调度优化

Linux 应用程序CPU调度优化

缘起 实时操作系统&#xff08;Real-time operating system, RTOS&#xff09;&#xff0c;又称即时操作系统&#xff0c;它会按照排序运行、管理系统资源&#xff0c;并为开发应用程序提供一致的基础。实时操作系统与一般的操作系统相比&#xff0c;最大的特色就是实时性&…
阅读更多...
如何通过员工工时管理降低企业成本？

如何通过员工工时管理降低企业成本？

作为当今快节奏商业环境的领导者或管理者&#xff0c;掌握员工的工作时间对于控制企业成本和确保每个人都各尽其责至关重要。 员工工时表软件就是这样一款工时跟踪管理解决方案&#xff1a;数字化的工时表有助于保护企业的财务不会被无节制的开支冲垮。然而&#xff0c;引入此…
阅读更多...
windows PC virtualBox 配置

windows PC virtualBox 配置

效果&#xff1a; oracle vitualbox 可以访问通PC主机&#xff0c;可以访问外网: 注意&#xff0c;如果docker0网络地址&#xff0c;和PC主机的网络地址冲突了&#xff0c;需要变更docker的网络地址&#xff1a; root/home/mysqlPcap/anti-tamper $ cat /etc/docker/daemon.js…
阅读更多...
C++初阶1

C++初阶1

目录 介绍&#xff1a; 一&#xff0c;命名空间 1-1&#xff0c;命名空间的定义 1-2&#xff0c;命名空间的使用 1-3&#xff0c;C标准官方命名空间 二&#xff0c;缺省参数 2.1&#xff0c;缺省参数分类 三&#xff0c;函数重载 四&#xff0c;引用 4-1&#xff0c;…
阅读更多...
论文阅读——ELECTRA

论文阅读——ELECTRA

论文下载&#xff1a;https://openreview.net/pdf?idr1xMH1BtvB 另一篇分析文章&#xff1a;ELECTRA 详解 - 知乎 一、概述 对BERT的token mask 做了改进。结合了GAN生成对抗模型的思路&#xff0c;但是和GAN不同。 不是对选择的token直接用mask替代&#xff0c;而是替换为…
阅读更多...
中国两轮“技术派”绿源，为全球电动市场带来跨越式方案

中国两轮“技术派”绿源，为全球电动市场带来跨越式方案

历史越长的行业&#xff0c;遇到变革之时&#xff0c;需要经历的考验、做出的突破就越多。两轮电动车&#xff0c;这个非常本土化的赛道&#xff0c;就是如此。 中国是两轮电动车产销大国&#xff0c;自上世纪晚期开始&#xff0c;中国两轮电动车迅速发展&#xff0c;绿源等一…
阅读更多...
【Linux】虚拟机部署与发布J2EE项目（Windows版本）

【Linux】虚拟机部署与发布J2EE项目（Windows版本）

&#x1f389;&#x1f389;欢迎来到我的CSDN主页&#xff01;&#x1f389;&#x1f389; &#x1f3c5;我是Java方文山&#xff0c;一个在CSDN分享笔记的博主。&#x1f4da;&#x1f4da; &#x1f31f;推荐给大家我的专栏《微信小程序开发实战》。&#x1f3af;&#x1f3a…
阅读更多...
优思学院｜精益管理的八步法

优思学院｜精益管理的八步法

精益管理是什么&#xff1f;所谓的精&#xff0c;即少而精&#xff0c;不投入多余的生产要素&#xff0c;只是在适当的时间生产必要数量的市场急需产品&#xff08;或下道工序急需的产品&#xff09;&#xff1b;所谓的益&#xff0c;即所有经营活动都要有益有效&#xff0c;具…
阅读更多...
【C语言】字符函数与字符串函数

【C语言】字符函数与字符串函数

简单不先于复杂&#xff0c;而是在复杂之后。 目录 0. 前言 1. 函数介绍 1.1 strlen 1.1.1 介绍 1.1.2 strlen 函数模拟实现 1.1.2.1 计数器方法 1.1.2.2 递归方法 1.1.2.3 指针 - 指针方法 1.2 strcpy 1.2.1 介绍 1.2.2 strcpy 函数模拟实现 1.3 strcat 1…
阅读更多...
TSINGSEE青犀睡岗离岗检测算法——确保加油站安全运营

TSINGSEE青犀睡岗离岗检测算法——确保加油站安全运营

众所周知&#xff0c;加油站是一个需要24小时营业的场所&#xff0c;由于夜间加油人员较少&#xff0c;员工极易处于疲劳或者睡眠状态&#xff0c;为保障安全和效率&#xff0c;通过TSINGSEE青犀睡岗离岗检测算法在加油站场景中&#xff0c;可以及时发现工作人员的疲劳状况&…
阅读更多...
Python---while循环中else的基本语法（是同级关系）

Python---while循环中else的基本语法（是同级关系）

为什么需要在while循环中添加else结构 循环可以和else配合使用&#xff0c; else下方缩进的代码指的是当循环正常结束之后要执行的代码。 强调&#xff1a; 循环 正常结束&#xff0c;else之后要执行的代码。 非正常结束&#xff0c;其else中的代码是不会执行的。&#…
阅读更多...
【软考系统架构设计师】2023年系统架构师冲刺模拟习题之《数据库系统》

【软考系统架构设计师】2023年系统架构师冲刺模拟习题之《数据库系统》

在数据库章节中可能会考察以下内容&#xff1a; 文章目录 数据库完整性约束&#x1f31f;数据库模式&#x1f31f;&#x1f31f;ER模式&#x1f31f;关系代数&#x1f31f;&#x1f31f;并发控制&#x1f31f;数据仓库与数据挖掘&#x1f31f;&#x1f31f;反规范化技术&#x…
阅读更多...
【卖断货攻略】抢先看：美国全品类30天爆量近2亿刀！

【卖断货攻略】抢先看：美国全品类30天爆量近2亿刀！

距离10月27日黑五大促正式上线不足6小时&#xff0c;你上车了吗&#xff1f; 看到TikTok美国市场近期的GMV走势图&#xff0c;就感觉这届黑五将不简单。 为助力跨境商家在这个关键节点做好最后准备&#xff0c;本期超店有数将从选品、营销两大角度为大家盘点现阶段TikTok Shop…
阅读更多...
体系结构评估——（三）风险承担者

体系结构评估——（三）风险承担者

风险承担者分为系统生产者、系统消费者、系统服务人员和其他四大类。 其中系统生产者有&#xff1a;软件系统架构师、开发人员、维护人员、集成人员、测试人员、标准专家、 性能工程师、安全专家、项目经理、产品线经理。 系统消费者有&#xff1a;客户、最终用户、应用开发…
阅读更多...
特征工程优化

特征工程优化

参考链接 https://www.bilibili.com/video/BV1WN4y1k7R1/?buvidXU0E30D0C6006B7F1EE1425156434CFEC440F&from_spmidtm.recommend.0.0&is_story_h5false&midfMtk7pz9LsVpSyGt0Mcizg%3D%3D&p1&plat_id116&share_fromugc&share_mediumandroid&sh…
阅读更多...
政务钉钉扫码登录(前端)

政务钉钉扫码登录(前端)

前提 使用 iframe 嵌入专有钉钉二维码页面&#xff0c;本篇仅说前端&#xff1b;需要申请 client_id 应用标识&#xff0c;但这里不赘述。详见此处&#xff1b;回调地址 redirect_uri&#xff0c;与服务器相关人员确认&#xff0c;但这里不赘述&#xff1b;扫码登录官方说明 …
阅读更多...
LeetCode 1465. 切割后面积最大的蛋糕

LeetCode 1465. 切割后面积最大的蛋糕

矩形蛋糕的高度为 h 且宽度为 w&#xff0c;给你两个整数数组 horizontalCuts 和 verticalCuts&#xff0c;其中&#xff1a; horizontalCuts[i] 是从矩形蛋糕顶部到第 i 个水平切口的距离 verticalCuts[j] 是从矩形蛋糕的左侧到第 j 个竖直切口的距离 请你按数组 horizontalC…
阅读更多...
【优选算法系列】第二节.双指针（202. 快乐数和11. 盛最多水的容器）

【优选算法系列】第二节.双指针（202. 快乐数和11. 盛最多水的容器）

作者简介&#xff1a;大家好&#xff0c;我是未央&#xff1b; 博客首页&#xff1a;未央.303 系列专栏&#xff1a;优选算法系列 每日一句&#xff1a;人的一生&#xff0c;可以有所作为的时机只有一次&#xff0c;那就是现在&#xff01;&#xff01;&#xff01;&#xff01…
阅读更多...
了解接口测试只需3分钟

了解接口测试只需3分钟

为什么要做接口测试&#xff1f; 在公司里&#xff0c;客户端和服务端通常是由不同的团队开发的&#xff0c;在项目开发过程中&#xff0c;客户端和服务端开发的进度不一致&#xff0c;比如服务端先开发完了&#xff0c;这个时候可以先对服务端进行接口测试&#xff0c;确保服…
阅读更多...
douyin ios 8404六神参数学习记录

douyin ios 8404六神参数学习记录

玩那么久安卓了&#xff0c;也终于换一换ios终端分析分析&#xff0c;还是熟悉的x-gorgon&#xff0c;x-argus&#xff0c;x-medusa那些参数。 随便抓个抖音 ios版本的接口&#xff1a; 像评论接口&#xff1a; https://api26-normal-hl.amemv.com/aweme/v2/comment/list/?…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023