【Redis 开发】Redisson

2024-04-28 11:20
文章标签 开发 redis redisson

本文主要是介绍【Redis 开发】Redisson,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

Redisson

  • Redisson
    • Redisson分布式锁
    • Redisson可重入锁
    • Redission解决超时释放的问题
    • Redission解决锁的判断一次性问题
    • Redission分布式锁主从一致性问题

Redisson

Redisson是一个在Redis的基础上实现的java驻内存数据网格,就是提供了一系列的分布式的java对象
官方地址:https://redisson.org

Redisson分布式锁

第一步:引入依赖

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

第二步:配置Redisson客户端:在配置文件中进行配置
这里通过配置类,完成对Redis的基本配置,在调用Redisson的创建方法根据这个配置类,创建出对应的客户端操作对象RedissonClient


@Configuration
public class RedisConfig {public RedissonClient redissonClient(){//配置类Config config=new Config();//添加redis地址,这里添加单点的地址,也可以使用config.useClusterServers()添加集群地址config.useSingleServer().setAddress("redis://192.168.75.135.101:6379").setPassword("520521");//创建客户端return Redisson.create(config);}
}

如何使用Redisson提供的分布式锁

    @Resourceprivate RedissonClient redissonClient;@Testvoid testRedisson() throws InterruptedException {//获取锁(可重入),指定锁的名称RLock nihao = redissonClient.getLock("nihao");//尝试获取锁,参数分别是,最大等待时间,锁自动释放时间,时间单位boolean b = nihao.tryLock(1, 10, TimeUnit.SECONDS);//判断锁释放获取成功if(b){try{System.out.println("执行业务");}finally {//释放锁nihao.unlock();}}}

Redisson可重入锁

在这里插入图片描述
原理就是在存放value的时候通过计数器机制进行重复访问,当同一个线程在此访问这个锁的时候会进行判断,是不是自己同一个线程,是的话计数器加1,同理释放锁的时候就是将该计数器的数字减1
基本流程:
在这里插入图片描述
要实现上述操作功能需要用到Lua脚本

local key = KEYS[1];-- 锁的key
local threadId = ARGV[1];-- 线程唯一标识
local releaseTime=ARGV[2];--锁的自动释放时间
-- 判断当前锁是否还是被自己持有
if(redis.call('HEXISTs",key,threadId)==0)then
return nil;--如果已经不是自己,则直接返回
end;
--是自己的锁,则重入次数-
1local count =redis.call('HINCRBY",key,threadId,-1);
--判断是否重入次数是否已经为0
if(count>0)then
--大于0说明不能释放锁,重置有效期然后返回
redis.call('EXPIRE",key, releaseTime);
return nil;
--等于0说明可以释放锁,直接删除
else
redis.call('DEL',key);
return nil;
end ;

这是可复用锁的底层原理
在Redisson的操作类中已经实现了可重复锁的相关实现,在获取锁的同时会自动进行重复锁判断

Redission解决超时释放的问题

Redisson底层通过使用Redis的watch机制和Lua脚本来实现解决超时释放锁的问题。当一个线程在获取锁时,Redisson会将锁的持有者信息保存到Redis中,并启动一个定时任务来监控锁的有效期。当锁的有效期超时时,定时任务会使用Lua脚本来检查锁是否还是当前线程持有,如果是则延长锁的有效期,如果不是则释放锁。这种机制可以确保在锁超时释放的情况下,不会出现并发访问问题。通过这种方式,Redisson能够在底层实现有效地解决超时释放的问题。

Redission解决锁的判断一次性问题

前面讲到在进行判断的时候如果没有拿到锁就会返回失败,Redis中提供了重试机制,设置一个最大等待时间,期间进行重复获取锁的操作

Redission分布式锁主从一致性问题

在当下的场景中都是多台Redis服务器进行主从服务器,假定这时有一个线程访问中Redis服务器,成功获取锁,就在这时,主服务器与从服务器同步数据的时候主服务器出现故障,这时Redis哨兵会从从服务器中选出一个来当主服务器,这是锁信息并未同步,就在这时其他线程也能够得到锁进行操作,就会出现问题

解决方案:
在Redisson中提供联锁方案,就是需要同时给多个Redis节点所送锁的信息,这时后就要判断,如果有一个失败,那么所有的节点获取锁都会失败

Rlock lock1=redissonClient.getLock("order");
Rlock lock2=redissonClient2.getLock("order");
Rlock lock3=redissonClient3.getLock("order");
//创建联锁
redissonClient.getMultiLock(lock1,lock2,lock3);

这篇关于【Redis 开发】Redisson的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/943124

相关文章

SpringBoot集成redisson实现延时队列教程

《SpringBoot集成redisson实现延时队列教程》文章介绍了使用Redisson实现延迟队列的完整步骤,包括依赖导入、Redis配置、工具类封装、业务枚举定义、执行器实现、Bean创建、消费... 目录1、先给项目导入Redisson依赖2、配置redis3、创建 RedissonConfig 配

基于 Cursor 开发 Spring Boot 项目详细攻略

《基于Cursor开发SpringBoot项目详细攻略》Cursor是集成GPT4、Claude3.5等LLM的VSCode类AI编程工具,支持SpringBoot项目开发全流程,涵盖环境配... 目录cursor是什么?基于 Cursor 开发 Spring Boot 项目完整指南1. 环境准备2. 创建

Redis 的 SUBSCRIBE命令详解

《Redis的SUBSCRIBE命令详解》Redis的SUBSCRIBE命令用于订阅一个或多个频道,以便接收发送到这些频道的消息,本文给大家介绍Redis的SUBSCRIBE命令,感兴趣的朋友跟随... 目录基本语法工作原理示例消息格式相关命令python 示例Redis 的 SUBSCRIBE 命令用于订

SpringBoot 多环境开发实战(从配置、管理与控制)

《SpringBoot多环境开发实战(从配置、管理与控制)》本文详解SpringBoot多环境配置,涵盖单文件YAML、多文件模式、MavenProfile分组及激活策略,通过优先级控制灵活切换环境... 目录一、多环境开发基础(单文件 YAML 版)(一)配置原理与优势(二)实操示例二、多环境开发多文件版

使用docker搭建嵌入式Linux开发环境

《使用docker搭建嵌入式Linux开发环境》本文主要介绍了使用docker搭建嵌入式Linux开发环境,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面... 目录1、前言2、安装docker3、编写容器管理脚本4、创建容器1、前言在日常开发全志、rk等不同

sky-take-out项目中Redis的使用示例详解

《sky-take-out项目中Redis的使用示例详解》SpringCache是Spring的缓存抽象层,通过注解简化缓存管理,支持Redis等提供者,适用于方法结果缓存、更新和删除操作,但无法实现... 目录Spring Cache主要特性核心注解1.@Cacheable2.@CachePut3.@Ca

Redis实现高效内存管理的示例代码

《Redis实现高效内存管理的示例代码》Redis内存管理是其核心功能之一,为了高效地利用内存,Redis采用了多种技术和策略,如优化的数据结构、内存分配策略、内存回收、数据压缩等,下面就来详细的介绍... 目录1. 内存分配策略jemalloc 的使用2. 数据压缩和编码ziplist示例代码3. 优化的

redis-sentinel基础概念及部署流程

《redis-sentinel基础概念及部署流程》RedisSentinel是Redis的高可用解决方案,通过监控主从节点、自动故障转移、通知机制及配置提供,实现集群故障恢复与服务持续可用,核心组件包... 目录一. 引言二. 核心功能三. 核心组件四. 故障转移流程五. 服务部署六. sentinel部署

Python实战之SEO优化自动化工具开发指南

《Python实战之SEO优化自动化工具开发指南》在数字化营销时代,搜索引擎优化(SEO)已成为网站获取流量的重要手段,本文将带您使用Python开发一套完整的SEO自动化工具,需要的可以了解下... 目录前言项目概述技术栈选择核心模块实现1. 关键词研究模块2. 网站技术seo检测模块3. 内容优化分析模

基于Redis自动过期的流处理暂停机制

《基于Redis自动过期的流处理暂停机制》基于Redis自动过期的流处理暂停机制是一种高效、可靠且易于实现的解决方案,防止延时过大的数据影响实时处理自动恢复处理,以避免积压的数据影响实时性,下面就来详... 目录核心思路代码实现1. 初始化Redis连接和键前缀2. 接收数据时检查暂停状态3. 检测到延时过