【实践篇】Redis最强Java客户端(三)之Redisson 7种分布式锁使用指南

news2025/1/21 12:15:34

文章目录

  • 0. 前言
  • 1. Redisson 7种分布式锁使用指南
    • 1.1 简单锁：
    • 1.2 公平锁：
    • 1.3 可重入锁：
    • 1.4 红锁：
    • 1.5 读写锁：
    • 1.6 信号量：
    • 1.7 闭锁：
  • 2. Spring boot 集成Redisson 验证分布式锁
  • 3. 参考资料
  • 4. 源码地址
  • 5. Redis从入门到精通系列文章

在这里插入图片描述

0. 前言

前两章我们了解了《【实践篇】Redis最强Java客户端(一)之Redisson入门介绍》和《【实践篇】Redis最强Java客户端(二)之Redisson基础概念》本章第三章主要介绍Redisson的七种分布式锁，分别是简单锁、公平锁、可重入锁、红锁、读写锁、信号量和闭锁。下面是每种锁的基本概念、使用方法以及性能和并发控制方面的考虑。
在这里插入图片描述

1. Redisson 7种分布式锁使用指南

1.1 简单锁：

  • 简单锁是最基本的分布式锁，通过调用Redisson的getLock()方法来获取锁，并使用lock()和unlock()方法来加锁和解锁。
  • 简单锁在性能方面表现良好，可以提供良好的并发控制。
RLock lock = redisson.getLock("myLock");
lock.lock();
try {
    // 执行需要加锁的业务逻辑
} finally {
    lock.unlock();
}

1.2 公平锁：

  • 公平锁是按照请求锁的顺序来获取锁的，先到先得。通过调用Redisson的getFairLock()方法来获取公平锁。
  • 性能和公平性控制：公平锁在性能方面相对较低，因为需要维护一个请求锁的队列来保证公平性。
RLock fairLock = redisson.getFairLock("myFairLock");
fairLock.lock();
try {
    // 执行需要加锁的业务逻辑
} finally {
    fairLock.unlock();
}

1.3 可重入锁：

  • 可重入锁是可以被同一个线程多次获取的锁。通过调用Redisson的getReentrantLock()方法来获取可重入锁。
  • 性能和重入控制：可重入锁在性能方面表现良好，并且可以通过计数器来控制锁的重入次数。
RReentrantLock reentrantLock = redisson.getReentrantLock("myReentrantLock");
reentrantLock.lock();
try {
    // 执行需要加锁的业务逻辑
} finally {
    reentrantLock.unlock();
}

1.4 红锁：

  • 红锁是在多个Redis实例上获取锁的一种机制，要求大多数Redis实例成功获取锁才算成功。通过调用Redisson的getRedLock()方法来获取红锁。
  • 性能和分布式锁控制：红锁在性能方面相对较低，因为需要在多个Redis实例之间进行同步。
RLock lock1 = redisson.getLock("lock1");
RLock lock2 = redisson.getLock("lock2");
RLock lock3 = redisson.getLock("lock3");
RedissonRedLock redLock = new RedissonRedLock(lock1, lock2, lock3);
redLock.lock();
try {
    // 执行需要加锁的业务逻辑
} finally {
    redLock.unlock();
}

1.5 读写锁：

  • 读写锁是同时支持读操作和写操作的锁。通过调用Redisson的getReadWriteLock()方法来获取读写锁。
  • 读写锁在读操作方面允许并发访问，但在写操作方面只允许一个线程访问。
RReadWriteLock readWriteLock = redisson.getReadWriteLock("myReadWriteLock");
RLock readLock = readWriteLock.readLock();
RLock writeLock = readWriteLock.writeLock();
readLock.lock();
try {
    // 执行需要读取的业务逻辑
} finally {
    readLock.unlock();
}

writeLock.lock();
try {
    // 执行需要写入的业务逻辑
} finally {
    writeLock.unlock();
}

1.6 信号量：

  • 信号量是一种用于控制并发访问数量的锁。通过调用Redisson的getSemaphore()方法来获取信号量。
  • 信号量可以控制同时访问的线程数量，从而控制并发访问。
