美畅物联丨分布式锁实战:Spring Boot项目中的Redis应用
wptr33 2025-01-05 20:30 20 浏览
在分布式系统里,多个节点或许会同时对共享资源进行访问与操作。为防止出现数据不一致、资源竞争等状况,就需要一种机制来对这些并发访问加以协调,于是分布式锁就出现了。它如同一把全局的钥匙,在同一时刻仅有一个节点能够获取该钥匙以访问共享资源,进而确保了数据的一致性以及系统的稳定性。
在Spring Boot应用里,利用Redis达成分布式锁是一种常见的操作方式,Redis提供了简洁且有效的机制以实现该功能。
以下为在Spring Boot中运用Redis实现分布式锁的步骤:
一、搭建 Spring Boot 项目并引入 Redis 依赖
1、创建 Spring Boot 项目
(1)利用Spring Initializr创建一个Spring Boot项目。在项目配置期间,挑选合适的Spring Boot版本,一般推荐使用稳定版本。
要确保添加Web依赖,因为在Web服务中我们通常会使用分布式锁来保护共享资源。此外,添加Redis依赖,这会让我们在项目中便捷地使用Redis相关功能。
(2)检查项目结构与配置文件
在生成的项目结构里,pom.xml(针对Maven项目)或者build.gradle(针对Gradle项目)属于项目构建文件,其作用是管理项目的依赖关系。
src/main/java目录是用于编写Java代码的地方,src/main/resources目录则用于存放配置文件、静态资源等。
2、配置 Redis 连接
(1)在application.properties或者application.yml中进行配置。
若使用application.properties文件,则添加如下配置:
properties
spring.redis.host=localhostspring.redis.port=6379
(2)这里假定Redis服务在本地运行,其主机名是localhost,端口为6379。若Redis服务受密码保护,那么还需添加spring.redis.password配置项。
若采用application.yml文件,配置如下:
yaml
spring:
redis:
host: localhost
port: 6379
这种配置方式更为直观,具有清晰的层次结构。同样地,若存在密码,也能够在password(密码)字段添加密码信息。
二、实现 Redis 分布式锁的基本步骤
1、注入 RedisTemplate
在需要运用分布式锁的类里注入RedisTemplate。
在Spring Boot框架下,RedisTemplate属于操作Redis的核心类。在服务类或者相关业务逻辑类当中,借助@Autowired注解来注入RedisTemplate。
java
import org.springframework.data.redis.core.RedisTemplate;import org.springframework.stereotype.Service;@Servicepublic class MyService {
private final RedisTemplate<String, Object> redisTemplate;
@Autowired
public MyService(RedisTemplate<String, Object> redisTemplate) {
this.redisTemplate = redisTemplate;
}
// 以下是使用分布式锁的业务逻辑}
在这里,把RedisTemplate注入到MyService类里,以便于在这个类之后的业务逻辑当中,运用Redis操作达成分布式锁。
2、获取分布式锁
利用Redis的SETNX命令达成锁获取
在MyService类里,编写一个用于获取分布式锁的方法。能够借助RedisTemplate的opsForValue方法来操作Redis中的字符串类型数据,该方法对应SETNX(SET if Not eXists)命令,此命令的作用是当键不存在时设置键值。
java
public boolean tryLock(String lockKey, long expireTime) {
Boolean result = redisTemplate.opsForValue().setIfAbsent(lockKey, "locked");
if (result!= null && result) {
// 设置锁的过期时间,防止死锁
redisTemplate.expire(lockKey, expireTime, TimeUnit.SECONDS);
return true;
}
return false;}
此方法接收两个参数,其中lockKey为用于标识锁的唯一键,expireTime则是锁的过期时间(单位为秒)。首先尝试获取锁,若键不存在(也就是说当前没有其他节点持有该锁),便将键值设为locked,并且返回true以表明获取锁成功。接着设置锁的过期时间,如此一来,即便持有锁的节点发生故障,锁也会在一段时间后自动释放,从而避免了死锁状况。若获取锁失败(键已经存在),则返回false。
3、释放分布式锁
利用Redis的DEL命令达成锁的释放
编写一个用于释放分布式锁的方法,同样借助RedisTemplate进行操作。
java
public void unlock(String lockKey) {
redisTemplate.delete(lockKey);}
这个方法十分简单,利用redisTemplate.delete方法删除相应的锁键,进而释放锁。但在实际应用时,必须注意确保只有持有锁的节点才能够释放锁,防止误将其他节点持有的锁释放。
三、注意事项
1、锁的过期时间:要确保设定合理的锁过期时间,防止由于某些原因(例如服务器宕机)致使锁无法释放。
2、重试机制:运用Spring Retry或者其他重试机制来处理锁获取失败的状况。
3、锁的唯一性:要保证锁键具有唯一性,以免不同业务逻辑发生冲突。
4、性能考量:分布式锁会带来一定的性能损耗,在高并发场景下尤其需要谨慎使用。
通过以上步骤,我们可以在 Spring Boot 项目中有效地使用 Redis 实现分布式锁,保护共享资源,确保分布式系统的稳定运行和数据一致性。不过,在实际应用中,还需要根据具体的业务场景和系统架构进行更多的优化和调整。
————————————————
关注“美畅物联”,了解更多视频汇聚及AIoT底座解决方案。
相关推荐
- redis的八种使用场景
-
前言:redis是我们工作开发中,经常要打交道的,下面对redis的使用场景做总结介绍也是对redis举报的功能做梳理。缓存Redis最常见的用途是作为缓存,用于加速应用程序的响应速度。...
- 基于Redis的3种分布式ID生成策略
-
在分布式系统设计中,全局唯一ID是一个基础而关键的组件。随着业务规模扩大和系统架构向微服务演进,传统的单机自增ID已无法满足需求。高并发、高可用的分布式ID生成方案成为构建可靠分布式系统的必要条件。R...
- 基于OpenWrt系统路由器的模式切换与网页设计
-
摘要:目前商用WiFi路由器已应用到多个领域,商家通过给用户提供一个稳定免费WiFi热点达到吸引客户、提升服务的目标。传统路由器自带的Luci界面提供了工厂模式的Web界面,用户可通过该界面配置路...
- 这篇文章教你看明白 nginx-ingress 控制器
-
主机nginx一般nginx做主机反向代理(网关)有以下配置...
- 如何用redis实现注册中心
-
一句话总结使用Redis实现注册中心:服务注册...
- 爱可可老师24小时热门分享(2020.5.10)
-
No1.看自己以前写的代码是种什么体验?No2.DooM-chip!国外网友SylvainLefebvre自制的无CPU、无操作码、无指令计数器...No3.我认为CS学位可以更好,如...
- Apportable:拯救程序员,IOS一秒变安卓
-
摘要:还在为了跨平台使用cocos2d-x吗,拯救objc程序员的奇葩来了,ApportableSDK:FreeAndroidsupportforcocos2d-iPhone。App...
- JAVA实现超买超卖方案汇总,那个最适合你,一篇文章彻底讲透
-
以下是几种Java实现超买超卖问题的核心解决方案及代码示例,针对高并发场景下的库存扣减问题:方案一:Redis原子操作+Lua脚本(推荐)//使用Redis+Lua保证原子性publicbo...
- 3月26日更新 快速施法自动施法可独立设置
-
2016年3月26日DOTA2有一个79.6MB的更新主要是针对自动施法和快速施法的调整本来内容不多不少朋友都有自动施法和快速施法的困扰英文更新日志一些视觉BUG修复就不翻译了主要翻译自动施...
- Redis 是如何提供服务的
-
在刚刚接触Redis的时候,最想要知道的是一个’setnameJhon’命令到达Redis服务器的时候,它是如何返回’OK’的?里面命令处理的流程如何,具体细节怎么样?你一定有问过自己...
- lua _G、_VERSION使用
-
到这里我们已经把lua基础库中的函数介绍完了,除了函数外基础库中还有两个常量,一个是_G,另一个是_VERSION。_G是基础库本身,指向自己,这个变量很有意思,可以无限引用自己,最后得到的还是自己,...
- China's top diplomat to chair third China-Pacific Island countries foreign ministers' meeting
-
BEIJING,May21(Xinhua)--ChineseForeignMinisterWangYi,alsoamemberofthePoliticalBureau...
- 移动工作交流工具Lua推出Insights数据分析产品
-
Lua是一个适用于各种职业人士的移动交流平台,它在今天推出了一项叫做Insights的全新功能。Insights是一个数据平台,客户可以在上面实时看到员工之间的交流情况,并分析这些情况对公司发展的影响...
- Redis 7新武器:用Redis Stack实现向量搜索的极限压测
-
当传统关系型数据库还在为向量相似度搜索的性能挣扎时,Redis7的RedisStack...
- Nginx/OpenResty详解,Nginx Lua编程,重定向与内部子请求
-
重定向与内部子请求Nginx的rewrite指令不仅可以在Nginx内部的server、location之间进行跳转,还可以进行外部链接的重定向。通过ngx_lua模块的Lua函数除了能实现Nginx...
- 一周热门
-
-
C# 13 和 .NET 9 全知道 :13 使用 ASP.NET Core 构建网站 (1)
-
因果推断Matching方式实现代码 因果推断模型
-
git pull命令使用实例 git pull--rebase
-
git pull 和git fetch 命令分别有什么作用?二者有什么区别?
-
面试官:git pull是哪两个指令的组合?
-
git 执行pull错误如何撤销 git pull fail
-
git fetch 和git pull 的异同 git中fetch和pull的区别
-
git pull 之后本地代码被覆盖 解决方案
-
还可以这样玩?Git基本原理及各种骚操作,涨知识了
-
git命令之pull git.pull
-
- 最近发表
- 标签列表
-
- git pull (33)
- git fetch (35)
- mysql insert (35)
- mysql distinct (37)
- concat_ws (36)
- java continue (36)
- jenkins官网 (37)
- mysql 子查询 (37)
- python元组 (33)
- mybatis 分页 (35)
- vba split (37)
- redis watch (34)
- python list sort (37)
- nvarchar2 (34)
- mysql not null (36)
- hmset (35)
- python telnet (35)
- python readlines() 方法 (36)
- munmap (35)
- docker network create (35)
- redis 集合 (37)
- python sftp (37)
- setpriority (34)
- c语言 switch (34)
- git commit (34)