分布式锁、Lua脚本、redisson、运行lua脚本优化代码

news2024/11/15 8:14:40

20240721

  • 一、分布式锁
    • 1. 什么是分布式锁
    • 2. 分布式锁的实现
    • 3. 基于redis的分布式锁
    • 4 总结
  • 二、对于lua脚本可以保证事务,要么成功要么失败。
    • 1. 在redis中调用lua脚本
  • 三、Redisson
    • 1 步骤
    • 2. Redisson的总结
    • 3. 几种分布式锁的区别
  • 三、优化我们的秒杀
    • 1. 我们在创建优惠券的时候,就把他存入redis中,然后对于判断库存和id是否重复下单的操作,我们就在redis中操作
    • 2. 编写lua脚本
    • 3. 在代码里面运行lua脚本

(来源于黑马—太困了,有一些忘了,每天补)

一、分布式锁

1. 什么是分布式锁

因为我们会有多个线程,比如我们的后端服务器有多个,通过nginx进行负载均衡,就会导致我们锁失效,多个服务器都能访问到。
在这里插入图片描述

2. 分布式锁的实现

在这里插入图片描述

3. 基于redis的分布式锁

在这里插入图片描述

4 总结

在这里插入图片描述

二、对于lua脚本可以保证事务,要么成功要么失败。

1. 在redis中调用lua脚本

在这里插入图片描述

三、Redisson

1 步骤

也可以在配置文件中配置,但可能会导致和redis的配置冲突,所以写成配置类。
在这里插入图片描述
在这里插入图片描述

2. Redisson的总结

在这里插入图片描述

3. 几种分布式锁的区别

在这里插入图片描述

三、优化我们的秒杀

在这里插入图片描述

1. 我们在创建优惠券的时候,就把他存入redis中,然后对于判断库存和id是否重复下单的操作,我们就在redis中操作

    @Override
    @Transactional
    public void addSeckillVoucher(Voucher voucher) {
        // 保存优惠券
        save(voucher);
        // 保存秒杀信息
        SeckillVoucher seckillVoucher = new SeckillVoucher();
        seckillVoucher.setVoucherId(voucher.getId());
        seckillVoucher.setStock(voucher.getStock());
        seckillVoucher.setBeginTime(voucher.getBeginTime());
        seckillVoucher.setEndTime(voucher.getEndTime());
        seckillVoucherService.save(seckillVoucher);
        //保存秒杀优惠券的库存到Redis中
        stringRedisTemplate.opsForValue().set("secKill:stock:" + voucher.getId(), voucher.getStock().toString());
    }

2. 编写lua脚本

-- 1.参数列表
-- 1.1 优惠券id
local voucherId= ARGV[1]
-- 1.2 用户id
local userId=ARGV[2]

-- 2.数据key
-- 2.1 库存key
local stockKey='secKill:stock:'..voucherId -- 连接的时候,是使用..来连接  里面存的是库存
-- 2.2 订单key
local orderKey='secKill:order'..voucherId   --  里面存的是下单人的id


-- 3.脚本业务
-- 3.1 判断库存是否充足,get stockKey
if(tonumber(redis.call('get',stockKey)) <=0) then  -- redis.call('get',stockKey)返回的是一个string类型的,无法和0进行比较,所以,转换
    -- 3.2 库存不足,返回1

return 1 -- 什么意思
end
-- 3.3 判断用户是否已经购买过,SISMEMBER orderKye userId   对于set类型 sadd是添加,SISMEMBER是判断是否存在
if(tonumber(redis.call('SISMEMBER',orderKey,userId)) ==1) then
    --3.4 重复下单,返回2
    return 2
end
-- 3.5 扣减库存,incrby stockKey -1
redis.call('incrby',stockKey,-1)
-- 3.6 下单,sadd orderKye userId
redis.call('sadd',orderKey,userId)
return 0


