java基于redis实现分布式锁

文章目录

  • 前言
  • 一、redis
  • 二、Redisson
    • 1.引入库
    • 2. 分布式锁
    • 3. 锁自动续期
  • 总结


前言

上篇文章介绍了Java中锁的应用,在SpringBoot单体应用中完全够用,但是SpringCloud微服务集群中就力所不及了。
我的使用场景是某些微服务应用中使用spring注解的形式来完成定时任务的功能,服务集群之后每台服务器都会调起定时任务,这和预想的不一样,需要添加分布式锁来控制任务的执行,推荐大家使用quartz和xxl-job来完成定时任务的调度。


一、redis

redis的使用我就不过多介绍了,前面文章写了好几篇了,可以自行爬楼翻看。

@Service
public class StudentService {private static final Logger log = LoggerFactory.getLogger(StudentService.class);@AutowiredStringRedisTemplate stringRedisTemplate;@Value("${server.port}")private String port;@Scheduled(cron = "0 0/1 6-23 * * ?")public void execute(){ValueOperations<String, String> operations = stringRedisTemplate.opsForValue();String key="student-"+ DateUtils.format(new Date(),"yyyyMMdd");String value = RandomUtil.randomNumbers(6);long timeout=24 * 60 * 60;Boolean absent = operations.setIfAbsent(key, value, timeout, TimeUnit.SECONDS);log.debug(port+"获取锁:"+absent);try {//todo 业务处理if(absent){Thread.sleep(1000);}} catch (InterruptedException e) {e.printStackTrace();}finally {if(value.equals(operations.get(key))){stringRedisTemplate.delete(key);log.debug(port+"执行完成,解除锁");}}}
}

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
定时任务集群要保证服务器时间一致,否则每次执行都可能跑到时间较为靠前的那台服务器上

二、Redisson

1.引入库

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

2. 分布式锁

@Service
public class StudentService {private static final Logger log = LoggerFactory.getLogger(StudentService.class);@Value("${server.port}")private String port;@Autowiredprivate RedissonClient redissonClient;@Scheduled(cron = "0 0/1 6-23 * * ?")public void redisson(){String key="student-"+ DateUtils.format(new Date(),"yyyyMMdd");long timeout=24 * 60 * 60;RLock lock = redissonClient.getLock(key);boolean tryLock=false;try {tryLock = lock.tryLock();log.debug(port+"获取锁["+key+"]:"+tryLock);if(tryLock){lock.lock(timeout, TimeUnit.SECONDS);//锁到期自动解锁//todo 业务处理Thread.sleep(10000);}} catch (Exception e) {e.printStackTrace();}finally {if(tryLock&&lock.isHeldByCurrentThread()){lock.unlock();log.debug(port+"执行完成,解除锁["+key+"]");}}}
}

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

3. 锁自动续期

@Service
public class StudentService {private static final Logger log = LoggerFactory.getLogger(StudentService.class);@Value("${server.port}")private String port;@Autowiredprivate RedissonClient redissonClient;@Scheduled(cron = "0 0/1 6-23 * * ?")public void redissonRenewal(){String key="student-"+ DateUtils.format(new Date(),"yyyyMMdd");long time=10;RLock lock = redissonClient.getLock(key);boolean tryLock=false;try {tryLock = lock.tryLock(time,TimeUnit.SECONDS);log.debug(port+"获取锁["+key+"]:"+tryLock);if(tryLock){log.debug(port+"锁["+key+"]剩余生存时间为:"+(lock.remainTimeToLive()/1000)+"秒");lock.lock();//todo 业务处理Thread.sleep(40000);log.debug(port+"锁["+key+"]剩余生存时间为:"+(lock.remainTimeToLive()/1000)+"秒");}} catch (Exception e) {e.printStackTrace();}finally {if(tryLock&&lock.isHeldByCurrentThread()){lock.unlock();log.debug(port+"执行完成,解除锁["+key+"]");}}}
}

在这里插入图片描述

在这里插入图片描述
在这里插入图片描述


总结

回到顶部
Redisson
redisson-spring-boot-starter

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

C++-带你走进多态(1)

1. 多态的概念 1.1 概念 多态的概念&#xff1a;通俗来说&#xff0c;就是多种形态&#xff0c;具体点就是去完成某个行为&#xff0c;当不同的对象去完成时会产生出不同的状态。 举个栗子&#xff1a;比如买票这个行为&#xff0c;当普通人买票时&#xff0c;是全价买票&am…

Jenkins解决Host key verification failed (2)

Jenkins解决Host key verification failed 分析原因情况 一、用OpenSSH的人都知ssh会把你每个你访问过计算机的公钥(public key)都记录在~/.ssh/known_hosts。当下次访问相同计算机时&#xff0c;OpenSSH会核对公钥。如果公钥不同&#xff0c;OpenSSH会发出警告&#xff0c;避免…

Spring中关于事务的一些方方面面

事务隔离级别&#xff1a; 先了解一些事务隔离级别有哪些&#xff1a; 未提交读(Read Uncommitted)&#xff1a; 允许脏读&#xff0c;也就是可能读取到其他会话中未提交事务修改的数据 提交读(Read Committed)&#xff1a; 只能读取到已经提交的数据。Oracle等多数数据库默…

车载电子电器架构 —— OEM基础技术概念开发流程

车载电子电器架构 —— 基础技术概念开发 我是穿拖鞋的汉子,魔都中坚持长期主义的汽车电子工程师。 老规矩,分享一段喜欢的文字,避免自己成为高知识低文化的工程师: 屏蔽力是信息过载时代一个人的特殊竞争力,任何消耗你的人和事,多看一眼都是你的不对。非必要不费力证明…

Linux之JAVA环境配置jdkTomcatMySQL

目录 一. 安装jdk 1.1 查询是否有jdk 1.2 解压 1.3 配置环境变量 二. 安装Tomcat&#xff08;开机自启动&#xff09; 2.1 解压 2.2 启动tomcat 2.3 防火墙设置 2.4 创建启动脚本&#xff08;设置自启动&#xff0c;服务器开启即启动&#xff09; 三. MySQL安装&#xff08;…

vscode使用restClient实现各种http请求

vscode使用restClient实现各种http请求 一&#xff0c;安装插件 首先&#xff0c;我们要在vscode的扩展中&#xff0c;搜索rest Client&#xff0c;然后安装它&#xff0c;这里我已经安装过了。 安装后&#xff0c;我们就可以使用rest client插件进行http各种操作了。 二&…

二分图匹配详解

二分图的原始模型及相关概念 二分图又称作二部图&#xff0c;是图论中的一种特殊模型。 设G(V,E)G(V,E)是一个无向图。 如顶点集V可分割为两个互不相交的子集&#xff08;A, B&#xff09;&#xff0c;并且图中每条边(i&#xff0c;j)所关联的两个顶点 i 和 j 就都分属两个不…

定时任务处理-Spring Task

目录 1 前言 2 cron表达式 2.1 相关概念的介绍 2.2 举个例子(白雪警告) 2.3 使用网站自动生成 3 Spring Task的使用 3.1 导入依赖坐标 3.2 开启任务调度 3.3 自定义定时任务类 1 前言 当我们需要处理一些定时任务的时候就需要用到我们的Spring Task&#xff0c;接下来…

(done) 两个矩阵 “相似” 是什么意思?

参考视频&#xff1a;https://www.bilibili.com/video/BV1zu411673J/?spm_id_from333.337.search-card.all.click&vd_source7a1a0bc74158c6993c7355c5490fc600 参考资料&#xff1a;https://baike.baidu.com/item/%E7%9B%B8%E4%BC%BC%E7%9F%A9%E9%98%B5/10369874?frge_a…

小波变换模拟

小波变换是一种信号处理技术&#xff0c;通过在时间-频率域中使用基于小波的函数进行信号分析。小波变换在处理非平稳信号和图像时特别有用&#xff0c;可以将信号分解为不同频率的成分。它在数据压缩、去噪、特征提取等领域有广泛应用。 MATLAB中提供了用于二维离散小波变换的…

css4浮动+清除浮动

浮动 一.常见网页布局1.三种布局方式2.布局准则 二.浮动&#xff08;float&#xff09;1.好处2.概念3.三大特性4.使用5.常见网页布局模板6.注意点 三.清除浮动1.why2.本质3.语法4.四种way&#xff08;后三个都是给父级添加&#xff09;清除浮动总结 一.常见网页布局 1.三种布局…

Java8 Stream API 详解:流式编程进行数据处理

&#x1f3f7;️个人主页&#xff1a;牵着猫散步的鼠鼠 &#x1f3f7;️系列专栏&#xff1a;Java全栈-专栏 &#x1f3f7;️个人学习笔记&#xff0c;若有缺误&#xff0c;欢迎评论区指正 前些天发现了一个巨牛的人工智能学习网站&#xff0c;通俗易懂&#xff0c;风趣幽默&…

切比雪夫(最小区域法)平面拟合算法

欢迎关注更多精彩 关注我&#xff0c;学习常用算法与数据结构&#xff0c;一题多解&#xff0c;降维打击。 本期话题&#xff1a;切比雪夫&#xff08;最小区域法&#xff09;平面拟合算法 相关背景和理论 点击前往 主要介绍了应用背景和如何转化成线性规划问题 平拟合输入和…

【C++精简版回顾】8.const

1.const数据成员 &#xff08;1&#xff09;const数据成员必须使用初始化参数列表 &#xff08;2&#xff09;不能修改 &#xff08;3&#xff09;不能修改必须初始化 class MM { public:MM() {}MM(int age, string name) :age(age), name(name) {}~MM() {cout << "…

SpringBoot和ApiFox整合快速上手

前置&#xff1a;IDEA版本IntelliJ IDEA 2023.2.4&#xff0c;Apifox 2.5.6 安装插件&#xff1a;Apifox Helper1.2.1 目录 1.文档生成 2.提取登录接口token 1.文档生成 把密钥配置到 导入成功:文档就会出现 2.提取登录接口token 之后我们再使用的时候&#xff0c;只需要配置…

2024.2.25 -ElasticSearch 进阶

倒排索引 Elasticsearch的倒排索引机制是通过将文档中出现的词汇与它们所在的文档ID关联起来&#xff0c;实现快速查找包含特定词汇的文档。下面是一个具体的例子来说明倒排索引的工作原理&#xff1a; 假设我们有一个简单的文章集合&#xff0c;包含以下三篇文章&#xff1a…

解锁苏宁电商数据新纪元:关键字搜索API接口引领业务升级

苏宁关键字搜索API接口&#xff1a;电商数据探索的新篇章 一、引言 在电商领域&#xff0c;数据的重要性不言而喻。为了帮助开发者更高效地获取和利用电商数据&#xff0c;苏宁开放平台提供了关键字搜索API接口。本文将带你深入了解这一接口的技术细节&#xff0c;让你在电商…

设计模式--单例模式--懒汉饿汉

单例模式 单例模式(Singleton)&#xff0c;保证一个类仅有一个实例&#xff0c;并提供一个访问它的全局访问点。 单例模式 通常我们可以让一个全局变量使得一个对象被访问&#xff0c;但它不能防止你实例化多个对象。一个最好的办法就是&#xff0c;让类自身负责保存它的唯一实…

selenium自动化测试如何定位一闪而过的元素,比如提示信息、提交按钮

这里以登录按钮为例 在当前页面按F12点击控制,在下方输入debugger&#xff0c;点击登录按钮后点击输入debugger的地方按回车&#xff0c;一闪而过的元素就会定住不动就可以定位了

企业网站建设需要多少钱?定制开发费用报价在3000-4000元

建立一个网站需要多少钱&#xff1f; 网站建设的价格划分也有很多。 这里首先要提的是市面上常见的一种低成本建站方式——模板网站&#xff0c;就是那种直接制作网站原型就可以无限复制的网站。 或者可以在几分钟内建立一个由软件生成的网站。 成本低得惊人&#xff0c;从500元…