【Java】使用Redis 实现自增流水号

import redis.clients.jedis.Jedis;
 
public class RedisSequence {
    private Jedis jedis;
    private String keyPrefix;
    private int increment;
 
    public RedisSequence(Jedis jedis, String keyPrefix, int increment) {
        this.jedis = jedis;
        this.keyPrefix = keyPrefix;
        this.increment = increment;
    }
 
    public synchronized long nextVal() {
        String key = keyPrefix;
        long currentVal = jedis.incrBy(key, increment);
        return currentVal;
    }
 
    public static void main(String[] args) {
        // 假设已经创建了 Jedis 实例并且连接到了 Redis 服务器
        Jedis jedis = new Jedis("localhost", 6379);
        RedisSequence sequence = new RedisSequence(jedis, "order_id", 1);
 
        // 获取并打印出五个序列号
        for (int i = 0; i < 5; i++) {
            System.out.println("Next sequence number: " + sequence.nextVal());
        }
 
        // 关闭 Jedis 连接
        jedis.close();
    }
}

这段代码使用Redis的INCRBY命令来实现自增流水号。RedisSequence类封装了自增流水号的逻辑，其中nextVal方法负责获取下一个流水号。main方法展示了如何使用RedisSequence类来获取序列号。在实际应用中，需要确保Jedis实例已经正确连接到Redis服务器，并且在使用完毕后关闭连接。