【分布式锁】Redission实现分布式锁

🕗 发布于 2024-07-24 08:45 分布式

接着上一节，我们遇到了超卖的问题，并通过Redis实现分布式锁，进行了解决。本节我将换一种方式实现分布式锁。

前提：
nginx、redis、nacos
模块1：
provider-and-consumer 端口 8023
模块2
rabbitmq-consumer 端口 8021

添加依赖

<dependency>
    <groupId>org.redisson</groupId>
    <artifactId>redisson</artifactId>
    <version>3.15.6</version>
</dependency>

业务代码

模块1代码 RedisTestController.java

package com.atguigu.gulimall.providerconsumer.controller;

import lombok.extern.slf4j.Slf4j;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.UUID;
import java.util.concurrent.TimeUnit;

/**
 * @author: jd
 * @create: 2024-07-08
 */
@RestController
@RequestMapping("/test")
@Slf4j
public class RedisTestController {


    @Autowired
    private StringRedisTemplate stringRedisTemplate;
    @Autowired
    private RedissonClient redissonClient;

    @GetMapping("/RedissonLock")
   public String  deductStockByRedisson(){

        //写死一个固定商品ID，作为我们被秒杀的商品
        String lockKey="lock:product:102";
        //获取锁对象
        RLock lock = redissonClient.getLock(lockKey);
        //加锁，使用lock方法，锁将会自动续命
        lock.lock();
        try{
            //获取当前库存
            String stock1 = stringRedisTemplate.opsForValue().get("stock");
            if(stock1==null){
                System.out.println("秒杀未开始,请等开始后操作下单");
                return "end";
            }

            int stock = Integer.parseInt(stringRedisTemplate.opsForValue().get("stock"));
            if(stock>0){
                // 扣减库存
                int realStock = stock - 1;
                // 更新库存
                stringRedisTemplate.opsForValue().set("stock", realStock + "");
                System.out.println("扣减成功，剩余的库存为：" + realStock);
            }else {
                System.out.println("扣减库存失败，库存不足");
            }
        }finally {
            if(lock.isLocked()&&lock.isHeldByCurrentThread()){
                //释放分布式锁
                lock.unlock();
                System.out.println("分布式锁释放"); //解锁
            }
        }

        return "end";
   }



}

模块2代码 RedisTestController.java

package com.atguigu.gulimall.rabbitmqconsumer.controller;

import lombok.extern.slf4j.Slf4j;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.UUID;
import java.util.concurrent.TimeUnit;

/**
 *
 * 和provider-and-consumer 这两个服务中都有这个RedisTestController，用来模拟两个不同的服务
 * @author: jd
 * @create: 2024-07-08
 */
@RestController
@RequestMapping("/test")
@Slf4j
public class RedisTestController {


    @Autowired
    private StringRedisTemplate stringRedisTemplate;

    @Autowired
    private RedissonClient redissonClient;

    @GetMapping("/RedissonLock")
    public String  deductStockByRedisson(){

        //写死一个固定商品ID，作为我们被秒杀的商品
        String lockKey="lock:product:102";
        //获取锁对象
        RLock lock = redissonClient.getLock(lockKey);
        //加锁，使用lock方法，锁将会自动续命
        lock.lock();
        try{
            //获取当前库存
            String stock1 = stringRedisTemplate.opsForValue().get("stock");
            if(stock1==null){
                System.out.println("秒杀未开始,请等开始后操作下单");
                return "end";
            }

            int stock = Integer.parseInt(stringRedisTemplate.opsForValue().get("stock"));
            if(stock>0){
                // 扣减库存
                int realStock = stock - 1;
                // 更新库存
                stringRedisTemplate.opsForValue().set("stock", realStock + "");
                System.out.println("扣减成功，剩余的库存为：" + realStock);
            }else {
                System.out.println("扣减库存失败，库存不足");
            }
        }finally {
            if(lock.isLocked()&&lock.isHeldByCurrentThread()){
                //释放分布式锁
                lock.unlock();
                System.out.println("分布式锁释放"); //解锁
            }

        }

        return "end";
    }

}

测试结果：
单次请求，我发送两次，结果：
在这里插入图片描述

在这里插入图片描述

第二次：

在这里插入图片描述

成功扣减。

并发情况模拟：
当前库存数
在这里插入图片描述
压测：

并发压测结果：
8023模块

