spring防止重复点击，两种注解实现（AOP）

第一种：@EasyLock

简介

   为了简化可复用注解，自己实现的注解，代码简朴随拿随用
  使用方式

1.创建一个注解

1. @Target(ElementType.METHOD)
2. @Retention(RetentionPolicy.RUNTIME)
3. @Documented
4. public @interface EasyLock {
5.     long waitTime() default 1;
6.     long leaseTime() default 3;
7. }

复制代码

 2. 创建一个AOP切面类（异常可以自界说，这里我用的Cicada）

1. import lombok.extern.slf4j.Slf4j;
2. import org.apache.commons.lang.StringUtils;
3. import org.aspectj.lang.ProceedingJoinPoint;
4. import org.aspectj.lang.annotation.Around;
5. import org.aspectj.lang.annotation.Aspect;
6. import org.aspectj.lang.annotation.Pointcut;
7. import org.aspectj.lang.reflect.MethodSignature;
8. import org.redisson.api.RLock;
9. import org.redisson.api.RedissonClient;
10. import org.springframework.stereotype.Component;
11. import vip.lspace.agent.common.annotation.EasyLock;
12. import vip.lspace.agent.common.exception.LockException;
14. import javax.annotation.Resource;
15. import java.util.concurrent.TimeUnit;
17. @Component
18. @Aspect
19. @Slf4j
20. public class LockAop {
21.     @Resource
22.     private LockException lockException;
24.     @Resource
25.     RedissonClient redissonClient;
27.     private static final String redisLockKeyParamName = "redisLockKey";
29.     @Pointcut("@annotation(vip.lspace.agent.common.annotation.EasyLock)")
30.     public void lockPointcut() {
31.     }
33.     @Around("lockPointcut()")
34.     public Object doAround(ProceedingJoinPoint proceedingJoinPoint) {
35.         log.info("EasyLock locking");
36.         MethodSignature methodSignature = (MethodSignature) proceedingJoinPoint.getSignature();
37.         EasyLock easyLock = methodSignature.getMethod().getAnnotation(EasyLock.class);
39.         Object[] args = proceedingJoinPoint.getArgs();
40.         String[] parameterNames = methodSignature.getParameterNames();
41.         String redisLockKey = "";
42.         for (int i = 0; i < parameterNames.length; i++) {
43.             if (parameterNames[i].equals(redisLockKeyParamName)) {
44.                 redisLockKey = (String) args[i];
45.             }
46.         }
47.         if (StringUtils.isBlank(redisLockKey)) {
48.             throw lockException.lockKeyNotExist();
49.         }
51.         RLock lock = redissonClient.getLock(redisLockKey);
52.         try {
53.             if (!lock.tryLock(easyLock.waitTime(), easyLock.leaseTime(), TimeUnit.SECONDS)) {
54.                 throw lockException.getLockTimeOut(redisLockKey);
55.             }
56.             return proceedingJoinPoint.proceed();
57.         } catch (Throwable e) {
58.             throw new RuntimeException(e);
59.         } finally {
60.             if (lock.isLocked() && lock.isHeldByCurrentThread()) {
61.                 lock.unlock();
62.                 log.info("当前线程{}，释放锁:{}", Thread.currentThread().getId(), redisLockKey);
63.             }
64.         }
65.     }

复制代码

1. @CicadaBean(namespace = "lock")
2. public interface LockException {
3.     @ExceptionInfo(errCode = 13001, errMessage = "没找到分布式锁key")
4.     CicadaException lockKeyNotExist();
6.     @ExceptionInfo(errCode = 13002, errMessage = "超时未获取到锁: %s")
7.     CicadaException getLockTimeOut(String key);
8. }

复制代码

3.使用方式
    留意点：
  必须包含名为redisLockKey的参数，作为redis的key

1. @Override
2.     @EasyLock(waitTime = 1,
3.             leaseTime = 3
4.     )
5.     @Transactional(rollbackFor = Exception.class)
6.     public void concurrentTest(String redisLockKey) {
7.         PaymentBillBacktrack paymentBillBacktrack = paymentBillBacktrackService.getById(1L);
8.         String refundRequestNo = paymentBillBacktrack.getMerchantRefundRequestNo();
9.         paymentBillBacktrack.setMerchantRefundRequestNo(String.valueOf(Integer.parseInt(refundRequestNo) + 1));
10.         paymentBillBacktrackService.updateById(paymentBillBacktrack);
11.     }

复制代码

第二种：@NiceLock

简介

   大佬提供的公共组件，引包后可直接使用，使用简朴，细节代码可看nicelock: nicelock：一个注解，即可使用Java的分布式锁。（基于Redisson）
  使用方式

1.引包
肯定得引入1.1.6的，甚至最新版本，否则有问题！！！

1. <dependency>
2.      <groupId>com.suchtool</groupId>
3.      <artifactId>nicelock-spring-boot-starter</artifactId>
4.      <version>1.1.6</version>
5. </dependency>

复制代码

2.使用

1.     @Override
2.     @Transactional
3.     @NiceLock(
4.             keys = {"#userId"},
5.             acquireTimeout = 3000L,
6.             exception = NiceLockLockFailException.class,
7.             message = "服务已完成评价，不能重复提交"
8.     )
9.     public void test(String userId) {
10.         System.out.println("修改订单: 用户ID=" + userId);
11.     }

复制代码

  注解中传入了exception参数后，报错会输出message的内容，更加直观 
  测试方式

Apifox中的主动化测试中可以配多个线程同时执行接口，测试重复点击是否生效

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。