RSemaphore semaphore = redisson.getSemaphore("mySemaphore");
semaphore.acquire();
try {
    // 执行需要并发控制的业务逻辑
} finally {
    semaphore.release();
}

1.7 闭锁：

  • 闭锁是一种用于等待其他线程完成任务的同步工具。通过调用Redisson的getCountDownLatch()方法来获取闭锁。
  • 闭锁可以等待其他线程完成任务后再继续执行。
RCountDownLatch latch = redisson.getCountDownLatch("myLatch");
latch.trySetCount(1);

// 等待其他线程完成任务
latch.await();

// 执行需要等待的业务逻辑

以上是Redisson的七种分布式锁的基本概念、使用方法以及性能和并发控制方面的考虑。这些分布式锁可以在分布式环境中提供可靠的并发控制和资源访问解决方案。

2. Spring boot 集成Redisson 验证分布式锁

  1. 添加Redisson依赖
<dependency>
    <groupId>org.redisson</groupId>
    <artifactId>redisson-spring-boot-starter</artifactId>
    <version>3.15.5</version>
</dependency>
  1. 配置Redisson连接
# Redisson连接信息
spring.redis.host=127.0.0.1
spring.redis.port=6379
# 其他Redisson配置（可选）
spring.redisson.config=classpath:redisson.yaml
  1. 创建Redisson配置文件（可选）
singleServerConfig:
  address: "redis://127.0.0.1:6379"
  1. 使用Redisson
package com.example.redissondemo.controller;

import org.redisson.api.RLock;
import org.redisson.api.RReadWriteLock;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class LockController {

    @Autowired
    RedissonClient redissonClient;

    @GetMapping("/lock")
    public void testLock() throws InterruptedException {

        // 1. 可重入锁（Reentrant Lock）
        RLock reentrantLock = redissonClient.getLock("reentrantLock");
        reentrantLock.lock();
        try {
            // critical section / business logic
        } finally {
            reentrantLock.unlock();
        }

        // 2. 公平锁（Fair Lock）
        RLock fairLock = redissonClient.getFairLock("fairLock");
        fairLock.lock();
        try {
            // critical section / business logic
        } finally {
            fairLock.unlock();
        }

        // 3. 读写锁（Read-Write Lock）
        RReadWriteLock rwLock = redissonClient.getReadWriteLock("rwLock");
        
        // 写锁
        rwLock.writeLock().lock();
        try {
            // write data
        } finally {
            rwLock.writeLock().unlock();
        }
        
        // 读锁
        rwLock.readLock().lock();
        try {
            // read data
        } finally {
            rwLock.readLock().unlock();
        }

        // 4. 联锁（MultiLock）
        RLock lock1 = redissonClient.getLock("lock1");
        RLock lock2 = redissonClient.getLock("lock2");
        RLock lock3 = redissonClient.getLock("lock3");
        RLock multiLock = redissonClient.getMultiLock(lock1, lock2, lock3);
        multiLock.lock();
        try {
            // combined business operations on lock1, lock2 and lock3
        } finally {
            multiLock.unlock();
        }

        // 5. 红锁（RedLock）
        RLock redLock = redissonClient.getRedLock(lock1, lock2, lock3);
        redLock.lock();
        try {
            // combined business operations on lock1, lock2 and lock3
        } finally {
            redLock.unlock();
        }

        // 6. 自动过期锁（Auto-expiring Lock）
        RLock autoExpireLock = redissonClient.getLock("autoExpireLock");
        autoExpireLock.lock();
        try {
            // critical section / business logic
        } finally {
            autoExpireLock.forceUnlock();
        }

        // 7. 闭锁（CountDownLatch Lock）
        RCountDownLatch latch = redissonClient.getCountDownLatch("latchLock");
        latch.trySetCount(1);
        latch.await();
        
        // to release the latch
        latch.countDown();
    }
}

如果想自定义配置可以这样写，不依赖于Spring boot 注入bean 手动构造一个client 提交给Spring 容器

@java
public class RedissonConfig {

    @Value("${redisson.address}")
    private String addressUrl;

    @Value("${redisson.password}")
    private String password;