扣减成功，剩余的库存为：83
分布式锁释放
扣减成功，剩余的库存为：81
分布式锁释放
扣减成功，剩余的库存为：80
分布式锁释放
扣减成功，剩余的库存为：78
分布式锁释放
扣减成功，剩余的库存为：76
分布式锁释放
扣减成功，剩余的库存为：75
分布式锁释放
扣减成功，剩余的库存为：72
分布式锁释放
扣减成功，剩余的库存为：68
分布式锁释放
扣减成功，剩余的库存为：66
分布式锁释放
扣减成功，剩余的库存为：64
分布式锁释放
扣减成功，剩余的库存为：62
分布式锁释放
扣减成功，剩余的库存为：60
分布式锁释放
扣减成功，剩余的库存为：58
分布式锁释放
扣减成功，剩余的库存为：56
分布式锁释放
扣减成功，剩余的库存为：54
分布式锁释放
扣减成功，剩余的库存为：52
分布式锁释放
扣减成功，剩余的库存为：50
分布式锁释放
扣减成功，剩余的库存为：48
分布式锁释放
扣减成功，剩余的库存为：46
分布式锁释放
扣减成功，剩余的库存为：44
分布式锁释放
扣减成功，剩余的库存为：42
分布式锁释放
扣减成功，剩余的库存为：40
分布式锁释放
扣减成功，剩余的库存为：38
分布式锁释放
扣减成功，剩余的库存为：36
分布式锁释放
扣减成功，剩余的库存为：34
分布式锁释放
扣减成功，剩余的库存为：32
分布式锁释放
扣减成功，剩余的库存为：30
分布式锁释放
扣减成功，剩余的库存为：28
分布式锁释放
扣减成功，剩余的库存为：26
分布式锁释放
扣减成功，剩余的库存为：24
分布式锁释放
扣减成功，剩余的库存为：22
分布式锁释放
扣减成功，剩余的库存为：20
分布式锁释放
扣减成功，剩余的库存为：18
分布式锁释放
扣减成功，剩余的库存为：16
分布式锁释放
扣减成功，剩余的库存为：14
分布式锁释放
扣减成功，剩余的库存为：12
分布式锁释放
扣减成功，剩余的库存为：10
分布式锁释放
扣减成功，剩余的库存为：8
分布式锁释放
扣减成功，剩余的库存为：6
分布式锁释放
扣减成功，剩余的库存为：4
分布式锁释放
扣减成功，剩余的库存为：2
分布式锁释放
扣减库存失败，库存不足
分布式锁释放
扣减库存失败，库存不足
分布式锁释放
扣减库存失败，库存不足
分布式锁释放
扣减库存失败，库存不足
分布式锁释放
扣减库存失败，库存不足
分布式锁释放
扣减库存失败，库存不足
分布式锁释放
扣减库存失败，库存不足
分布式锁释放
扣减库存失败，库存不足
分布式锁释放
扣减库存失败，库存不足
分布式锁释放

8021模块日志

扣减成功，剩余的库存为：82
分布式锁释放
扣减成功，剩余的库存为：79
分布式锁释放
扣减成功，剩余的库存为：77
分布式锁释放
扣减成功，剩余的库存为：74
分布式锁释放
扣减成功，剩余的库存为：73
分布式锁释放
扣减成功，剩余的库存为：71
分布式锁释放
扣减成功，剩余的库存为：70
分布式锁释放
扣减成功，剩余的库存为：69
分布式锁释放
扣减成功，剩余的库存为：67
分布式锁释放
扣减成功，剩余的库存为：65
分布式锁释放
扣减成功，剩余的库存为：63
分布式锁释放
扣减成功，剩余的库存为：61
分布式锁释放
扣减成功，剩余的库存为：59
分布式锁释放
扣减成功，剩余的库存为：57
分布式锁释放
扣减成功，剩余的库存为：55
分布式锁释放
扣减成功，剩余的库存为：53
分布式锁释放
扣减成功，剩余的库存为：51
分布式锁释放
扣减成功，剩余的库存为：49
分布式锁释放
扣减成功，剩余的库存为：47
分布式锁释放
扣减成功，剩余的库存为：45
分布式锁释放
扣减成功，剩余的库存为：43
分布式锁释放
扣减成功，剩余的库存为：41
分布式锁释放
扣减成功，剩余的库存为：39
分布式锁释放
扣减成功，剩余的库存为：37
分布式锁释放
扣减成功，剩余的库存为：35
分布式锁释放
扣减成功，剩余的库存为：33
分布式锁释放
扣减成功，剩余的库存为：31
分布式锁释放
扣减成功，剩余的库存为：29
分布式锁释放
扣减成功，剩余的库存为：27
分布式锁释放
扣减成功，剩余的库存为：25
分布式锁释放
扣减成功，剩余的库存为：23
分布式锁释放
扣减成功，剩余的库存为：21
分布式锁释放
扣减成功，剩余的库存为：19
分布式锁释放
扣减成功，剩余的库存为：17
分布式锁释放
扣减成功，剩余的库存为：15
分布式锁释放
扣减成功，剩余的库存为：13
分布式锁释放
扣减成功，剩余的库存为：11
分布式锁释放
扣减成功，剩余的库存为：9
分布式锁释放
扣减成功，剩余的库存为：7
分布式锁释放
扣减成功，剩余的库存为：5
分布式锁释放
扣减成功，剩余的库存为：3
分布式锁释放
扣减成功，剩余的库存为：1
分布式锁释放
扣减成功，剩余的库存为：0
分布式锁释放
扣减库存失败，库存不足
分布式锁释放
扣减库存失败，库存不足
分布式锁释放
扣减库存失败，库存不足
分布式锁释放
扣减库存失败，库存不足
分布式锁释放
扣减库存失败，库存不足
分布式锁释放
扣减库存失败，库存不足
分布式锁释放
扣减库存失败，库存不足
分布式锁释放

