快捷導(dǎo)航

分布式鎖在Spring Boot應(yīng)用中的實(shí)現(xiàn)過程

更新時(shí)間：2025年08月02日 10:43:43 作者：csdn_Ty

文章介紹在SpringBoot中通過自定義Lock注解、LockAspect切面和RedisLockUtils工具類實(shí)現(xiàn)分布式鎖,確保多實(shí)例并發(fā)操作的數(shù)據(jù)一致性,注解聲明式管理鎖,切面處理獲取與釋放,工具類基于Redisson操作Redis,簡(jiǎn)化鎖機(jī)制集成

Lock注解

首先，我們定義一個(gè)Lock注解，用于標(biāo)記需要加鎖的方法。這個(gè)注解包含了鎖的鍵值、超時(shí)時(shí)間和等待時(shí)間等信息。

import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
import java.util.concurrent.TimeUnit;
 
/**
 * @author tangzx
 */
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface Lock {
 
    /**
     * 鎖的鍵值
     *
     * @return 鎖的鍵值
     */
    String value() default "";
 
    /**
     * 鎖的鍵值
     *
     * @return 鎖的鍵值
     */
    String key() default "";
 
    /**
     * 超時(shí)時(shí)間
     *
     * @return 超時(shí)時(shí)間
     */
    long leaseTime() default 30L;
 
    /**
     * 等待時(shí)間
     *
     * @return 等待時(shí)間
     */
    long waitTime() default 0L;
 
    /**
     * 超時(shí)時(shí)間單位(默認(rèn)秒)
     *
     * @return 超時(shí)時(shí)間單位
     */
    TimeUnit leaseTimeTimeUnit() default TimeUnit.SECONDS;
 
    /**
     * 等待時(shí)間單位(默認(rèn)秒)
     *
     * @return 等待時(shí)間單位
     */
    TimeUnit waitTimeTimeUnit() default TimeUnit.SECONDS;
 
}

LockAspect切面

接下來，我們創(chuàng)建一個(gè)LockAspect切面類，用于處理Lock注解。

這個(gè)切面會(huì)在方法執(zhí)行前嘗試獲取鎖，如果獲取成功，則執(zhí)行方法體；如果獲取失敗，則執(zhí)行相應(yīng)的失敗邏輯。

import com.lock.core.exception.AppException;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
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.springframework.expression.Expression;
import org.springframework.expression.ExpressionParser;
import org.springframework.expression.spel.standard.SpelExpressionParser;
import org.springframework.expression.spel.support.StandardEvaluationContext;
import org.springframework.stereotype.Component;
 
import java.util.concurrent.atomic.AtomicReference;
 
/**
 * @author tangzx
 */
@Slf4j
@Aspect
@Component
public class LockAspect {
 
    @Around("@annotation(lock)")
    public Object around(ProceedingJoinPoint joinPoint, Lock lock) throws Throwable {
        String value = lock.value();
        String key = lock.key();
        long leaseTimeMs = lock.leaseTimeTimeUnit().toMillis(lock.leaseTime());
        long waitTimeMs = lock.waitTimeTimeUnit().toMillis(lock.waitTime());
        String lockKey = resolveLockKey(value, key, joinPoint);
        AtomicReference<Object> result = new AtomicReference<>(null);
        AtomicReference<Throwable> throwable = new AtomicReference<>(null);
        RedisUtils.LockOps.execute(lockKey, leaseTimeMs, waitTimeMs, () -> {
            try {
                result.set(joinPoint.proceed());
            } catch (Throwable t) {
                throwable.set(t);
            }
        }, () -> {
            AppLogger.append("未獲取到Lock鎖[{}]", lockKey);
            throw new AppException("正在處理中，請(qǐng)稍后再試");
        });
        if (null != throwable.get()) {
            throw throwable.get();
        }
        return result.get();
    }
 
    public String resolveLockKey(String lockName, String key, ProceedingJoinPoint joinPoint) {
        MethodSignature methodSignature = (MethodSignature) joinPoint.getSignature();
        String[] parameterNames = methodSignature.getParameterNames();
        Object[] args = joinPoint.getArgs();
 
        ExpressionParser parser = new SpelExpressionParser();
        Expression expression = parser.parseExpression(key);
        StandardEvaluationContext context = new StandardEvaluationContext();
        for (int i = 0; i < args.length; i++) {
            context.setVariable(parameterNames[i], args[i]);
        }
        String value = expression.getValue(context, String.class);
        if (StringUtils.isNotBlank(value)) {
            return lockName + ":" + value;
        }
        if (log.isWarnEnabled()) {
            log.warn("lockName={},根據(jù)規(guī)則[key={}],未在參數(shù)中獲取到對(duì)應(yīng)的值,默認(rèn)使用lockName作為key", lockName, key);
        }
        return lockName;
    }
 
}

RedisLockUtils工具類

最后，我們實(shí)現(xiàn)一個(gè)RedisLockUtils工具類，用于與Redis交互，實(shí)現(xiàn)鎖的獲取和釋放。

這個(gè)類會(huì)使用Redisson客戶端來簡(jiǎn)化分布式鎖的操作。

import com.redis.utils.ServiceLocator;
import lombok.extern.slf4j.Slf4j;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
 
import java.util.Optional;
import java.util.concurrent.TimeUnit;
 
/**
 * @author ：Tzx
 * @date ：Created in 2021/8/2 18:09
 * @description： redis鎖
 * @version: 1.0
 */
@Slf4j
public class RedisLockUtils {
 
    private final static String REDIS_LOCK_HANDLER_PREFIX = RedisLockUtils.class.getSimpleName().toLowerCase() + ":";
 
