java redis分布式锁 demo

### 回答1：
以下是一个简单的Java代码示例，该代码使用Redis实现分布式锁：

import redis.clients.jedis.Jedis;

public class RedisDistributedLock {
    private Jedis jedis;

    public RedisDistributedLock(Jedis jedis) {
        this.jedis = jedis;
    }

    public boolean lock(String key) {
        // 使用setnx命令实现加锁
        // 如果返回值为1，说明获取锁成功
        return jedis.setnx(key, "1") == 1;
    }

    public void unlock(String key) {
        // 释放锁只需要删除key
        jedis.del(key);
    }
}

使用方法：

Jedis jedis = new Jedis("localhost");
RedisDistributedLock lock = new RedisDistributedLock(jedis);

if (lock.lock("my-key")) {
    try {
        // 获取锁成功，执行业务逻辑
    } finally {
        lock.unlock("my-key");
    }
} else {
    // 获取锁失败，执行其他操作
}

这只是一个简单的示例，实际应用中可能需要考虑超时释放锁、防止死锁等因素。

### 回答2：
Java Redis分布式锁demo可以通过使用Redis的SET命令和EX命令（带有过期时间）来实现。

1. 首先，在Java中引入Redis的Java客户端依赖，例如Jedis或Lettuce。

2. 初始化Redis连接池，创建Redis连接。

3. 编写获取分布式锁的方法，以下是一个简单的示例代码：

import redis.clients.jedis.Jedis;

public class RedisLockDemo {

    private static final String LOCK_KEY = "myLock";
    private static final int LOCK_EXPIRE_TIME = 10; // 锁的过期时间，单位秒

    private Jedis jedis;

    public RedisLockDemo() {
        // 初始化Redis连接池和连接
        jedis = new Jedis("localhost");
    }

    public boolean acquireLock() {
        Long result = jedis.setnx(LOCK_KEY, "locked");
        if (result == 1) {
            // 设置锁的过期时间
            jedis.expire(LOCK_KEY, LOCK_EXPIRE_TIME);
            return true;
        }
        return false;
    }

    public void releaseLock() {
        jedis.del(LOCK_KEY);
    }

    public static void main(String[] args) {
        RedisLockDemo demo = new RedisLockDemo();
        if (demo.acquireLock()) {
            try {
                // 成功获取到锁，执行相应的业务逻辑
                System.out.println("执行业务逻辑...");
            } finally {
                demo.releaseLock();
            }
        } else {
            // 未能获取到锁，可以进行相应的处理
            System.out.println("获取锁失败，执行其他逻辑...");
        }
    }
}

以上代码中，`acquireLock`方法通过Redis的`SETNX`命令尝试从Redis获取锁，如果返回值为1表示成功获取到锁，然后再使用`EXPIRE`命令设置锁的过期时间。`releaseLock`方法则是通过`DEL`命令释放锁。

在`main`方法中，调用`acquireLock`方法获取锁，并在成功获取到锁后执行相应的业务逻辑，最后通过`releaseLock`方法释放锁。

通过以上的简单示例代码，可以实现Java Redis分布式锁的功能。

### 回答3：
Java Redis分布式锁是一种解决多个进程或线程之间访问共享资源时可能发生竞争条件的方法。通过使用Redis作为分布式锁的后端存储，可以确保在任何给定时间只有一个进程或线程可以访问共享资源。

下面是一个Java Redis分布式锁的简单演示示例：

import redis.clients.jedis.Jedis;
import redis.clients.jedis.params.SetParams;

public class RedisDistributedLockDemo {
    // Redis连接信息
    private static final String HOST = "localhost";
    private static final int PORT = 6379;

    // 锁的名称
    private static final String LOCK_NAME = "mylock";

    // 锁的过期时间（毫秒）
    private static final long LOCK_EXPIRE_TIME = 5000;

    public static void main(String[] args) {
        // 创建Redis连接
        Jedis jedis = new Jedis(HOST, PORT);

        // 尝试获取锁
        boolean acquired = acquireLock(jedis);

        if (acquired) {
            // 获取到了锁，执行业务逻辑
            try {
                System.out.println("获得了锁，开始执行业务逻辑");
                Thread.sleep(2000); // 模拟业务逻辑执行时间
            } catch (InterruptedException e) {
                e.printStackTrace();
            } finally {
                // 释放锁
                releaseLock(jedis);
            }
        } else {
            // 没有获取到锁，输出错误信息
            System.out.println("未获得锁，执行其他逻辑");
        }

        // 关闭Redis连接
        jedis.close();
    }

    private static boolean acquireLock(Jedis jedis) {
        // 尝试获取锁并设置过期时间
        SetParams params = SetParams.setParams().nx().px(LOCK_EXPIRE_TIME);
        String result = jedis.set(LOCK_NAME, "locked", params);

        return result != null && result.equals("OK");
    }

    private static void releaseLock(Jedis jedis) {
        // 释放锁
        jedis.del(LOCK_NAME);
    }
}

这个演示示例使用Redis的`set`命令来获取锁，并设置了锁的过期时间，以防止死锁的情况。如果成功获取到锁并执行了业务逻辑，最后释放锁。

总结起来，Java Redis分布式锁的实现主要涉及到以下几个步骤：
1. 创建Redis连接
2. 尝试获取锁
3. 如果成功获取到锁，则执行业务逻辑
4. 释放锁
5. 关闭Redis连接

通过这种方式，我们可以确保在分布式环境中的各个进程或线程之间共享资源的安全访问，避免竞争条件的发生。