可以看到，没有超卖现象。至此Redission实现分布式锁已经OK。
redis实现分布式锁可见博文：【分布式锁】Redis实现分布式锁

原文地址：https://blog.csdn.net/qq_39666711/article/details/140629060

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！

上一篇：Vue系列面试题
下一篇：为Jetson Xavier NX安装合适版本的pytorch（解决torch not compiled with cuda enabled）

YOLOv9改进策略【注意力机制篇】| MCAttention 多尺度交叉轴注意力
本文记录的是基于MCA注意力模块的YOLOv9目标检测改进方法研究。普通的轴向注意力难以实现长距离交互，不利于捕获分割任务中所需的空间结构或形状，而MCA注意力，在改进YOLOv9的过程中，能够契合目
阅读更多2024-09-21
政务安全体系构建中的挑战
这些攻击通常具备高度隐蔽性和破坏性，传统的安全防护手段难以跟上攻击的变化速度，导致政务系统无法提供全面有效的保护。▋挑战二：人工处理安全事件效率低当前，安全事件的处理往往依赖于人工分析和手动操作，导致
阅读更多2024-09-21
TCP协议特点
TCP是一种可靠的传输控制协议，即在网络条件正常的情况下，TCP协议能够保证接收端收到所有数据，并且接收到的数据顺序与发送端一致。TCP通过在发送端给每个数据包分配单调递增的序列号，以及在接收端发送A
阅读更多2024-09-21
【Java EE】文件IO
文件IO
阅读更多2024-09-21
HTML5精粹练习第1章博客
用最新的HTML5标签来联系博客。
阅读更多2024-09-21
QT编译后，如何手动运行，或复制到其他机器运行
编译后（文件名叫Work.exe），通过QT功能，是可以成功运行的。如果在目录中双击，或复制到其他机器上运行，就会失败。
阅读更多2024-09-21
初学者的15个Python实用库
你可能知道 Python 的交互式 shell，这是运行 Python 的一种很好的方式。你可以用这个库做很多很棒的事情。在本文中，我重点介绍了15个最有用的包，详细说明了它们的功能和特性。IPyth
阅读更多2024-09-21
排序算法-归并排序
1. 归并的缺点在于需要O(N)的空间复杂度，归并排序的思考更多的是解决在磁盘中的外排序问题。2. 时间复杂度：O(N*logN)3. 空间复杂度：O(N)4. 稳定性：稳定我的主页还有其他排序算法欢
阅读更多2024-09-21
无人机集群路径规划：雾凇优化算法（ rime optimization algorithm，RIME）求解无人机集群路径规划，提供MATLAB代码
无人机三维路径规划是指在三维空间中为无人机规划一条合理的飞行路径，使其能够安全、高效地完成任务。路径规划是无人机自主飞行的关键技术之一，它可以通过算法和模型来确定无人机的航迹，以避开障碍物、优化飞行时
阅读更多2024-09-21
git pull 报错 refusing to merge unrelated histories
git pull 报错 refusing to merge unrelated histories
阅读更多2024-09-21

【分布式锁】Redission实现分布式锁

相关文章