Redis锁与幂等性不得不说的故事

news2025/7/21 10:27:18

前言：

相信很多小伙伴对缓存锁都不陌生，但是简单的缓存锁想要用好还是需要一些功力。本文总结了笔者多年使用缓存所的一些心得，欢迎交流探讨~

幂等模型：

幂等场景一般由查重+写入两步操作组成，两步操作组成一个最小完整逻辑，再通过缓存锁保证原子性

实现：

实现redis分布式锁需要注意两个关键点：保证原子性、设置过期时间

保证原子性的目的：是为了保证同一时间只有一个请求能获取到锁

设置过期时间的目的：是为了防止解锁失败导致死锁

public class MethodLock {

    private static final Logger logger = LoggerFactory.getLogger(MethodLock.class);

    public static final String KEY_SEPARATOR = ":";
    public static final String PARAM_SEPARATOR = "_";
    public static final String KEY_PARAM_SEPARATOR = "#";
    public static final String SET_SUCCESS_RESULT = "OK";
    public static final String METHOD_LOCK = "doraemon:method:lock";


    private static Jedis jedis;

    private static Jedis getJedis() {
        if (jedis == null) {
            jedis = 自行实现;
        }
        return jedis;
    }


    /**
     * 获取锁
     *
     * @param methodName 方法名，类名加方法名（例：MethodLock.getLock）
     * @param timeout    锁过期时间（单位秒）
     * @param params     参数（通过参数控制锁的粒度）
     * @return
     */
    public static boolean getLock(String methodName, long timeout, String... params) {
        String method = "getLock|获取锁|";

        try {
            String key = getKey(methodName, params);
            String result = getJedis().set(key, methodName, "nx", "ex", timeout <= 0 ? 5 : timeout);
            if (Objects.equals(SET_SUCCESS_RESULT, result)) {
                return true;
            }
        } catch (Exception e) {
            logger.error(method + "执行失败,methodName={},timeout={},params={}", methodName, timeout, JSONObject.toJSONString(params), e);
        }

        return false;
    }

    /**
     * 释放锁
     *
     * @param methodName 方法名，类名加方法名（例：MethodLock.getLock）
     * @param params     参数（通过参数控制锁的粒度）
     * @return
     */
    public static boolean delLock(String methodName, String... params) {
        String method = "delLock|释放锁|";

        try {
            String key = getKey(methodName, params);
            long result = getJedis().del(key);
            if (result > 0) {
                return true;
            }
        } catch (Exception e) {
            logger.error(method + "执行失败,methodName={},params={}", methodName, JSONObject.toJSONString(params), e);
        }

        return false;
    }

    /**
     * 【私有方法】获取redis key
     *
     * @param methodName
     * @param params
     * @return
     */
    protected static String getKey(String methodName, String... params) {
        if (StringUtils.isBlank(methodName)) {
            return null;
        }
        String key = METHOD_LOCK + KEY_SEPARATOR + methodName;
        if (params != null && params.length > 0) {
            key += KEY_PARAM_SEPARATOR + Joiner.on(PARAM_SEPARATOR).useForNull("null").join(params);
        }
        return key;
    }