当前位置:网站首页>一个注解替换synchronized关键字:分布式场景下实现方法加锁
一个注解替换synchronized关键字:分布式场景下实现方法加锁
2022-08-04 01:08:00 【[email protected】
一个注解替换synchronized关键字:分布式场景下实现方法加锁
一、前言
单机部署场景下,当我们需要锁住少量代码块或者方法,通常会使用synchronized关键字进行加锁,如下所示
public synchronized void test(){
}
public void test2(){
Object o = new Object();
synchronized (o){
}
}
但是,在分布式场景下,由于jvm之间无法通信,一个服务是无法感知另外一个服务对当前代码快加锁。
该demo实现了分布式场景下,使用一个注解,对方法进行加锁。单机也可以使用。
二 、实现原理
1.原理
利用Aspect的Around方法,对需要加锁的方法进行动态代理
在方法执行前获取Redisson锁对象,获取成功,方法执行。执行成功后释放锁
获取规则根据注解的相关参数进行设置。
用Redisson进行加锁
2.注解参数描述
- value锁名称
- waitTime等待超时:默认5秒,当waitTime<0,表示一直等待获取锁
- leaseTime过期时长:默认10秒
- timeUnit时长单位:默认单位秒
三、公平锁注解(@FairLock)
@FairLock实现了对接口fairLock加锁,知道该接口当前请求结束后,才可以再次被请求
@FairLock("fairLock")
@RequestMapping("fairLock")
public Date fairLock() throws InterruptedException {
Thread.sleep(3000);
return new Date();
}
四、读写锁注解(@ReadWriteLock)
@ReadWriteLock(value = “readWrite”,lockType = ReadWriteLockType.WRITELOCK)
如下图所示,用@ReadWriteLock对方法进行加读写锁,锁名称为readWrite,类型为读锁

import com.mabo.redis.easycode.readWriteLock.ReadWriteLock;
import com.mabo.redis.easycode.readWriteLock.ReadWriteLockType;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.text.SimpleDateFormat;
import java.util.Date;
@RestController
public class ReadWriteLockController {
private static SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
@ReadWriteLock(value = "readWrite",lockType = ReadWriteLockType.READLOCK)
@RequestMapping("read")
public String read() throws InterruptedException {
System.out.println("开始执行read");
Thread.sleep(100000);
System.out.println("read执行结束");
return sdf.format(new Date());
}
/** * value锁名称 * waitTime等待超时:默认5秒,当waitTime<0,表示一直等待获取锁 * leaseTime过期时长:默认10秒 * timeUnit时长单位:默认秒 */
@ReadWriteLock(value = "readWrite",lockType = ReadWriteLockType.WRITELOCK)
@RequestMapping("write")
public String write() throws InterruptedException {
Thread.sleep(3000);
return sdf.format(new Date());
}
}
五、下载地址
github下载地址: github
https://github.com/MaBo2420935619/EasycodeRedissonLock
版权声明
本文为[[email protected]]所创,转载请带上原文链接,感谢
https://blog.csdn.net/weixin_47053123/article/details/126138519
边栏推荐
猜你喜欢

电子组装行业对MES管理系统的需求分析

因为一次bug的教训,我决定手撕Nacos源码(先撕客户端源码)
![Please refer to dump files (if any exist) [date].dump, [date]-jvmRun[N].dump and [date].dumpstream.](/img/10/87c0bedd49b5dce6fbcd28ac361145.png)
Please refer to dump files (if any exist) [date].dump, [date]-jvmRun[N].dump and [date].dumpstream.

Quickly build a website with static files

2022 中国算力大会发布“创新先锋”优秀成果

typescript52 - simplify generic function calls

LeetCode第三题(Longest Substring Without Repeating Characters)三部曲之三:两次优化

Apache DolphinScheduler新一代分布式工作流任务调度平台实战-中

nodejs安装及环境配置

redis中常见的问题(缓存穿透,缓存雪崩,缓存击穿,redis淘汰策略)
随机推荐
【Untitled】
数组_滑动窗口 | leecode刷题笔记
Observability:你所需要知道的关于 Syslog 的一些知识
thinkphp 常用技巧
电子制造企业部署WMS仓储管理系统的好处是什么
手撕Gateway源码,今日撕工作流程、负载均衡源码
【虚拟化生态平台】虚拟化平台esxi挂载USB硬盘
typescript55-泛型约束
FeatureNotFound( bs4.FeatureNotFound: Couldn‘t find a tree builder with the features you requested:
通用的测试用例编写大全(登录测试/web测试等)
IDEA02:配置SQL Server2019数据库
有没有jdbc 链接优炫数据库文档及示例?
Use nodejs switch version (no need to uninstall and reinstall)
typescript56 - generic interface
OpenCV如何实现Sobel边缘检测
特征值与特征向量
typescript57 - Array generic interface
动态内存二
【详细教程】一文参透MongoDB聚合查询
redis中常见的问题(缓存穿透,缓存雪崩,缓存击穿,redis淘汰策略)