Spring防止重复点击的两种实现方法_Java

第一种：@easylock

简介

为了简化可复用注解，自己实现的注解，代码简单随拿随用

使用方式

1.创建一个注解

@target(elementtype.method)
@retention(retentionpolicy.runtime)
@documented
public @interface easylock {
    long waittime() default 1;
    long leasetime() default 3;
}

2. 创建一个aop切面类（异常可以自定义，这里我用的cicada）

import lombok.extern.slf4j.slf4j;
import org.apache.commons.lang.stringutils;
import org.aspectj.lang.proceedingjoinpoint;
import org.aspectj.lang.annotation.around;
import org.aspectj.lang.annotation.aspect;
import org.aspectj.lang.annotation.pointcut;
import org.aspectj.lang.reflect.methodsignature;
import org.redisson.api.rlock;
import org.redisson.api.redissonclient;
import org.springframework.stereotype.component;
import vip.lspace.agent.common.annotation.easylock;
import vip.lspace.agent.common.exception.lockexception;
 
import javax.annotation.resource;
import java.util.concurrent.timeunit;
 
@component
@aspect
@slf4j
public class lockaop {
    @resource
    private lockexception lockexception;
 
    @resource
    redissonclient redissonclient;
 
    private static final string redislockkeyparamname = "redislockkey";
 
    @pointcut("@annotation(vip.lspace.agent.common.annotation.easylock)")
    public void lockpointcut() {
    }
 
    @around("lockpointcut()")
    public object doaround(proceedingjoinpoint proceedingjoinpoint) {
        log.info("easylock locking");
        methodsignature methodsignature = (methodsignature) proceedingjoinpoint.getsignature();
        easylock easylock = methodsignature.getmethod().getannotation(easylock.class);
 
        object[] args = proceedingjoinpoint.getargs();
        string[] parameternames = methodsignature.getparameternames();
        string redislockkey = "";
        for (int i = 0; i < parameternames.length; i++) {
            if (parameternames[i].equals(redislockkeyparamname)) {
                redislockkey = (string) args[i];
            }
        }
        if (stringutils.isblank(redislockkey)) {
            throw lockexception.lockkeynotexist();
        }
 
        rlock lock = redissonclient.getlock(redislockkey);
        try {
            if (!lock.trylock(easylock.waittime(), easylock.leasetime(), timeunit.seconds)) {
                throw lockexception.getlocktimeout(redislockkey);
            }
            return proceedingjoinpoint.proceed();
        } catch (throwable e) {
            throw new runtimeexception(e);
        } finally {
            if (lock.islocked() && lock.isheldbycurrentthread()) {
                lock.unlock();
                log.info("当前线程{}，释放锁:{}", thread.currentthread().getid(), redislockkey);
            }
        }
    }

@cicadabean(namespace = "lock")
public interface lockexception {
    @exceptioninfo(errcode = 13001, errmessage = "没找到分布式锁key")
    cicadaexception lockkeynotexist();
 
    @exceptioninfo(errcode = 13002, errmessage = "超时未获取到锁: %s")
    cicadaexception getlocktimeout(string key);
}

3.使用方式

注意点：

必须包含名为redislockkey的参数，作为redis的key

@override
    @easylock(waittime = 1,
            leasetime = 3
    )
    @transactional(rollbackfor = exception.class)
    public void concurrenttest(string redislockkey) {
        paymentbillbacktrack paymentbillbacktrack = paymentbillbacktrackservice.getbyid(1l);
        string refundrequestno = paymentbillbacktrack.getmerchantrefundrequestno();
        paymentbillbacktrack.setmerchantrefundrequestno(string.valueof(integer.parseint(refundrequestno) + 1));
        paymentbillbacktrackservice.updatebyid(paymentbillbacktrack);
    }

第二种：@nicelock

简介

大佬提供的公共组件，引包后可直接使用，使用简单

使用方式

1.引包

一定得引入1.1.6的，甚至最新版本，不然有问题！！！

<dependency>
     <groupid>com.suchtool</groupid>
     <artifactid>nicelock-spring-boot-starter</artifactid>
     <version>1.1.6</version>
</dependency>

2.使用

    @override
    @transactional
    @nicelock(
            keys = {"#userid"},
            acquiretimeout = 3000l,
            exception = nicelocklockfailexception.class,
            message = "服务已完成评价，不能重复提交"
    )
    public void test(string userid) {
        system.out.println("修改订单: 用户id=" + userid);
    }