简单实用！利用Redis轻松实现高并发全局ID生成器

Redis作为高性能的KV数据库，并且操作还是原子性的，所以用来做支持高并发的发号器十分合适。

本文给大家介绍3种常见的全局ID生成方式。

1、全局递增ID

目标：一直递增的全局ID。

/**
* 一直递增的全局id
*
* @param redisTemplate redis客户端对象
* @param busId         业务id，可以按需配置
* @param step          步长，即每次递增的间隔
*/
publicstaticStringgetNo(RedisTemplate<String, Object>redisTemplate, StringbusId, intstep) {
//保存redis中的key，注意不要重复
StringredisKey="uniqueNo_";
//利用increment即redis原生incrBy命令的原子性特性生成递增的序列号
Longincrement=redisTemplate.opsForValue().increment(redisKey, step);
if (increment==null) {
thrownewRuntimeException("redis命令执行失败");
  }
//业务id+递增id，如果需要纯数字，去掉业务id即可
returnbusId+increment;
}

2、以天为分割的全局ID

目标：生成格式为 yyyyMMdd + 递增序列号的全局ID。

/**
* 以天为间隔的递增序列号
* @param redisTemplate redis客户端对象
* @param busId 业务id，可以按需配置
* @param step 步长，即每次递增的间隔
*/
publicstaticStringgetNo(RedisTemplate<String, Object>redisTemplate, StringbusId, intstep) {
//当天日期，比如20221226
Stringdate=LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyyMMdd"));
//保存redis中的key，注意不要重复
StringredisKey="uniqueNo_"+date;
//利用increment即redis原生incrBy命令的原子性特性生成递增的序列号
Longincrement=redisTemplate.opsForValue().increment(redisKey, step);
if (increment==null) {
thrownewRuntimeException("redis命令执行失败");
  }
if (step==increment.intValue()) {
//首次执行时，给redisKey设置ttl，第二天这个key就可以被redis自动删除
redisTemplate.expire(redisKey, 25, TimeUnit.HOURS);
  }
//组合  20221226 + 业务id + 0001(可以根据需要自由调整序列号的长度)
returndate+busId+String.format("%04d", increment);
}

3、批量获取ID

有时我们需要批量的获取递增ID，比如给一批订单号设置ID。

/**
* 批量获取id
*
* @param redisTemplate redis客户端对象
* @param busId         业务id，可以按需配置
* @param size          获取的id个数，与步长类似
*/
publicstaticList<String>getNoByGroup(RedisTemplate<String, Object>redisTemplate, StringbusId, intsize) {
//保存redis中的key，注意不要重复
StringredisKey="uniqueNo_group";
//设置步长为size，相当于一次性申请size个id
Longincrement=redisTemplate.opsForValue().increment(redisKey, size);
if (increment==null) {
thrownewRuntimeException("redis命令执行失败");
  }
longbegin=increment-Long.parseLong(size+"");
List<String>rs=newArrayList<>();
for (longi=begin+1; i<=increment; i++) {
rs.add(busId+i);
  }
returnrs;
}