3. 在代码里面运行lua脚本

 /**
     * * 使用lua脚本实现秒杀
     */
    private static final DefaultRedisScript<Long> SECKILL_SCRIPT;//DefaultRedisScript 是 Spring Data Redis 提供的一个类,用于封装 Redis Lua 脚本。在这个上下文中
    static {
//static { ... }
//这是一个静态初始化块,用于在类加载时初始化 SECKILL_SCRIPT 实例。
//在这个块中,设置了 SECKILL_SCRIPT 的具体属性,包括脚本的位置和结果类型。
        SECKILL_SCRIPT = new DefaultRedisScript<>();
        SECKILL_SCRIPT.setLocation(new ClassPathResource("seckill.lua"));
        SECKILL_SCRIPT.setResultType(Long.class);
    }
    /**
     * 使用lua
     * @param voucherId
     * @return
     */
    @Override
    public Result seckillVoucher(Long voucherId) {
        //获取用户
        Long userId= UserHolder.getUser().getId();
        //1.执行lua脚本
        Long result = stringRedisTemplate.execute(//总共三个参数,第一个参数是我们的lua脚本,第二个是KEY的参数,第三个是ARGV的参数(有两个)
                SECKILL_SCRIPT,
                Collections.emptyList(),//KEY的参数,传一个空集合
                voucherId.toString(),//ARGV的参数
                userId.toString()
        );
        //2.判断结果是否为0
        int i = result.intValue();//转型
        if(result!=0){
            //2.1不为零,没有购买资格
            return Result.fail(result == 1 ? "库存不足" : "不能重复下单");
        }
        //2.2为0,有购买资格,把下单信息保存到阻塞队列
        long orderId=redisIdWorker.nextId("order");//用我们之前的生成全局唯一的订单id方法生成订单
        //TODO 保存到阻塞队列

        //3.返回订单id
        return Result.ok(orderId);
    }

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

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

相关文章

Mybatis-Plus代码生成器配置方法

Mybatis-Plus网址&#xff1a;https://baomidou.com/pages/779a6e/#%E4%BD%BF%E7%94%A8 第一步&#xff1a;引入依赖 <!-- 代码生成器 --> <dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-generator</artifactId>…

IFIX6.5变量创建进阶-标签组用法

IFIX6.5变量创建进阶-标签组用法 普通变量创建 https://blog.csdn.net/hmxm6/article/details/140507111 OPC数据连接 项目介绍和应用场景 在实际项目中可能有好几个相同标签变量属于一类的 比如现在有三台风机&#xff0c;都有启动停止风量的三个数据 数据库里面需要创…

EI成稿丨明年上检索

基于xxxx嵌入式系统的无线传感网络路由优化算法研究基于网络安全xxxx全球互联网经济发展趋势分析基于深度学习的大数据xxxxx基于全IP物联网网络xxxxx安全管理中的优化研究xxxxx农业可持续发展评价及升级路径研究xxxxx分层轮廓数字化转型风险评估与防范策略基于Kano模型与xxxxx公…

防火墙--内容安全

目录 概述 IAE引擎流程 DPI深度包检测 基于特征字的检测技术 基于应用网关的检测技术 基于行为模式的检测技术 DFI深度流检测 基于数据流进行识别检测的技术 DPI和DFI对比 IDS&#xff08;入侵检测&#xff09; IPS&#xff08;入侵防御&#xff09; 优势 入侵检测…

使用百度语音技术实现文字转语音

