![cover](https://img-blog.csdnimg.cn/a00f8e84ae234139bd1db4fa98babe73.png)
Redis生成全局唯一ID
简介:全局唯一ID生成器是一种在分布式系统下用来生成全局唯一ID的工具特性:唯一性高性能安全性高可用递增性生成规则:有时为了增加ID的安全性,我们可以不直接使用Redis自增的数值,而是拼接一些其他信息ID组成部分:符号位:1bit,永远为0时间戳:31bit,以秒为单位,可以使用69年序列号:32bit,秒内的计数器,支持每秒产生2^32个不同IDID生成类:package com.exampl
简介:
全局唯一ID生成器是一种在分布式系统下用来生成全局唯一ID的工具
特性:
唯一性
高性能
安全性
高可用
递增性
生成规则:
有时为了增加ID的安全性,我们可以不直接使用Redis自增的数值,而是拼接一些其他信息
ID组成部分:
- 符号位:1bit,永远为0
- 时间戳:31bit,以秒为单位,可以使用69年
- 序列号:32bit,秒内的计数器,支持每秒产生2^32个不同ID
ID生成类:
package com.example.util;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Component;
import java.time.LocalDateTime;
import java.time.ZoneOffset;
import java.time.format.DateTimeFormatter;
/**
* @Author DaBai
* @Date 2022/3/17 下午 09:25
* @Version 1.0
*/
@Component
public class RedisIDWorker {
private static final long BEGIN_TIMESTAMP = 1640995200L;
/**
* 序列号位数
*/
private static final int COUNT_BITS = 32;
private StringRedisTemplate stringRedisTemplate;
public RedisIDWorker(StringRedisTemplate stringRedisTemplate) {
this.stringRedisTemplate = stringRedisTemplate;
}
public long nextID(String keyPrefix) {
//1、生成时间戳
LocalDateTime now = LocalDateTime.now();
long nowScond = now.toEpochSecond(ZoneOffset.UTC);
long timestamp = nowScond - BEGIN_TIMESTAMP;
//2、生成序列号
// 2.1 获取当前日期,精确到天
String date = now.format(DateTimeFormatter.ofPattern("yyyy:MM:dd"));
long count = stringRedisTemplate.opsForValue().increment("icr" + keyPrefix + ":" + date);
//3、拼接字符串
// 时间戳左移32位,然后 或 序列号,有1为1
long ids = timestamp << COUNT_BITS | count;
return ids;
}
测试类:
@Resource
RedisIDWorker redisIDWorker;
private ExecutorService es = Executors.newFixedThreadPool(500);
@Test
public void ShowID() throws InterruptedException {
CountDownLatch countDownLatch = new CountDownLatch(300);
Runnable task = () -> {
for (int i = 0; i < 100; i++) {
long id = redisIDWorker.nextID("order");
System.out.println("id = " + id);
}
countDownLatch.countDown();
};
long startTime = System.currentTimeMillis();
for (int i = 0; i < 300; i++) {
es.submit(task);
}
countDownLatch.await();
long end = System.currentTimeMillis();
System.out.println("time = " + (end - startTime));
}
更多推荐
所有评论(0)