基于Redission实现分布式锁

news/2025/1/16 16:03:20/

pom文件

 <dependency><groupId>org.redisson</groupId><artifactId>redisson-spring-boot-starter</artifactId><version>3.15.0</version></dependency>

import lombok.extern.slf4j.Slf4j;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;import java.util.concurrent.TimeUnit;/*** 分布式锁实现基于Redisson*/
@Slf4j
@Component
public class RedissonLockClient {@Autowiredprivate RedissonClient redissonClient;@Autowiredprivate RedisTemplate<String, Object> redisTemplate;/*** 获取锁*/public RLock getLock(String lockKey) {return redissonClient.getLock(lockKey);}/*** 加锁操作** @return boolean*/public boolean tryLock(String lockName, long expireSeconds) {return tryLock(lockName, 0, expireSeconds);}/*** 加锁操作** @return boolean*/public boolean tryLock(String lockName, long waitTime, long expireSeconds) {RLock rLock = getLock(lockName);boolean getLock = false;try {getLock = rLock.tryLock(waitTime, expireSeconds, TimeUnit.SECONDS);if (getLock) {log.info("获取锁成功,lockName={}", lockName);} else {log.info("获取锁失败,lockName={}", lockName);}} catch (InterruptedException e) {log.error("获取式锁异常,lockName=" + lockName, e);getLock = false;}return getLock;}public boolean fairLock(String lockKey, TimeUnit unit, int leaseTime) {RLock fairLock = redissonClient.getFairLock(lockKey);try {boolean existKey = existKey(lockKey);// 已经存在了,就直接返回if (existKey) {return false;}return fairLock.tryLock(3, leaseTime, unit);} catch (InterruptedException e) {e.printStackTrace();}return false;}public boolean existKey(String key) {return redisTemplate.hasKey(key);}/*** 锁lockKey** @param lockKey* @return*/public RLock lock(String lockKey) {RLock lock = getLock(lockKey);lock.lock();return lock;}/*** 锁lockKey** @param lockKey* @param leaseTime* @return*/public RLock lock(String lockKey, long leaseTime) {RLock lock = getLock(lockKey);lock.lock(leaseTime, TimeUnit.SECONDS);return lock;}/*** 解锁** @param lockName 锁名称*/public void unlock(String lockName) {try {redissonClient.getLock(lockName).unlock();} catch (Exception e) {log.error("解锁异常,lockName=" + lockName, e);}}}

配置类


@Configuration
public class RedissonConfig {@Value("${spring.redis.host}")private String host;@Value("${spring.redis.port}")private String port;@Beanpublic RedissonClient getRedisson(){Config config = new Config();//单机模式  依次设置redis地址和密码config.useSingleServer().setAddress("redis://" + host + ":" + port);return Redisson.create(config);}
}

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

相关文章

CSS 伪类选择器<a> 的四个伪类选择器

CSS 伪类选择器是用于选择文档中没有特殊语义的元素并给它们应用样式的一种方法。其中&#xff0c;伪类选择器 a 是针对 HTML 超链接元素的伪类选择器&#xff0c;用于在链接状态下应用样式。常见的 a 伪类选择器有四种&#xff0c;分别是&#xff1a;hover、active、visited 和…

深度学习中的激活函数

给定一个线性变换可以把x的值映射到一条直线上&#xff0c;如下图 输出结果就是y1w1xb1 如果y1经过一个线性变换得到一个y2&#xff0c;那么x和y2的关系是什么&#xff1f; 答案&#xff0c;毫无疑问是一条直线&#xff0c;不管如何的线性变换&#xff0c;依旧是一个线性的问…

力扣每日一题36:有效的数独

题目描述&#xff1a; 请你判断一个 9 x 9 的数独是否有效。只需要 根据以下规则 &#xff0c;验证已经填入的数字是否有效即可。 数字 1-9 在每一行只能出现一次。数字 1-9 在每一列只能出现一次。数字 1-9 在每一个以粗实线分隔的 3x3 宫内只能出现一次。&#xff08;请参考…

OJ第三篇

文章目录 随机链表的复制 随机链表的复制 链接:随机链表的复制 这个题简单而言就是它给一个链表&#xff0c;每个结点包含两个指针&#xff0c;分别指向下一个和一个随机的结点&#xff08;也有可能指向空&#xff09;&#xff0c;你要做的就是复制这个链表&#xff0c;使你创…

C#开发的OpenRA游戏之金钱系统(1)

C#开发的OpenRA游戏之金钱系统(1) 设计一个游戏,肯定要有一个唯一的资源,用这个资源来管理整个游戏的进度,以及相互争夺的焦点。在OpenRA里,就是使用矿产资源。所以在地图上分布几个矿场,玩家就需要相互争夺矿场,谁开采多谁就更有钱,谁有钱了就可以升级更好的科技,以…

Spark中的Driver、Executor、Stage、TaskSet、DAGScheduler等介绍

工作流程&#xff1a; Driver 创建 SparkSession 并将应用程序转化为执行计划&#xff0c;将作业划分为多个 Stage&#xff0c;并创建相应的 TaskSet。Driver 将 TaskSet 发送给 TaskScheduler 进行调度和执行。TaskScheduler 根据资源情况将任务分发给可用的 Executor 进程执…

Spring MVC中通过配置文件配置定时任务

Spring MVC中配置定时任务&#xff08;配置文件方式&#xff09; 1.步骤 1.步骤 1-1 在springmvc.xml&#xff08;配置文件&#xff09;的beans中添加 xmlns:task"http://www.springframework.org/schema/task" http://www.springframework.org/schema/task http…

jwt详细介绍

jwt详细介绍 1.jwt 简介&#xff1a;2.jwt 工具类介绍3.案列演示&#xff1a;3.1并在web.xml进行配置过滤器 3.2过滤3.3全局响应设置 1.jwt 简介&#xff1a; 。JWT&#xff08;JSON Web Token&#xff09; 是一种用于安全传输信息的开放标准&#xff08;RFC 7519&#xff09;…