    @Bean
    public RedissonClient getRedisson(){
        Config config = new Config();
        config.useSingleServer().setAddress(addressUrl).setPassword(password);
        return Redisson.create(config);
    }
}

3. 参考资料

  1. Redisson官方网站：https://redisson.org/

  2. Redisson GitHub仓库：https://github.com/redisson/redisson

  3. redisson 参考文档 https://redisson.org/documentation.html

4. 源码地址

https://github.com/wangshuai67/icepip-springboot-action-examples
https://github.com/wangshuai67/Redis-Tutorial-2023

5. Redis从入门到精通系列文章

  • 《【Redis实践篇】使用Redisson 优雅实现项目实践过程中的5种场景》
  • 《Redis使用Lua脚本和Redisson来保证库存扣减中的原子性和一致性》
  • 《SpringBoot Redis 使用Lettuce和Jedis配置哨兵模式》
  • 《Redis【应用篇】之RedisTemplate基本操作》
  • 《Redis 从入门到精通【实践篇】之SpringBoot配置Redis多数据源》
  • 《Redis 从入门到精通【进阶篇】之三分钟了解Redis HyperLogLog 数据结构》
  • 《Redis 从入门到精通【进阶篇】之三分钟了解Redis地理位置数据结构GeoHash》
  • 《Redis 从入门到精通【进阶篇】之高可用哨兵机制(Redis Sentinel)详解》
  • 《Redis 从入门到精通【进阶篇】之redis主从复制详解》
  • 《Redis 从入门到精通【进阶篇】之Redis事务详解》
  • 《Redis从入门到精通【进阶篇】之对象机制详解》
  • 《Redis从入门到精通【进阶篇】之消息传递发布订阅模式详解》
  • 《Redis从入门到精通【进阶篇】之持久化 AOF详解》
  • 《Redis从入门到精通【进阶篇】之持久化RDB详解》
  • 《Redis从入门到精通【高阶篇】之底层数据结构字典(Dictionary)详解》
  • 《Redis从入门到精通【高阶篇】之底层数据结构快表QuickList详解》
  • 《Redis从入门到精通【高阶篇】之底层数据结构简单动态字符串(SDS)详解》
  • 《Redis从入门到精通【高阶篇】之底层数据结构压缩列表(ZipList)详解》
  • 《Redis从入门到精通【进阶篇】之数据类型Stream详解和使用示例》
    在这里插入图片描述大家好，我是冰点，今天的【实践篇】Redis最强Java客户端(三)之Redisson 7种分布式锁使用指南，全部内容就是这些。如果你有疑问或见解可以在评论区留言。

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

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

相关文章

测开之路：大厂测试开发工作四年的感悟

测开之路：大厂测试开发工作四年的感悟

经历 在两个大厂分别做了两年的测试开发工作&#xff0c;暂且成为 N 厂和 A 厂吧。负责过游戏自动化框架开发、专项测试工具开发、版本质量保障、Devops 平台开发&#xff0c;也带过小团队。每个厂&#xff0c;每份工作都力求突破&#xff0c;过程辛苦&#xff0c;自然结果都是…
阅读更多...
MYSQL的索引使用注意

MYSQL的索引使用注意

索引并不是时时都会生效的&#xff0c;比如以下几种情况&#xff0c;将导致索引失效 最左前缀法则 如果使用了联合索引&#xff0c;要遵守最左前缀法则。最左前缀法则指的是查询从索引的最左列开始&#xff0c; 并且不跳过索引中的列。如果跳跃某一列&#xff0c;索引将会部分…
阅读更多...
【PTA】浙江大学计算机与软件学院2019年考研复试上机自测

【PTA】浙江大学计算机与软件学院2019年考研复试上机自测

个人学习记录&#xff0c;代码难免不尽人意。 呃&#xff0c;今天做了做19年的复试上机题&#xff0c;死在hash表上了&#xff0c;后面详细解释。心态要好&#xff0c;心态要好 7-1 Conway’s Conjecture John Horton Conway, a British mathematician active in recreational…
阅读更多...
用友U8与MES系统API接口对接案例分析

用友U8与MES系统API接口对接案例分析

