使用自定義註解實現redisson分佈式鎖
自定義註解實現redisson分佈式鎖
1、自定義註解
package com.example.demo.annotation; import java.lang.annotation.*; /** * desc: 自定義 redisson 分佈式鎖註解 * * @author: 邢陽 * @mail: [email protected] * @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; }
2、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: [email protected] * @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)); } }
3、service中使用註解加鎖使用
/** * desc: 鎖 * * @author: 邢陽 * @mail: [email protected] * @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維護鎖定該庫存,進行操作。
代碼:
1、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;} }
2、分佈式鎖
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(); } }
3、測試類
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的一個線程能獲取到鎖。
以上為個人經驗,希望能給大傢一個參考,也希望大傢多多支持WalkonNet。
推薦閱讀:
- Redisson 主從一致性問題詳解
- redisson分佈式鎖的用法大全
- Java Redis Redisson配置教程詳解
- 解決線程並發redisson使用遇到的坑
- Redisson實現Redis分佈式鎖的幾種方式