    private static volatile RedissonClient redissonClient;
 
    /**
     * 獲取分布式鎖執(zhí)行
     *
     * @param redisKey      redisKey
     * @param codeToExecute 獲取鎖執(zhí)行
     */
    public static void execute(String redisKey, Runnable codeToExecute) {
        execute(redisKey, null, null, codeToExecute, null);
    }
 
    /**
     * 獲取分布式鎖執(zhí)行
     *
     * @param redisKey              redisKey
     * @param codeToExecute         獲取鎖執(zhí)行
     * @param codeIfLockNotAcquired 未獲取到鎖執(zhí)行
     */
    public static void execute(String redisKey, Runnable codeToExecute, Runnable codeIfLockNotAcquired) {
        execute(redisKey, null, null, codeToExecute, codeIfLockNotAcquired);
    }
 
    /**
     * 獲取分布式鎖執(zhí)行
     *
     * @param key                   redisKey
     * @param leaseTimeMs           鎖超時(shí)時(shí)間
     * @param waitTimeMs            獲取鎖等待時(shí)間
     * @param codeToExecute         獲取鎖執(zhí)行
     * @param codeIfLockNotAcquired 未獲取到鎖執(zhí)行
     */
    public static void execute(String key, Long leaseTimeMs, Long waitTimeMs, Runnable codeToExecute, Runnable codeIfLockNotAcquired) {
        waitTimeMs = Optional.ofNullable(waitTimeMs).orElse(0L);
 
        String lockKey = REDIS_LOCK_HANDLER_PREFIX + key;
        RLock lock = getRedissonClient().getLock(lockKey);
        boolean tryLock = false;
        try {
            if (null != leaseTimeMs && leaseTimeMs > 0L) {
                tryLock = lock.tryLock(waitTimeMs, leaseTimeMs, TimeUnit.MILLISECONDS);
            } else {
                tryLock = lock.tryLock(waitTimeMs, TimeUnit.MILLISECONDS);
            }
        } catch (InterruptedException interruptedException) {
            log.warn("獲取鎖異常", interruptedException);
            Thread.currentThread().interrupt();
        }
        if (tryLock) {
            try {
                codeToExecute.run();
                return;
            } finally {
                if (lock.isHeldByCurrentThread()) {
                    lock.unlock();
                }
            }
        }
        if (log.isDebugEnabled()) {
            log.debug("未獲取到鎖[{}]", key);
        }
        Optional.ofNullable(codeIfLockNotAcquired).ifPresent(Runnable::run);
    }
 
    private static RedissonClient getRedissonClient() {
        if (null == redissonClient) {
            synchronized (RedisLockUtils.class) {
                if (null == redissonClient) {
                    redissonClient = ServiceLocator.getService(RedissonClient.class);
                }
            }
        }
        return redissonClient;
    }
 
}

下面是一個(gè)使用Lock注解的示例，展示了如何在Spring Boot應(yīng)用中實(shí)現(xiàn)分布式鎖。

假設(shè)我們有一個(gè)OrderService服務(wù)，其中包含一個(gè)方法createOrder，這個(gè)方法需要保證在多服務(wù)實(shí)例中同時(shí)只有一個(gè)能夠被執(zhí)行，以防止創(chuàng)建重復(fù)的訂單。

import org.springframework.stereotype.Service;
@Service
public class OrderService {
    @Lock(value = "order", key = "#orderId", leaseTime = 10, waitTime = 5)
    public void createOrder(String orderId) {
        // 業(yè)務(wù)邏輯，比如創(chuàng)建訂單、保存訂單等
        System.out.println("Creating order: " + orderId);
    }
}

在這個(gè)示例中，createOrder方法使用了Lock注解。當(dāng)這個(gè)方法被調(diào)用時(shí)，LockAspect切面會(huì)攔截這個(gè)調(diào)用，并嘗試獲取一個(gè)分布式鎖。鎖的鍵值是由key屬性的SpEL表達(dá)式計(jì)算得出的，這里使用了方法的參數(shù)orderId。leaseTime和waitTime分別設(shè)置了鎖的超時(shí)時(shí)間和等待時(shí)間。

當(dāng)多個(gè)服務(wù)實(shí)例嘗試同時(shí)創(chuàng)建同一個(gè)訂單時(shí)，由于分布式鎖的存在，只有一個(gè)實(shí)例能夠成功執(zhí)行createOrder方法，其他實(shí)例將會(huì)在等待一段時(shí)間后失敗，或者執(zhí)行Lock注解中定義的失敗邏輯。

這種使用注解的方式，使得分布式鎖的集成變得非常簡(jiǎn)單和直觀。開發(fā)者不需要關(guān)心鎖的具體實(shí)現(xiàn)細(xì)節(jié)，只需要在需要加鎖的方法上添加Lock注解，并設(shè)置相應(yīng)的參數(shù)即可。

通過這三個(gè)組件，我們可以在Spring Boot應(yīng)用中非常優(yōu)雅地實(shí)現(xiàn)分布式鎖。Lock注解提供了一種聲明式的方式，讓開發(fā)者可以輕松地為方法添加分布式鎖。LockAspect切面確保了鎖的邏輯在方法執(zhí)行前后被正確地處理。而RedisLockUtils工具類則負(fù)責(zé)與Redis交互，確保鎖的原子性和一致性。

在實(shí)現(xiàn)這些組件時(shí)，我們還需要注意一些細(xì)節(jié)，比如如何處理鎖的鍵值解析、如何處理鎖獲取失敗的情況、如何確保鎖的釋放等。