Redis实现全局唯一id的使用示例

目录

• 一、全局ID生成器
• 二、原理 
• 三、样例代码

一、全局ID生成器

全局ID生成器，是一种在分布式系统下用来生成全局唯一ID的工具，一般要满足下列特性：

二、原理 

为了增加ID的安全性，我们可以不直接使用Redis自增的数值，而是拼接一些其它信息：

 

ID的组成部分：

符号位：永远为0。

时间戳：31bit，以秒为单位，可以使用69年。

序列号：32bit，秒内的计数器，支持每秒产生2^32个不同ID。

三、样例代码

ID生成器代码：

@Component
public class RedisIdworker {
    //开始时间戳
    private static final long BEGIN_TIMESTAMP = 1640995200L;
    @Resource
    prphpivate StringRedisTemplate stringRedisTemplate;
    public long nextId(String KeyPrefix){
        //生成时间戳
        LocalDateTime now = LocalDateTime.now();
        long nowSecond = now.toEpochSecohttp://www.devze.comnd(ZoneOffset.UTC);
        long timestamp = nowSecond - BEGIN_TIMESTAMP;
        //生成序列号
        //获取当前格式，精确到天
        String date = now.format(DateTimeFormatter.ofPatte编程客栈rn("yyyyMMdd"));
        Long count = stringRedisTemplate.opsForValue().increment("icr:" + KeyPrefix + ":" + date);
    js    //拼接并返回
        //位运算，时间戳向左移动32位，右边空出的0用序列号补充，可以用或运算填充
        return timestamp << 32 | count;
    }
    public static void main(String[] args) {
        LocalDateTime time = LocalDateTime.of(2022, 1, 1, 0, 0, 0);
        long second = time.toEpochSecond(ZoneOffset.UTC);
        System.out.println(second);
    }
}

测试代码：

    @Resource
    private RedisIdWorker redisIdWorker;
    private ExecutorService es = Executors.newFixedThreadPool(500);php
    @Test
    void testIdWorker() throws InterruptedException {
        CountDownLatch latch = new CountDownLatch(300);
        Runnable task = () ->{
            for(int i = 0; i<100 ;i++){
                long id = redisIdWorker.nextId("order");
                System.out.println(id);
            }
            latch.countDown();
        };
        long begin = System.currentTimeMillis();
        for (int i = 0; i<300 ;i++){
            es.submit(task);
        }
        latch.await();
        long end = System.currentTimeMillis();
        System.out.println(end - begin);
    }

到此这篇关于Redis实现全局唯一id的使用示例的文章就介绍到这了,更多相关Redis 全局唯一id内容请搜索编程客栈(www.devze.com)以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程客栈(www.devze.com)！