使用自定义注解实现redisson分布式锁
作者:SillinessPlus 发布时间:2021-09-30 18:31:22
标签:注解,redisson,分布式锁
自定义注解实现redisson分布式锁
自定义注解
package com.example.demo.annotation;
import java.lang.annotation.*;
/**
* desc: 自定义 redisson 分布式锁注解
*
* @author: 邢阳
* @mail: xydeveloper@126.com
* @create 2021-05-28 16:50
*/
@Target({ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Inherited
public @interface Lock {
/**
* 锁的key spel 表达式
*
* @return
*/
String key();
/**
* 持锁时间
*
* @return
*/
long keepMills() default 20;
/**
* 没有获取到锁时,等待时间
*
* @return
*/
long maxSleepMills() default 30;
}
aop解析注解
package com.example.demo.utils;
import com.example.demo.annotation.Lock;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.reflect.MethodSignature;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.DefaultParameterNameDiscoverer;
import org.springframework.expression.EvaluationContext;
import org.springframework.expression.spel.standard.SpelExpressionParser;
import org.springframework.expression.spel.support.StandardEvaluationContext;
import org.springframework.stereotype.Component;
import java.util.Objects;
import java.util.concurrent.TimeUnit;
/**
* desc: 解析 自定义 redisson 分布式锁注解
*
* @author: 邢阳
* @mail: xydeveloper@126.com
* @create 2021-05-28 16:50
*/
@Aspect
@Component
public class LockAspect {
@Autowired
private RedissonClient redissonClient;
/**
* 用于SpEL表达式解析.
*/
private final SpelExpressionParser spelExpressionParser = new SpelExpressionParser();
/**
* 用于获取方法参数定义名字.
*/
private final DefaultParameterNameDiscoverer defaultParameterNameDiscoverer = new DefaultParameterNameDiscoverer();
@Around("@annotation(com.example.demo.annotation.Lock)")
public Object around(ProceedingJoinPoint proceedingJoinPoint) throws Throwable {
Object object = null;
RLock lock = null;
try {
// 获取注解实体信息
Lock lockEntity = (((MethodSignature) proceedingJoinPoint.getSignature()).getMethod())
.getAnnotation(Lock.class);
// 根据名字获取锁实例
lock = redissonClient.getLock(getKeyBySpeL(lockEntity.key(), proceedingJoinPoint));
if (Objects.nonNull(lock)) {
if (lock.tryLock(lockEntity.maxSleepMills(), lockEntity.keepMills(), TimeUnit.SECONDS)) {
object = proceedingJoinPoint.proceed();
} else {
throw new RuntimeException();
}
}
} finally {
if (Objects.nonNull(lock) && lock.isHeldByCurrentThread()) {
lock.unlock();
}
}
return object;
}
/**
* 获取缓存的key
*
* key 定义在注解上,支持SPEL表达式
*
* @return
*/
public String getKeyBySpeL(String spel, ProceedingJoinPoint proceedingJoinPoint) {
MethodSignature methodSignature = (MethodSignature) proceedingJoinPoint.getSignature();
String[] paramNames = defaultParameterNameDiscoverer.getParameterNames(methodSignature.getMethod());
EvaluationContext context = new StandardEvaluationContext();
Object[] args = proceedingJoinPoint.getArgs();
for (int i = 0; i < args.length; i++) {
context.setVariable(paramNames[i], args[i]);
}
return String.valueOf(spelExpressionParser.parseExpression(spel).getValue(context));
}
}
service中使用注解加锁使用
/**
* desc: 锁
*
* @author: 邢阳
* @mail: xydeveloper@126.com
* @create 2021-05-28 17:58
*/
@Service
public class LockService {
@Lock(key = "#user.id", keepMills = 10, maxSleepMills = 15)
public String lock(User user) {
System.out.println("持锁");
return "";
}
}
redisson分布式锁应用
分布式架构一定会用到分布式锁。目前公司使用的基于redis的redisson分布式锁。
应用场景
1.订单修改操作,首先要获取该订单的分布式锁,能取到才能去操作。lockey可以是订单的主键id。
2.库存操作,也要按照客户+仓库+sku维护锁定该库存,进行操作。
代码:
Redisson管理类
public class RedissonManager {
private static RedissonClient redisson;
static {
Config config = new Config();
config.useSentinelServers()
.addSentinelAddress("redis://127.0.0.1:26379","redis://127.0.0.1:7301", "redis://127.0.0.1:7302")
.setMasterName("mymaster")
.setReadMode(ReadMode.SLAVE)
.setTimeout(10000).setDatabase(0).setPassword("123***");
redisson = Redisson.create(config);
}
/**
* 获取Redisson的实例对象
* @return
*/
public static RedissonClient getRedisson(){ return redisson;}
}
分布式锁
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import java.util.concurrent.TimeUnit;
public class DistributedLock {
private static RedissonClient redissonClient = RedissonManager.getRedisson();
public static boolean tryLock(String lockKey, TimeUnit unit, int waitTime, int leaseTime) {
RLock lock = redissonClient.getLock(lockKey);
try {
return lock.tryLock(waitTime, leaseTime, unit);
} catch (InterruptedException e) {
return false;
}
}
public static void unlock(String lockKey) {
RLock lock = redissonClient.getLock(lockKey);
lock.unlock();
}
}
测试类
public class RedissonTest {
public static void main(String[] args) throws Exception{
Thread.sleep(2000L);
for (int i = 0; i < 3; i++) {
new Thread(() -> {
try {
//tryLock,第三个参数是等待时间,5秒内获取不到锁,则直接返回。 第四个参数 30是30秒后强制释放
boolean hasLock = DistributedLock.tryLock("lockKey", TimeUnit.SECONDS,5,30);
//获得分布式锁
if(hasLock){
System.out.println("idea1: " + Thread.currentThread().getName() + "获得了锁");
/**
* 由于在DistributedLock.tryLock设置的等待时间是5s,
* 所以这里如果休眠的小于5秒,这第二个线程能获取到锁,
* 如果设置的大于5秒,则剩下的线程都不能获取锁。可以分别试试2s,和8s的情况
*/
Thread.sleep(10000L);
DistributedLock.unlock("lockKey");
} else {
System.out.println("idea1: " + Thread.currentThread().getName() + "无法获取锁");
}
} catch (Exception e) {
e.printStackTrace();
}
}) .start();
}
}
}
我们再打开一个idea,可以把代码复制一份。同事启动两个RedissonTest ,模拟了并发操作。
测试结果:
idea2: Thread-1获得了锁
idea2: Thread-0无法获取锁
idea2: Thread-2无法获取锁
idea1: Thread-2无法获取锁
idea1: Thread-0无法获取锁
idea1: Thread-1无法获取锁
从测试结果发现,最后是只能有一个idea的一个线程能获取到锁。
来源:https://blog.csdn.net/weixin_43319539/article/details/117365044
0
投稿
猜你喜欢
- ArrayList集合在查询元素时速度很快,但在增删元素时效率较低,为了克服这种局限性,可以使用List接口的另一个实现类LinkedLis
- 本文实例讲述了C#数字图像处理之图像缩放的方法。分享给大家供大家参考。具体如下://定义图像缩放函数private static Bitma
- 一.Unsafe类的源码分析JDK的rt.jar包中的Unsafe类提供了硬件级别的原子操作,Unsafe里面的方法都是native方法,通
- 用途:IO工具类(将内容写到流中)使用场景IO工具类只是辅助流的读写,并不负责关闭流。原因是流可能被多次读写,读写关闭后容易造成问题。项目引
- 先引用using System.Runtime.InteropServices; 的命名空间, 然后在合适的位置加上如下代码就OK。。注意:
- 1.先导入以下两个jar包2.jsp文件表单必须是post提交,编码必须是multipart/form-data 文件上传文本框必须起名。3
- 这篇文章主要介绍了spring boot如何实现切割分片上传,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需
- 本文实例为大家分享了使用C#写出一个简单的记事本程序,供大家参考,具体内容如下编程语言: C# 编程环境: Visual Studio 20
- 这里以JDK 7U15在 Windows x86平台下的安装为例,其他平台安装与此类同。下载JDK请查看:JDK最新下载地址【含下载方法】①
- 前言记得前段时间的文章么?redis使用位图法记录在线用户的状态,还是需要自己实现一个IM在线用户状态的记录,今天来讲讲另一方案,布隆过滤器
- 提到Excel的导入导出,大家肯定都知道alibaba开源的EasyExcel,该项目的github地址为:https://github.c
- state:比较常用,各种状态都可以用它,但是它更着重于一种心理状态或者物理状态。Status:用在人的身上一般是其身份和地位,作“状态,情
- 以下实例演示了如何通过 Collections 类的 Collections.max() 和 Collections.min() 方法来查找
- 一、什么是命令模式命令模式是一个高内聚的模式,其定义为:将一个请求封装成一个对象,从而让你使用不同的请求把客户端参数化,对请 求排队或者记录
- 在前面的《基于任务的异步编程模式(TAP)》文章中讲述了.net 4.5框架下的异步操作自我实现方式,实际上,在.net 4.5中部分类已实
- 在为什么阿里巴巴不建议在for循环中使用”+”进行字符串拼接一文中,我们介绍了几种Java中字符串拼接的方式,以及优缺点。其中还有一个重要的
- 目录一对一关联保存:留言表实体类配置:(主表)留言内容表配置:(从表)留言表hbm.xml配置:(主表)留言内容表hbm.xml配置:(从表
- 问题描述利用选择排序把一列数组按从小到大或从大到小排序(一)、选择排序思想以从小到大为例:1、第一轮选择,从第一个数开始,依次比较后面所有的
- 最近没做项目,重新整理了一个最完整的Mybatis Generator(简称MBG)的最完整配置文件,带详解,再也不用去看EN的User G
- Sentinel是阿里巴巴开源的限流器熔断器,并且带有可视化操作界面。在日常开发中,限流功能时常被使用,用于对某些接口进行限流熔断,譬如限制