使用百度语音技术实现文字转语音 SpringBootVue前后端分离项目 调用api接口需要使用AK和SK生成AccessToken,生成getAccessToken的接口有跨域限制,所以统一的由后端处理了 部分参数在控制台->语音技术->在线调试里面能找到 Controller RestController RequestMapping(&q…

测试——Junit

内容大纲: 常用的五个注解 测试用例顺序指定 参数化 测试套件 断言 1. 常用的五个注解 1.1 Test 通常情况下,我们输入要写在main方法下,此时我想直接输出: Test void Test01(){System.out.println("第一个测试用例"); } 1.2 BeforeAll AfterAll BeforeALL在Tes…

Unity: TextMeshPro生成中文字体(附3.5k,7k,2w常用字集)

免费常用3千5&#xff0c;7千字&#xff0c;2万字中文字体包 1.选择Window/TextMeshPro/Font Asset Creator 注&#xff1a;准备字体&#xff1a;从字体库或其他来源获取中文字体文件&#xff0c;通常为.ttf、.otf或.ttc格式。最简单的方式是从Windows系统文件的Font文件夹里…

NV Switch 深度解析与性能剖析

NV Switch 深度解析与性能剖析 在当今高性能计算领域&#xff0c;英伟达&#xff08;NVIDIA&#xff09;的GPU技术犹如璀璨明星般闪耀。随着人工智能和机器学习技术的迅猛发展&#xff0c;对计算能力的需求不断攀升&#xff0c;实现GPU间的高效互联互通变得至关重要。正因如此&…

C# 实现跨进程条件变量

C# 进程通信系列 第一章 共享内存 第二章 条件变量&#xff08;本章&#xff09; 第三章 消息队列 文章目录 C# 进程通信系列前言一、关键实现1、用到的主要对象2、初始化区分创建和打开3、变量放到共享内存4、等待和释放逻辑 二、完整代码三、使用示例1、同步控制2、跨进程控…

通义千问大模型API调用示例

通义千问是由阿里云自主研发的大语言模型&#xff0c;用于理解和分析用户输入的自然语言。 模型概览 模型名称模型简介模型输入/输出限制qwen-turbo通义千问超大规模语言模型&#xff0c;支持中文、英文等不同语言输入模型支持8k tokens上下文&#xff0c;为了保证正常的使用…

Python数据可视化------动态柱状图

一、基础柱状图 # 基础柱状图 # 导包 from pyecharts.charts import Bar from pyecharts.options import *# 构建柱状图 bar Bar() # 添加数据&#xff08;列表&#xff09; x_list ["张三", "李四", "王五", "赵六"] y_list [50,…

vue引用js html页面 vue引用js动态效果

要引用的index.html页面&#xff1a;&#xff08;资源来自网络&#xff09;在pubilc下建一个static文件放入js文件 <!DOCTYPE html> <html lang"en"><head><meta charset"UTF-8"><title>数字翻转</title><meta con…

基于SpringBoot+Vue的校园志愿者管理系统(带1w+文档)

基于SpringBootVue的校园志愿者管理系统(带1w文档) 基于SpringBootVue的校园志愿者管理系统(带1w文档) 本次设计任务是要设计一个校园志愿者管理系统&#xff0c;通过这个系统能够满足管理员和志愿者的校园志愿者信息管理功能。系统的主要功能包括首页、个人中心、志愿者管理、…

多线程应用

并发与并行 计算机操作系统对于并发性和并行性的概念给出的定义是&#xff1a; 并行性是指两个或多个事件在同一时刻发生&#xff1b; 并发性是指两个或多个事件在同一时间段内发生。 并发是指多个任务(线程)都请求运行&#xff0c;如果系统只有一个CPU,CPU只能按受一个任务&…

java学习--断点调试

可进入调用的方法里看源码

C2W2.Assignment.Parts-of-Speech Tagging (POS).Part1

理论课&#xff1a;C2W2.Part-of-Speech (POS) Tagging and Hidden Markov Models 文章目录 0 Data Sources1 POS Tagging1.1 TrainingTransition countsEmission countsTag countsExercise 01 1.2 TestingExercise 02 理论课&#xff1a; C2W2.Part-of-Speech (POS) Tagging…

创建自己的 app: html网页直接打包成app;在线网页打包app工具fusionapp、pake

1、html网页直接打包成app 主要通过hbuilderx框架工具来进行打包 https://www.dcloud.io/hbuilderx.html 参考&#xff1a; https://www.bilibili.com/video/BV1XG411r7QZ/ https://www.bilibili.com/video/BV1ZJ411W7Na 1&#xff09;网页制作 这里做的工具是TodoList 页面&a…

数据结构——栈的实现(java实现)与相应的oj题

文章目录 一 栈栈的概念:栈的实现&#xff1a;栈的数组实现默认构造方法压栈获取栈元素的个数出栈获取栈顶元素判断当前栈是否为空 java提供的Stack类Stack实现的接口&#xff1a; LinkedList也可以当Stack使用虚拟机栈&#xff0c;栈帧&#xff0c;栈的三个概念 二 栈的一些算…

Android 11 HAL层集成FFMPEG

1.集成目录&#xff1a; android/vendor/noch/common/external/NoboMediaCodec 2.文件夹目录 3. Android.mk实现 # Copyright #LOCAL_PATH : $(call my-dir)SF_COMMON_MK : $(LOCAL_PATH)/common.mkinclude $(call first-makefiles-under,$(LOCAL_PATH))4.common.mk实现 # #…

Xilinx FPGA DDR4 接口配置基础(PG150)

1. 简介 1.1 DDR4 SDRAM 控制器主要特点 支持8到80位接口宽度的组件&#xff08;支持 RDIMM、LRDIMM、UDIMM 和 SODIMM&#xff09; 最大组件限制为9&#xff0c;此限制仅适用于组件&#xff0c;不适用于 DIMM。密度支持 最高支持 32 GB 的组件密度&#xff0c;64 GB 的 LRDI…