redis 分布式锁 java 代码

当使用 Redis 实现分布式锁时，可以借助 Redis 的 SETNX（SET if Not eXists）命令来实现。下面是一个简单的 Java 代码示例：

import redis.clients.jedis.Jedis;

public class RedisDistributedLock {
    private Jedis jedis;
    private static final String LOCK_KEY = "my_lock";
    private static final int LOCK_EXPIRE_TIME = 30000; // 锁的过期时间，单位毫秒

    public RedisDistributedLock() {
        jedis = new Jedis("localhost", 6379); // 连接 Redis 服务器
    }

    public boolean acquireLock(String requestId) {
        long startTime = System.currentTimeMillis();
        try {
            while ((System.currentTimeMillis() - startTime) < LOCK_EXPIRE_TIME) {
                String result = jedis.set(LOCK_KEY, requestId, "NX", "PX", LOCK_EXPIRE_TIME);
                if ("OK".equals(result)) {
                    return true; // 获取锁成功
                }
                Thread.sleep(100); // 休眠一段时间后重试
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return false; // 获取锁失败
    }

    public void releaseLock(String requestId) {
        try {
            String lockValue = jedis.get(LOCK_KEY);
            if (requestId.equals(lockValue)) {
                jedis.del(LOCK_KEY);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public static void main(String[] args) {
        RedisDistributedLock lock = new RedisDistributedLock();
        String requestId = "123456"; // 每个请求的唯一标识，可以使用 UUID 等方式生成
        if (lock.acquireLock(requestId)) {
            try {
                // 执行业务逻辑
                System.out.println("获取到锁，执行业务逻辑...");
                Thread.sleep(5000); // 模拟业务处理时间
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                lock.releaseLock(requestId);
                System.out.println("释放锁");
            }
        } else {
            System.out.println("获取锁失败");
        }
    }
}

在上面的代码中，`acquireLock` 方法尝试获取分布式锁，如果获取成功则返回 `true`，否则返回 `false`。`releaseLock` 方法用于释放锁。

需要注意的是，在实际生产环境中，还需要考虑异常情况下的锁释放、锁的可重入性、锁的自动续期等问题。上述代码仅为简单示例，具体实现可能因项目需求而异。