浅谈Redisson实现分布式锁对原理
1.Redisson简介
Redis 是最流行的 NoSQL 数据库解决方案之一,而 Java 是世界上最流行(注意,我没有说“最好”)的编程语言之一。虽然两者看起来很自然地在一起“工作”,但是要知道,Redis 其实并没有对 Java 提供原生支持。
相反,作为 Java 开发人员,我们若想在程序中集成 Redis,必须使用 Redis 的第三方库。而 Redisson 就是用于在 Java 程序中操作 Redis 的库,它使得我们可以在程序中轻松地使用 Redis。Redisson 在 java.util 中常用接口的基础上,为我们提供了一系列具有分布式特性的工具类。
Redisson底层采用的是Netty 框架。支持Redis 2.8以上版本,支持Java1.6+以上版本。
2.Redisson实现分布式锁的步骤
2.1.引入依赖
引入重要的两个依赖,一个是spring-boot-starter-data-redis,一个是redisson:
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId>
</dependency><dependency><groupId>org.redisson</groupId><artifactId>redisson</artifactId><version>3.7.5</version>
</dependency>
2.2.application.properties
# Redis服务器地址(默认session使用)
spring.redis.host=127.0.0.1
# Redis服务器连接密码(默认为空)
# spring.redis.password=
# Redis服务器连接端口
spring.redis.port=6379
2.3.定义Loker
接口编程的思想还是要保持的。我们定义一个Loker接口,用于分布式锁的一些操作:
package com.bruceliu.lock;/*** @BelongsProject: RedissonLock* @BelongsPackage: com.bruceliu.lock* @Author: bruceliu* @QQ:1241488705* @CreateTime: 2020-05-08 10:20* @Description: 锁接口*/
import java.util.concurrent.TimeUnit;public interface Locker {/*** 获取锁,如果锁不可用,则当前线程处于休眠状态,直到获得锁为止。** @param lockKey*/void lock(String lockKey);/*** 释放锁** @param lockKey*/void unlock(String lockKey);/*** 获取锁,如果锁不可用,则当前线程处于休眠状态,直到获得锁为止。如果获取到锁后,执行结束后解锁或达到超时时间后会自动释放锁** @param lockKey* @param timeout*/void lock(String lockKey, int timeout);/*** 获取锁,如果锁不可用,则当前线程处于休眠状态,直到获得锁为止。如果获取到锁后,执行结束后解锁或达到超时时间后会自动释放锁** @param lockKey* @param unit* @param timeout*/void lock(String lockKey, TimeUnit unit, int timeout);/*** 尝试获取锁,获取到立即返回true,未获取到立即返回false** @param lockKey* @return*/boolean tryLock(String lockKey);/*** 尝试获取锁,在等待时间内获取到锁则返回true,否则返回false,如果获取到锁,则要么执行完后程序释放锁,* 要么在给定的超时时间leaseTime后释放锁** @param lockKey* @param waitTime* @param leaseTime* @param unit* @return*/boolean tryLock(String lockKey, long waitTime, long leaseTime, TimeUnit unit)throws InterruptedException;/*** 锁是否被任意一个线程锁持有** @param lockKey* @return*/boolean isLocked(String lockKey);
}
有了Locker接口,我们再添加一个基于Redisson的实现类RedissonLocker,实现Locker中的方法:
package com.bruceliu.lock;/*** @BelongsProject: RedissonLock* @BelongsPackage: com.bruceliu.lock* @Author: bruceliu* @QQ:1241488705* @CreateTime: 2020-05-08 10:20* @Description: 基于Redisson的分布式锁*/
import java.util.concurrent.TimeUnit;import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;public class RedissonLocker implements Locker {private RedissonClient redissonClient;public RedissonLocker(RedissonClient redissonClient) {super();this.redissonClient = redissonClient;}@Overridepublic void lock(String lockKey) {RLock lock = redissonClient.getLock(lockKey);lock.lock();}@Overridepublic void unlock(String lockKey) {RLock lock = redissonClient.getLock(lockKey);lock.unlock();}@Overridepublic void lock(String lockKey, int leaseTime) {RLock lock = redissonClient.getLock(lockKey);lock.lock(leaseTime, TimeUnit.SECONDS);}@Overridepublic void lock(String lockKey, TimeUnit unit, int timeout) {RLock lock = redissonClient.getLock(lockKey);lock.lock(timeout, unit);}public void setRedissonClient(RedissonClient redissonClient) {this.redissonClient = redissonClient;}@Overridepublic boolean tryLock(String lockKey) {RLock lock = redissonClient.getLock(lockKey);return lock.tryLock();}@Overridepublic boolean tryLock(String lockKey, long waitTime, long leaseTime,TimeUnit unit) throws InterruptedException{RLock lock = redissonClient.getLock(lockKey);return lock.tryLock(waitTime, leaseTime, unit);}@Overridepublic boolean isLocked(String lockKey) {RLock lock = redissonClient.getLock(lockKey);return lock.isLocked();}}
2.4.定义工具类
有了Locker和实现类RedissonLocker,我们总不能一直去创建RedissonLocker对象或者不断的在每个要使用到分布式锁的地方都注入RedissonLocker的对象,所以我们定义一个工具类LockUtil,到时候想哪里使用就直接使用工具类的静态方法就行了:
package com.bruceliu.utils;/*** @BelongsProject: RedissonLock* @BelongsPackage: com.bruceliu.utils* @Author: bruceliu* @QQ:1241488705* @CreateTime: 2020-05-08 10:21* @Description: TODO*/
import com.bruceliu.lock.Locker;import java.util.concurrent.TimeUnit;/*** redis分布式锁工具类**/
public final class LockUtil {private static Locker locker;/*** 设置工具类使用的locker* @param locker*/public static void setLocker(Locker locker) {LockUtil.locker = locker;}/*** 获取锁* @param lockKey*/public static void lock(String lockKey) {locker.lock(lockKey);}/*** 释放锁* @param lockKey*/public static void unlock(String lockKey) {locker.unlock(lockKey);}/*** 获取锁,超时释放* @param lockKey* @param timeout*/public static void lock(String lockKey, int timeout) {locker.lock(lockKey, timeout);}/*** 获取锁,超时释放,指定时间单位* @param lockKey* @param unit* @param timeout*/public static void lock(String lockKey, TimeUnit unit, int timeout) {locker.lock(lockKey, unit, timeout);}/*** 尝试获取锁,获取到立即返回true,获取失败立即返回false* @param lockKey* @return*/public static boolean tryLock(String lockKey) {return locker.tryLock(lockKey);}/*** 尝试获取锁,在给定的waitTime时间内尝试,获取到返回true,获取失败返回false,获取到后再给定的leaseTime时间超时释放* @param lockKey* @param waitTime* @param leaseTime* @param unit* @return* @throws InterruptedException*/public static boolean tryLock(String lockKey, long waitTime, long leaseTime,TimeUnit unit) throws InterruptedException {return locker.tryLock(lockKey, waitTime, leaseTime, unit);}/*** 锁释放被任意一个线程持有* @param lockKey* @return*/public static boolean isLocked(String lockKey) {return locker.isLocked(lockKey);}
}
2.5.Redisson的配置类
现在我们开始配置吧,创建一个redisson的配置类RedissonConfig,内容如下:
package com.bruceliu.config;import java.io.IOException;import com.bruceliu.lock.RedissonLocker;
import com.bruceliu.utils.LockUtil;
import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;/*** @BelongsProject: RedissonLock* @BelongsPackage: com.bruceliu.config* @Author: bruceliu* @QQ:1241488705* @CreateTime: 2020-05-08 10:22* @Description: TODO*/
@Configuration
public class RedissonConfig {@Value("${spring.redis.host}")private String host;@Value("${spring.redis.port}")private String port;//@Value("${spring.redis.password}")//private String password;/*** RedissonClient,单机模式* @return* @throws IOException*/@Bean(destroyMethod = "shutdown")public RedissonClient redisson() throws IOException {Config config = new Config();//config.useSingleServer().setAddress("redis://" + host + ":" + port).setPassword(password);config.useSingleServer().setAddress("redis://" + host + ":" + port);return Redisson.create(config);}@Beanpublic RedissonLocker redissonLocker(RedissonClient redissonClient){RedissonLocker locker = new RedissonLocker(redissonClient);//设置LockUtil的锁处理对象LockUtil.setLocker(locker);return locker;}
}
2.6.Redisson分布式锁业务类
package com.bruceliu.service;import com.bruceliu.utils.LockUtil;import java.util.concurrent.TimeUnit;/*** @BelongsProject: RedissonLock* @BelongsPackage: com.bruceliu.service* @Author: bruceliu* @QQ:1241488705* @CreateTime: 2020-05-08 10:26* @Description: TODO*/
public class SkillService {int n = 500;public void seckill() {//加锁LockUtil.lock("resource", TimeUnit.SECONDS,5000);try {System.out.println(Thread.currentThread().getName() + "获得了锁");Thread.sleep(3000);System.out.println(--n);} catch (Exception e) {//异常处理}finally{//释放锁LockUtil.unlock("resource");System.out.println(Thread.currentThread().getName() + "释放了锁");}}
}
2.7.Redisson分布式锁测试
package com.bruceliu.test;import com.bruceliu.App;
import com.bruceliu.service.SkillService;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;/*** @BelongsProject: RedissonLock* @BelongsPackage: com.bruceliu.test* @Author: bruceliu* @QQ:1241488705* @CreateTime: 2020-05-08 10:29* @Description: TODO*/
@RunWith(SpringRunner.class)
@SpringBootTest(classes = App.class)
public class TestLock {@Testpublic void testLock() throws Exception{SkillService service = new SkillService();for (int i = 0; i < 10; i++) {ThreadA threadA = new ThreadA(service);threadA.setName("ThreadNameA->"+i);threadA.start();}Thread.sleep(50000);}}class ThreadA extends Thread {private SkillService skillService;public ThreadA(SkillService skillService) {this.skillService = skillService;}@Overridepublic void run() {skillService.seckill();}
}
运行结果:
注释文中加锁代码:
public void seckill() {//加锁//LockUtil.lock("resource", TimeUnit.SECONDS,5000);try {System.out.println(Thread.currentThread().getName() + "获得了锁");Thread.sleep(3000);System.out.println(--n);} catch (Exception e) {//异常处理}finally{//释放锁//LockUtil.unlock("resource");System.out.println(Thread.currentThread().getName() + "释放了锁");}
}
运行结果:

可以看到存在并发的问题!
相关文章:
浅谈Redisson实现分布式锁对原理
1.Redisson简介 Redis 是最流行的 NoSQL 数据库解决方案之一,而 Java 是世界上最流行(注意,我没有说“最好”)的编程语言之一。虽然两者看起来很自然地在一起“工作”,但是要知道,Redis 其实并没有对 Java…...
struts1.2升级struts2.5.30问题汇总
严重: 配置应用程序监听器[org.apache.struts2.tiles.StrutsTilesListener]错误java.lang.NoClassDefFoundError: org/apache/tiles/web/startup/AbstractTilesListenerat java.lang.ClassLoader.defineClass1(Native Method)at java.lang.ClassLoader.defineClass(ClassLoader…...
电动汽车充放电的优化调度(Matlab代码实现)
💥💥💞💞欢迎来到本博客❤️❤️💥💥 🏆博主优势:🌞🌞🌞博客内容尽量做到思维缜密,逻辑清晰,为了方便读者。 ⛳️座右铭&a…...
《JeecgBoot系列》 如何设计表单实现“下拉组件二级联动“ ? 以省市二级联动为例
《JeecgBoot系列》 如何设计表单实现"下拉组件二级联动" ? 以省市二级联动为例 一、准备字典表 1.1 创建字典表 CREATE TABLE sys_link_table ( id int NULL, pid int NULL, name varchar(64) null );1.2 准备数据 idpidname1全国21浙江省32杭州市42宁波市51江苏…...
数学小课堂:数学的线索(从猜想到定理再到应用的整个过程)
文章目录 引言I 勾股定理1.1 勾三股四弦五1.2 数学和自然科学的三个本质差别1.3 总结引言 从猜想到定理再到应用的整个过程是数学发展和体系构建常常经历的步骤。 I 勾股定理 勾股定理: 直角三角形两条直角边的平方之和等于斜边的平方,这个定理在国外都被称为毕达哥拉斯定理…...
Collecting package metadata (current_repodata.json): failed
一、问题描述 安装anaconda之后,想创建环境,用了下面这段代码: conda create -n pytorch python3.7 conda创建环境报错了,报了如下这一堆: Collecting package metadata (current_repodata.json): failedUnavailab…...
几十亿工单表,查询优化案例
前言: 之前在某大型保险公司担任技术经理,负责优化话务系统模块,由于系统已经运行10年之久,尤其在话务系统中,沉积了几十亿的话务信息表,业务人员反馈,话务系统历史数据查询部分已经完全查询不动࿰…...
LabVIEW应用程序(EXE)无法正确动态调用插件
LabVIEW应用程序(EXE)无法正确动态调用插件正在构建一个应用程序并使用插件架构,以便可以动态调用将来创建的VI(插件)。应用程序在LabVIEW开发环境中可以正常运行,但不能作为可执行程序运行。运行可执行文件…...
到了35岁,软件测试职业发展之困惑如何解?
35岁,从工作时间看,工作超过10年,过了7年之痒,多数IT人都已经跳槽几次。 35岁,发展比较好的软件测试人,已经在管理岗位(测试经理甚至测试总监)或已经成为测试专家或测试架构师。发展…...
Google Guice 3:Bindings(1)
1. 序言 上一篇博客,《Google Guice 2:Mental Model》,讲述了Guice的建模思路:Guice is a map Guice官网认为:binding是一个对象,它对应Guice map中的一个entry,通过创建binding就可以向Guice …...
学习国家颁布的三部信息安全领域法律,理解当前工作中的信息安全合规要求
目录三部信息安全领域的法律文件三部法律的角色定位与联系三部法律的适用范围三部法律的主要履职部门三部法律条文章节结构中的共性三部法律中的一些次重点章节网络安全法的重点章节数据安全法的重点章节个人信息保护法的重点章节关于工业和信息化部行政执法项目清单三部信息安…...
LeetCode_Python_二分查找算法
二分查找算法要求二分查找过程如何更新左右边界实例type1:常规记录中间元素type2:取跳出循环后的左或右边界算法要求 顺序存储结构元素大小有序 二分查找过程 将元素排序;将中间位置记录的这个元素与目标元素比较; 2.1 如果相同&a…...
功能测试三年,是时候做出改变了
前言 测试行业3年多经验,学历大专自考本科,主要测试方向web,PC端,wap站,小程序公众号都测试过,app也测过一些,C端B端都有,除功能外,接口性能也有涉猎,但是不…...
图扑孪生工厂流水线组态图可视化
前言 2018 年,世界经济论坛(WEF)携手麦肯锡公司共同倡议并正式启动了全球“灯塔工厂网络项目”(Lighthouse Network),共同遴选率先应用工业革命 4.0 技术实现企业盈利和持续发展的创新者与示范者。这就使得工厂系统需要对各流水线及生产运行成本方面进行…...
车机开发—【CarService启动流程】
汽车架构:车载HAL是汽车与车辆网络服务之间的接口定义(同时保护传入的数据): 车载HAL与Android Automotive架构: Car App:包括OEM和第三方开发的AppCar API:内有包含CarSensorManager在内的AP…...
webpack中require.context的运用
1. 作用: 利用require创建context (上下文),来告知在编译时具体需要导入哪些模块(即:批量处理待导入模块进行导入); webpack会在构建的时候解析代码中的require.context() (实际上是webpack的方法,vue一般基于webpack…...
2023“Java基础-中级-高级”面试集结,已奉上我的膝盖
Java基础(对象线程字符接口变量异常方法) 面向对象和面向过程的区别? Java 语言有哪些特点? 关于 JVM JDK 和 JRE 最详细通俗的解答 Oracle JDK 和 OpenJDK 的对比 Java 和 C的区别? 什么是 Java 程序的主类&…...
RabbitMQ之发布确认
发布确认 1 发布确认原理 生产者将信道设置成 confirm 模式,一旦信道进入 confirm 模式,所有在该信道上面发布的消息都将会被指派一个唯一的 ID(从 1 开始),一旦消息被投递到所有匹配的队列之后,broker就会发送一个确认给生产者(包含消息的唯一 ID),这就使得生产者知道消…...
一文读懂函数编程及其工作原理
微软MVP实验室研究员 马洪喜-微软 MVP 19年研发经验 云计算咨询顾问专家 容器云及基础架构云技术专家 DevOps 及微服务咨询专家 什么是函数编程 我先用通俗的大白话给大家解释一下函数(Functions, Function as a Service, FaaS)的几个要点,这样看后面示例时才不…...
WSO2 apim Subscribe to an API
WSO2 apim Application Subscribe to an API1. Published an Api2. Subscribe to an API using Key Generation Wizard3. Subscribe to an existing application4. AwakeningWSO2安装使用的全过程详解: https://blog.csdn.net/weixin_43916074/article/details/127987099. Offi…...
QMC5883L的驱动
简介 本篇文章的代码已经上传到了github上面,开源代码 作为一个电子罗盘模块,我们可以通过I2C从中获取偏航角yaw,相对于六轴陀螺仪的yaw,qmc5883l几乎不会零飘并且成本较低。 参考资料 QMC5883L磁场传感器驱动 QMC5883L磁力计…...
论文浅尝 | 基于判别指令微调生成式大语言模型的知识图谱补全方法(ISWC2024)
笔记整理:刘治强,浙江大学硕士生,研究方向为知识图谱表示学习,大语言模型 论文链接:http://arxiv.org/abs/2407.16127 发表会议:ISWC 2024 1. 动机 传统的知识图谱补全(KGC)模型通过…...
WEB3全栈开发——面试专业技能点P2智能合约开发(Solidity)
一、Solidity合约开发 下面是 Solidity 合约开发 的概念、代码示例及讲解,适合用作学习或写简历项目背景说明。 🧠 一、概念简介:Solidity 合约开发 Solidity 是一种专门为 以太坊(Ethereum)平台编写智能合约的高级编…...
关于 WASM:1. WASM 基础原理
一、WASM 简介 1.1 WebAssembly 是什么? WebAssembly(WASM) 是一种能在现代浏览器中高效运行的二进制指令格式,它不是传统的编程语言,而是一种 低级字节码格式,可由高级语言(如 C、C、Rust&am…...
【JavaWeb】Docker项目部署
引言 之前学习了Linux操作系统的常见命令,在Linux上安装软件,以及如何在Linux上部署一个单体项目,大多数同学都会有相同的感受,那就是麻烦。 核心体现在三点: 命令太多了,记不住 软件安装包名字复杂&…...
C++ Visual Studio 2017厂商给的源码没有.sln文件 易兆微芯片下载工具加开机动画下载。
1.先用Visual Studio 2017打开Yichip YC31xx loader.vcxproj,再用Visual Studio 2022打开。再保侟就有.sln文件了。 易兆微芯片下载工具加开机动画下载 ExtraDownloadFile1Info.\logo.bin|0|0|10D2000|0 MFC应用兼容CMD 在BOOL CYichipYC31xxloaderDlg::OnIni…...
代理篇12|深入理解 Vite中的Proxy接口代理配置
在前端开发中,常常会遇到 跨域请求接口 的情况。为了解决这个问题,Vite 和 Webpack 都提供了 proxy 代理功能,用于将本地开发请求转发到后端服务器。 什么是代理(proxy)? 代理是在开发过程中,前端项目通过开发服务器,将指定的请求“转发”到真实的后端服务器,从而绕…...
AI,如何重构理解、匹配与决策?
AI 时代,我们如何理解消费? 作者|王彬 封面|Unplash 人们通过信息理解世界。 曾几何时,PC 与移动互联网重塑了人们的购物路径:信息变得唾手可得,商品决策变得高度依赖内容。 但 AI 时代的来…...
JS设计模式(4):观察者模式
JS设计模式(4):观察者模式 一、引入 在开发中,我们经常会遇到这样的场景:一个对象的状态变化需要自动通知其他对象,比如: 电商平台中,商品库存变化时需要通知所有订阅该商品的用户;新闻网站中࿰…...
Java数值运算常见陷阱与规避方法
整数除法中的舍入问题 问题现象 当开发者预期进行浮点除法却误用整数除法时,会出现小数部分被截断的情况。典型错误模式如下: void process(int value) {double half = value / 2; // 整数除法导致截断// 使用half变量 }此时...