企业数字化转型&#xff1a;轻易云数据集成平台助力 U8 ERPMES 系统集成 为什么选择数字化转型&#xff1f; 领导层对企业资源规划&#xff08;ERP&#xff09;的深刻理解促使了数字化转型的启动。采用精确的“N5”滚动计划&#xff0c;为供应商提供充分的预期信息&#xff0c…
阅读更多...
MyBatis中的几种查询结果集返回类型映射

MyBatis中的几种查询结果集返回类型映射

MyBatis中的几种查询结果集返回类型映射 一、MyBatis查询结果类型 MyBatis查询是比较常用的功能操作&#xff0c;对于查询语句来说&#xff0c;它是需要返回查询结果的&#xff0c;不同查询可以返回不同类型的查询结果&#xff0c;例如&#xff1a;查询记录总数&#xff0c;那…
阅读更多...
SSM - Springboot - MyBatis-Plus 全栈体系（四）

SSM - Springboot - MyBatis-Plus 全栈体系（四）

第二章 SpringFramework 四、SpringIoC 实践和应用 1. SpringIoC / DI 实现步骤 1.1 配置元数据&#xff08;配置&#xff09; 配置元数据&#xff0c;既是编写交给SpringIoC容器管理组件的信息&#xff0c;配置方式有三种。基于 XML 的配置元数据的基本结构&#xff1a; …
阅读更多...
LabVIEW通过IEC61508标准验证ITER联锁系统

LabVIEW通过IEC61508标准验证ITER联锁系统

LabVIEW通过IEC61508标准验证ITER联锁系统 保护环境要求系统能够保护机器免受工厂系统故障或机器危险操作造成的严重损坏。负责此功能的ITER系统是联锁控制系统&#xff08;ICS&#xff09;。该系统通过中央联锁系统&#xff08;CIS&#xff09;监督和控制不同的工厂联锁系统&…
阅读更多...
javaee springMVC 一个案例

javaee springMVC 一个案例

项目结构 pom.xml <?xml version"1.0" encoding"UTF-8"?><project xmlns"http://maven.apache.org/POM/4.0.0" xmlns:xsi"http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation"http://maven.apache.org/P…
阅读更多...
分布式锁使用

分布式锁使用

1、在微服务项目中&#xff0c;上面的锁方法只能锁住一个单体的&#xff0c;分布式需要使用分布式锁 redis中的setnx 问题&#xff1a; 但是&#xff0c;如果进入判断后&#xff0c;还没执行到过期时间语句就断电&#xff0c;那也会死锁&#xff0c;所以应该使用 但是如果执行…
阅读更多...
Linux命令200例：mkfs用于创建文件系统

Linux命令200例：mkfs用于创建文件系统

&#x1f3c6;作者简介&#xff0c;黑夜开发者&#xff0c;CSDN领军人物&#xff0c;全栈领域优质创作者✌。CSDN专家博主&#xff0c;阿里云社区专家博主&#xff0c;2023年6月csdn上海赛道top4。 &#x1f3c6;数年电商行业从业经验&#xff0c;历任核心研发工程师&#xff0…
阅读更多...
(文章复现)基于主从博弈的新型城镇配电系统产消者竞价策略

(文章复现)基于主从博弈的新型城镇配电系统产消者竞价策略

参考文献&#xff1a; [1]陈修鹏,李庚银,夏勇.基于主从博弈的新型城镇配电系统产消者竞价策略[J].电力系统自动化,2019,43(14):97-104. 1.基本原理 在竞争性电力市场下&#xff0c;新型城镇配电系统内主要有以下几类主体&#xff1a;电力交易中心和调度部门、产消者、电网公共…
阅读更多...
WebSocket的那些事（5-Spring STOMP支持之连接外部消息代理）

WebSocket的那些事（5-Spring STOMP支持之连接外部消息代理）

目录 一、序言二、开启RabbitMQ外部消息代理三、代码示例1、Maven依赖项2、相关实体3、自定义用户认证拦截器4、Websocket外部消息代理配置5、ChatController6、前端页面chat.html 四、测试示例1、群聊、私聊、后台定时推送测试2、登录RabbitMQ控制台查看队列信息 五、结语 一、…
阅读更多...
合宙Air724UG LuatOS-Air LVGL API控件-截屏（Screenshots）

