使用Redis轻松获取自增式ID（redis自增式id）

使用Redis轻松获取自增式ID

Redis是一种基于内存的键值数据库，最初被设计用于处理高并发的Web应用场景。它支持多种数据结构，如字符串、哈希表、列表、集合等，并提供了丰富的命令集用于操作这些数据结构。其中，Redis提供的自增命令INCR可以很方便地生成自增式ID，这对于需要频繁创建唯一ID的应用场景非常有用。

在本文中，我们将介绍如何使用Redis生成自增式ID，并提供一些易于实践的Java代码示例。

Redis自增命令INCR

Redis提供了自增命令INCR，它的作用是将一个键值加1并返回增加后的值。如果该键不存在，则会自动创建该键，并将其值初始化为0。因此，我们可以使用INCR命令来实现自增式的ID。

以下是使用INCR命令生成自增ID的示例代码：

import redis.clients.jedis.Jedis;
public class RedisUtils {

    private static final String REDIS_HOST = "127.0.0.1";
    private static final int REDIS_PORT = 6379;
    private static final String ID_NAME = "global:id";

    private static Jedis jedis;

    static {
        jedis = new Jedis(REDIS_HOST, REDIS_PORT);
    }

    public static long getNextId() {
        return jedis.incr(ID_NAME);
    }
}

在上面的代码中，我们使用了Jedis客户端连接到Redis数据库，并定义了一个名为global:id的键来存储自增式ID。getNextId方法调用INCR命令并返回自增后的值。使用该方法可以轻松地生成自增ID，并且使用Redis可以保证ID的唯一性。

使用Redis实现分布式自增ID

上文中介绍的示例使用了单个Redis实例来生成自增ID，这个方案不适用于分布式系统。在分布式场景下，我们需要保证生成的ID是全局唯一的，并且不会有重复。为此，我们需要使用Redis的分布式锁机制，确保每个节点生成的ID是唯一的。

以下是使用Redis实现分布式自增ID的示例代码：

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

public class RedisUtils {

    private static final String REDIS_HOST = "127.0.0.1";
    private static final int REDIS_PORT = 6379;
    private static final String ID_NAME = "global:id";
    private static final SetParams LOCK_PARAMS = new SetParams().nx().ex(60);
    //设置分布式锁的参数：nx表示如果键不存在则设置值，ex表示过期时间为60秒

    private static Jedis jedis;

    static {
        jedis = new Jedis(REDIS_HOST, REDIS_PORT);
    }

    public static long getNextId() {
        String lockKey = ID_NAME + ":lock";
        while (true) {
            String lockValue = Thread.currentThread().getId() + ":" + System.currentTimeMillis();
            String result = jedis.set(lockKey, lockValue, LOCK_PARAMS);
            if ("OK".equals(result)) {
                long id = jedis.incr(ID_NAME);
                jedis.del(lockKey);
                return id;
            } else {
                try {
                    Thread.sleep(100);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}