当前位置: 首页 > article >正文

【分布式锁通关指南 05】通过redisson实现分布式锁

引言

在上个篇章中,我们通过redis手撸了一套分布式锁,但是最后也提到了它依然存在不完美的地方。那么有没有更简单和靠谱的实现方式。当然有,在本篇章中,我们将讲解如何使用redisson框架实现分布式锁以及理解它的源码。

什么是redisson

一句话总结-redis的高性能客户端,我们选择它是因为它内部已经封装好了很多锁的实现,详细介绍可以通过redisson的Github主页来查看。

在这里插入图片描述

SpringBoot整合redisson

我们继续以扣减库存的案例为例,看看如何通过SpringBoot来整合redisson,从而解决并发问题。

1.引入依赖

redisson的Github的readme里我们可以找到它的Quick start,里面就有最新版本的引入指引,当然你也可以在maven的中央仓库中找到。

在这里插入图片描述## 2.配置对象

接着将redisson的客户端对象注册成Bean,方便我们在别的service里可以注入使用,代码如下:

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 RedissonConfig {

    @Bean
    public RedissonClient redissonClient(){
        Config config = new Config();
        config.useSingleServer().setAddress("redis://127.0.0.1:6379");
        return Redisson.create(config);
    }
    
}

3.代码实现

redisson的封装非常完善,我们只需要获取锁、加锁、解锁即可,改造后的代码如下:


@Autowired
private RedissonClient redissonClient;


public String deductStockRedissonLock(Long goodsId, Integer count) {
    RLock lock = null;
    try {
        lock = redissonClient.getLock("lock" + goodsId);
        lock.lock();
        //1.查询商品库存数量
        String stock = template.opsForValue().get("stock" + goodsId);
        if (StringUtil.isNullOrEmpty(stock)) {
            return "商品不存在!";
        }
        int lastStock = Integer.parseInt(stock);
        //2.判断库存数量是否足够
        if (lastStock < count) {
            return "库存不足!";
        }
        //3.如果库存数量足够,则去扣减库存
        template.opsForValue().set("stock" + goodsId, String.valueOf(lastStock - count));
        return "扣减库存成功";
    } catch (Exception e) {
        throw new RuntimeException(e);
    } finally {
        if (lock != null) {
            lock.unlock();
        }
    }
}

在上个章节中我们考虑的锁重入、锁超时、锁阻塞等问题,这个时候我们不再需要考虑,它的底层都已经为我们完成了封装,我们只需要用即可,相关实现的源码我们会在后续章节中为大家带来讲解。

4.测试

改造完成后我们启动服务,先准备5000个库存,如下:

在这里插入图片描述
接着通过JMeter进行压测:

在这里插入图片描述
此时,库存剩余数量也为0,说明也无并发问题。

在这里插入图片描述

小结

本篇通过对redisson的整合,我们简化了分布式锁的实现,不用再关注各种边界情况,但是它做了什么样的封装也是需要我们学习的。因此,在后续的几个篇章里,将会为大家剖析redisson有关锁实现的源码。


http://www.kler.cn/a/566550.html

相关文章:

  • 【Docker】Dify+ollama+deepseek(打造本地私有化大模型)
  • ansible故障排查思路
  • 人工智能丨机器学习中特征的含义,什么是离散特征,什么是连续特征
  • 单片机的串口(USART)
  • 怎样分辨是否是高防服务器?
  • 可以用于promise面试的例子--其1
  • 【MATLAB代码】RSA加密和解密例程
  • 4个小时开发DeepSeek+baiduNaotu一键生成思维导图
  • DeepSeek-V3:AI语言模型的高效训练与推理之路
  • 基于coze+微信小程序实现图片上传并利用大模型解析
  • FX PDF编辑器支持在手机上进行各种PDF文档的操作
  • 【HeadFirst系列之HeadFirst设计模式】第14天之复合模式:设计模式的终极组合拳!
  • STM32呼吸灯实验手册(TIM定时器)
  • 基于Spring Boot + Vue的常规应急物资管理系统设计与实现
  • 构造一个工具(TravelSQLAgentTool),利用大语言模型(例如 Llama 模型)来完成 SQL 查询代理工具
  • XR应用测试:探索虚拟与现实的边界
  • unity pico开发 一:环境准备
  • 核弹级技术革命——搭配deepseek-r1满血版的腾讯云ai助手(codex)仅用14天独立开发出适配ARM架构的微内核操作系统!
  • 遇到liunx服务器IO负载,读IO流量峰值347MB/s,排查并解决。
  • 【STM32F103ZET6——库函数】4.串口通讯