合宙Air724UG LuatOS-Air LVGL API控件-截屏（Screenshots）

截屏&#xff08;Screenshots&#xff09; 分 享导出pdf 截屏功能&#xff0c;core版本号要>3211 示例代码 -- 创建图片控件img lvgl.img_create(lvgl.scr_act(), nil)-- 设置图片显示的图像lvgl.img_set_src(img, "/lua/test.png")-- 图片居中lvgl.obj_align(…
阅读更多...
Pygame中Sprite类的使用1

Pygame中Sprite类的使用1

在Pygame中有一个名为sprite的模块&#xff0c;又叫做“精灵”模块。通过该模块中的Sprite类可以实现图形的绘制、移动以及碰撞检测等功能。 1 Sprite类的编写 例如&#xff0c;要绘制“植物大战僵尸”中的僵尸&#xff0c;就可以创建一个新类&#xff0c;让该类继承自sprite…
阅读更多...
零基础Linux_2(基本指令_上)目录/文件的显示跳转创建删除

零基础Linux_2(基本指令_上)目录/文件的显示跳转创建删除

目录 1. 目录内容的显示 ls(显示非隐藏文件) pwd(显示用户当前所在的目录) ls -l(列出文件的详细信息) ls -a(显示隐藏文件) 2. 目录的跳转操作 cd ..(回到上级路径) cd 绝对路径名(进入这个路径) cd 绝对相对名(进入这个路径) cd ~(跳转到当前用户的家目录) cd -(跳…
阅读更多...
SQL语法知识回顾

SQL语法知识回顾

一、SQL语言的分类 由于数据库管理系统&#xff08;数据库软件&#xff09;功能非常多&#xff0c;不仅仅是存储数据&#xff0c;还要包含&#xff1a;数据的管理、表的管理、库的管理、账户管理、权限管理等等。所以&#xff0c;操作数据库的SQL语言&#xff0c;也基于功能&am…
阅读更多...
Microsoft Edge网页视频播放绿屏解决方法（B站）

Microsoft Edge网页视频播放绿屏解决方法（B站）

一&#xff1a;问题&#xff0c;在B站观看视频时有绿色条纹 二&#xff1a;查找原因&#xff0c;未知 三&#xff1a;解决方法 三.1网页设置关闭硬件加速 三.2 点击视频播放下的 “小齿轮”&#xff0c;然后点击“更多播放设置” 把播放策略 “默认” 改为“AVC” 四&…
阅读更多...
[SUCTF2019]SignIn 题解

[SUCTF2019]SignIn 题解

是一个64位的文件 使用了RSA加密算法 N是103461035900816914121390101299049044413950405173712170434161686539878160984549 使用在线网站分离得到p&#xff0c;q 然后编写脚本进行解密 import gmpy2 import binasciip 282164587459512124844245113950593348271 q 366669…
阅读更多...
回归预测 | MATLAB实现MPA-BiGRU海洋捕食者算法优化双向门控循环单元多输入单输出回归预测（多指标，多图）

回归预测 | MATLAB实现MPA-BiGRU海洋捕食者算法优化双向门控循环单元多输入单输出回归预测（多指标，多图）

回归预测 | MATLAB实现MPA-BiGRU海洋捕食者算法优化双向门控循环单元多输入单输出回归预测&#xff08;多指标&#xff0c;多图&#xff09; 目录 回归预测 | MATLAB实现MPA-BiGRU海洋捕食者算法优化双向门控循环单元多输入单输出回归预测&#xff08;多指标&#xff0c;多图&a…
阅读更多...
03-系统篇-内存碎片

03-系统篇-内存碎片

一.常见的malloc内存分配原理 1内存分配原理 linux中应用层动态分配内存一般是用的malloc函数&#xff0c;而malloc在glibc中实现时&#xff0c;是用sbrk()来分内存. 在前面的章节中&#xff0c;我们了解到了堆的概念&#xff0c;堆在内存中&#xff0c;是一断连续的内存&…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023