RedisTemplate 实现基于Value 操作的简易锁机制(示例代码)

import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import org.springframework.stereotype.Component;
import java.util.concurrent.TimeUnit;
@Component
public class DistributedLockService {
    private final RedisTemplate<String, String> redisTemplate;
    public DistributedLockService(RedisTemplate<String, String> redisTemplate) {
        this.redisTemplate = redisTemplate;
    }
    /**
     * 尝试获取锁。
     * @param lockKey 锁的key
     * @param requestId 请求标识，用于解锁时验证
     * @param expireTime 超时时间，单位秒
     * @return 是否获取锁成功
     */
    public boolean tryLock(String lockKey, String requestId, long expireTime) {
        ValueOperations<String, String> operations = redisTemplate.opsForValue();
        Boolean isLockSuccess = operations.setIfAbsent(lockKey, requestId, expireTime, TimeUnit.SECONDS);
        return Boolean.TRUE.equals(isLockSuccess);
    }
    /**
     * 释放锁。
     * @param lockKey 锁的key
     * @param requestId 请求标识，需与加锁时一致
     * @return 是否释放锁成功
     */
    public boolean releaseLock(String lockKey, String requestId) {
        String currentValue = redisTemplate.opsForValue().get(lockKey);
        if (requestId.equals(currentValue)) {
            redisTemplate.delete(lockKey);
            return true;
        }
        return false;
    }
    // 示例使用
    public void doSomethingUnderLock(String lockKey) {
        String requestId = UUID.randomUUID().toString(); // 生成唯一请求ID
        if (tryLock(lockKey, requestId, 5)) { // 尝试获取锁，超时5秒
            try {
                // 执行受保护的代码逻辑
                System.out.println("执行业务逻辑...");
            } finally {
                // 无论是否执行成功都尝试释放锁
                releaseLock(lockKey, requestId);
            }
        } else {
            System.out.println("获取锁失败，操作被跳过。");
        }
    }
}