基于setnx,lua脚本和Redisson详解Redis分布式锁实现的三种方式

@resource
private stringredistemplate stringredistemplate;
/**
 * 示例：扣减库存（基础分布式锁实现）
 */
private void order(){
    // 1. 生成唯一锁值（用于校验锁归属，避免误删）
    string lockvalue = uuid.randomuuid().tostring();
    // 2. 加锁：setnx + 过期时间（原子操作），30秒自动释放
    boolean locked = stringredistemplate.opsforvalue()
            .setifabsent("product:1001:lock", lockvalue, 30, timeunit.seconds);
    try {
        // 3. 加锁成功则执行业务逻辑（扣减库存）
        if (locked) {
            integer count = (integer) stringredistemplate.opsforhash().get("product:1001","number");
            if (count > 0) {
                stringredistemplate.opsforhash().put("product:1001", "number", count - 1);
            }
        }
    } finally {
        // 4. 释放锁：先校验锁归属，再删除（非原子操作）
        if (lockvalue.equals(stringredistemplate.opsforvalue().get("product:1001:lock"))) {
            stringredistemplate.delete("product:1001:lock");
        }
    }
}

@resource
private stringredistemplate stringredistemplate;
private static final string lock_key = "product:1001:lock";
private static final string stock_key = "product:1001:number";
private static final long lock_timeout = 30; // 锁超时时间（秒）
private static final long sleep_time = 100; // 重试间隔（毫秒）
private void order() {
    string lockvalue = uuid.randomuuid().tostring();
    try {
        // 1. 尝试获取锁（原子加锁）
        boolean locked = tryacquirelock(lockvalue);
        if (!locked) {
            // 加锁失败可重试/返回失败（示例直接返回，实际可加循环重试）
            return;
        }
        // 2. 执行业务：获取并扣减库存（简化为string结构，避免hash类型转换问题）
        string stockstr = stringredistemplate.opsforvalue().get(stock_key);
        if (stockstr == null || integer.parseint(stockstr) <= 0) {
            return;
        }
        stringredistemplate.opsforvalue().set(stock_key, string.valueof(integer.parseint(stockstr) - 1));
    } finally {
        // 3. 释放锁：lua脚本封装“校验+删除”，保证原子性
        releaselock(lockvalue);
    }
}
/**
 * 原子加锁：set nx ex
 */
private boolean tryacquirelock(string lockvalue) {
    return stringredistemplate.opsforvalue()
            .setifabsent(lock_key, lockvalue, lock_timeout, timeunit.seconds);
}
/**
 * 原子释放锁：lua脚本
 */
private void releaselock(string lockvalue) {
    string script = "if redis.call('get', keys[1]) == argv[1] then " +
            "return redis.call('del', keys[1]) " +
            "else " +
            "return 0 " +
            "end";
    stringredistemplate.execute(
            new defaultredisscript<>(script, long.class),
            arrays.aslist(lock_key),
            lockvalue
    );
}

@resource
private redissonclient redissonclient;
@resource
private stringredistemplate stringredistemplate;
private void order() {
    // 1. 获取分布式锁对象（可重入锁）
    rlock lock = redissonclient.getlock("product:1001:lock");
    try {
        // 2. 加锁：最多等待10秒，锁30秒后自动释放；获取锁成功则执行业务
        if (lock.trylock(10, 30, timeunit.seconds)) {
            try {
                // 3. 扣减库存业务逻辑
                integer count = (integer) stringredistemplate.opsforhash().get("product:1001","number");
                if (count != null && count > 0) {
                    stringredistemplate.opsforhash().put("product:1001", "number", count - 1);
                }
            } finally {
                // 4. 手动释放锁（若业务执行完未超时，主动释放）
                lock.unlock();
            }
        }
    } catch (interruptedexception e) {
        // 5. 中断异常处理，恢复线程中断状态
        thread.currentthread().interrupt();
    }
}