Redis进阶Redission实现分布式锁

news/2024/11/24 10:36:49/

Redis进阶Redission实现分布式

  • 基于Redis实现的各种问题
  • 怎么解决这些问题
  • redisson实现
    • 1、导入依赖
    • 2.注册成Bean
    • 3、代码实现


基于Redis实现的各种问题

基于Redis实现的分布式锁还具有其他问题

不可重入:按照以上的逻辑,我们一个线程只能获取一次锁,我们怎样才能让其可以多次尝试获取锁呢?

解决方案:我们可以将锁保存在Redis的Hash类型中,key用来存储唯一标识,value用来存储count,用来标识获取到锁的次数,每次想要获取到锁首先检验锁是否存在,如果存在检验key是否相等,如果相等说明是获取到锁的线程本身想要再次获取锁,就让count++,当释放锁的时候,让count–,当count为0时删除redis的锁

不能多次尝试获取锁:如果按照上面封装的Redis锁,我们只能尝试获取一次锁就返回结果
解决方案:我们可以给线程设置一个尝试获取锁的时间,让其可以在这个时间内多次获取锁吗

超时释放:当我们因为给锁添加了一个超时释放时间时,常常可能因为业务阻塞原因导致锁被超时释放,这是锁被其他线程获取,多个线程同时执行业务就可能会引发线程安全问题
解决方案:我们可以给锁的删除时间不断续约,让线程一直持有锁不会过期释放直到线程执行业务结束

主从一致性:当我们使用Redis集群时,有主节点和从节点,当主节点收到锁的写入时,会将写入命令发送给其他从节点来同步数据,如果此时主节点发生故障,redis的哨兵会推举新的主节点,但是由于从节点的数据还没有同步,其他线程请求没有进行数据同步的主节点,就会导致多个线程同时获得锁,造成线程安全问题
解决方案:我们可以设置多个主节点,当进行锁插入时,会向每一个主节点发送请求,如果有一个主节点发生故障,导致数据丢失,返回结果和其他主节点不一致,那么结果就是失败的,当所有主节点都返回成功时,结果才是成功的

怎么解决这些问题

redisson工具类可以完美解决这些问题

redisson_30">redisson实现

1、导入依赖

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

2.注册成Bean

@Configuration
public class RedisConfig {@Beanpublic RedissonClient getRedissonClient(){Config config=new Config();config.useSingleServer().setAddress("redis://localhost:6379").setPassword("");return Redisson.create(config);}
}

3、代码实现

redisson获取锁的方法:

   public boolean tryLock(long waitTime, long leaseTime, TimeUnit unit)//当调用此方法时不传入锁的过期删除时间,会解决锁的过期删除问题public boolean tryLock(long waitTime, TimeUnit unit)

waitTime:线程尝试获取锁的最大时间
leaseTime:设置锁的超时释放时间
TimeUnit:时间单位

解决不可多次尝试获取锁和超时删除实现:

        RLock lock = redissonClient.getLock(keyName);//线程可以在一秒内多次尝试获取锁,如果一秒内还未获取锁返回获取锁失败boolean isLock = lock.tryLock(1L, TimeUnit.SECONDS);

解决主从一致性实现(创建多个主节点):

        RLock lock = redissonClient.getLock(keyName);RLock lock1 = redissonClient.getLock(keyName));RLock lock2 = redissonClient.getLock(keyName));RLock mLock = redissonClient.getMultiLock(lock1, lock2, lock);boolean isLock = lock.tryLock(1L, TimeUnit.SECONDS);

http://www.ppmy.cn/news/1549516.html

相关文章

第二十九章 TCP 客户端 服务器通信 - 记录的拼接

文章目录 第二十九章 TCP 客户端 服务器通信 - 记录的拼接记录的拼接多路复用 TCP设备正在关闭连接使用CLOSE命令断开连接 第二十九章 TCP 客户端 服务器通信 - 记录的拼接 记录的拼接 在某些情况下&#xff0c;TCP会将不同的记录连接在一起形成单个记录。如果客户端或服务器…

Fakelocation Server服务器/专业版 Windows11

前言:需要Windows11系统 Fakelocation开源文件系统需求 Windows11 | Fakelocation | 任务一 打开 PowerShell&#xff08;以管理员身份&#xff09;命令安装 Chocolatey Set-ExecutionPolicy Bypass -Scope Process -Force; [System.Net.ServicePointManager]::SecurityProto…

【spark】远程debug spark任务(含有pyspark)

--master yarn和--master client都是可以的。 spark-submit \ --master yarn \ --deploy-mode client \ --name "test-remote-debug" \ --conf "spark.driver.extraJavaOptions-agentlib:jdwptransportdt_socket,servery,suspendn,address5005" \ --conf …

TabTransformer 模型示例

代码功能 定义模型&#xff1a; TabTransformer 类继承自 nn.Module&#xff0c;包含嵌入层、Transformer 编码器和全连接层。 前向传播方法 forward 中&#xff0c;输入数据经过嵌入层、Transformer 编码器和全连接层&#xff0c;最终输出分类结果。 定义数据集类&#xff…

【MySQL课程学习】:MySQL安装,MySQL如何登录和退出?MySQL的简单配置

&#x1f381;个人主页&#xff1a;我们的五年 &#x1f50d;系列专栏&#xff1a;MySQL课程学习 &#x1f337;追光的人&#xff0c;终会万丈光芒 &#x1f389;欢迎大家点赞&#x1f44d;评论&#x1f4dd;收藏⭐文章 目录 MySQL在Centos 7环境下的安装&#xff1a; 卸载…

CSS3_BFC(十二)

BFC MDN对BFC的解释&#xff1a;块格式化上下文&#xff08;Block Formating Context, BFC&#xff09;是web页面的可视CSS渲染的一部分&#xff0c;是块盒子的布局过程发生的区域&#xff0c;也是浮动元素与其他元素交互的区域。 1、开启BFC flow-root对内容的影响是最低的&am…

【应用介绍】FastCAE-PHengLEI流体仿真

1 风雷组件集成背景 1.1 风雷软件简介 风雷软件是中国空气动力研究与发展中心&#xff08;CARDC&#xff09;研发的面向流体工程的混合CFD平台。平台的建立遵循面向对象的设计理念&#xff0c;采用C语言编程。自2010年开始&#xff0c;气动中心开始着力于工程化品牌CFD软件的…

力扣第 61 题旋转链表

题目描述 给定一个链表&#xff0c;旋转链表&#xff0c;将链表中的每个节点向右移动 k k k 个位置&#xff0c;其中 k k k 是非负数。 示例 1: 输入: head [1,2,3,4,5], k 2 输出: [4,5,1,2,3] 解释: 向右旋转 1 步: [5,1,2,3,4] 向右旋转 2 步: [4,5,1,2,3]示例 2: 输…