java中雪花算法时钟回拨问题解决

 更新时间:2024年10月30日 11:11:47   作者:需要重新演唱  
本文介绍了分布式系统中使用雪花算法生成唯一ID时可能遇到的时钟回拨问题,以及解决这个问题的几种方法,包括等待机制、扩展位、预留时间戳或逻辑时钟等,感兴趣的可以了解一下

雪花算法(Snowflake)是Twitter开源的一种分布式唯一ID生成算法,用于在分布式系统中生成全局唯一的ID。雪花算法生成的ID是一个64位的整数,通常表示为长整型(long)。

雪花算法的结构

雪花算法生成的ID由以下几部分组成:

  • 符号位(1位):始终为0,保证生成的ID为正数。
  • 时间戳(41位):记录生成ID的时间戳,精确到毫秒级。可以使用大约69年的时间。
  • 机器ID(10位):标识生成ID的机器,可以支持1024台机器。
  • 序列号(12位):同一毫秒内生成的多个ID的序列号,可以支持每毫秒生成4096个ID。

时钟回拨问题

时钟回拨问题是指在分布式系统中,由于各种原因(如NTP时间同步),某些节点的系统时间可能会回退到过去的时间点。这会导致雪花算法生成的ID出现重复,因为时间戳部分会重复。

解决时钟回拨问题的方法

  • 等待机制

    • 当检测到时钟回拨时,生成器可以等待时间追上上次生成ID的时间戳,然后再生成新的ID。这种方法简单直接,但可能会导致生成器在等待期间无法生成新的ID。
  • 扩展位

    • 在ID结构中增加额外的位来处理时钟回拨。例如,可以使用额外的位来记录时钟回拨的次数,从而避免ID重复。
  • 预留时间戳

    • 在生成ID时,预留一些时间戳范围,用于处理时钟回拨。例如,可以预留一些时间戳范围,当检测到时钟回拨时,使用预留的时间戳生成新的ID。
  • 逻辑时钟

    • 使用逻辑时钟(如Lamport时钟或Vector时钟)代替物理时钟。逻辑时钟可以保证在分布式系统中事件的顺序,避免时钟回拨问题。

示例代码

以下是一个使用等待机制解决时钟回拨问题的雪花算法实现示例:

public class SnowflakeIdGenerator {
    private final long twepoch = 1288834974657L; // 起始时间戳,例如Twitter的Snowflake起始时间
    private final long workerIdBits = 10L;
    private final long maxWorkerId = -1L ^ (-1L << workerIdBits);
    private final long sequenceBits = 12L;
    private final long workerIdShift = sequenceBits;
    private final long timestampLeftShift = sequenceBits + workerIdBits;
    private final long sequenceMask = -1L ^ (-1L << sequenceBits);

    private long workerId;
    private long sequence = 0L;
    private long lastTimestamp = -1L;

    public SnowflakeIdGenerator(long workerId) {
        if (workerId > maxWorkerId || workerId < 0) {
            throw new IllegalArgumentException(String.format("worker Id can't be greater than %d or less than 0", maxWorkerId));
        }
        this.workerId = workerId;
    }

    public synchronized long nextId() {
        long timestamp = timeGen();

        if (timestamp < lastTimestamp) {
            // 时钟回拨,等待时间追上
            long offset = lastTimestamp - timestamp;
            if (offset <= 5) {
                try {
                    wait(offset << 1);
                    timestamp = timeGen();
                    if (timestamp < lastTimestamp) {
                        throw new RuntimeException(String.format("Clock moved backwards. Refusing to generate id for %d milliseconds", offset));
                    }
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }
            } else {
                throw new RuntimeException(String.format("Clock moved backwards. Refusing to generate id for %d milliseconds", offset));
            }
        }

        if (lastTimestamp == timestamp) {
            sequence = (sequence + 1) & sequenceMask;
            if (sequence == 0) {
                timestamp = tilNextMillis(lastTimestamp);
            }
        } else {
            sequence = 0L;
        }

        lastTimestamp = timestamp;

        return ((timestamp - twepoch) << timestampLeftShift) |
                (workerId << workerIdShift) |
                sequence;
    }

    protected long tilNextMillis(long lastTimestamp) {
        long timestamp = timeGen();
        while (timestamp <= lastTimestamp) {
            timestamp = timeGen();
        }
        return timestamp;
    }

    protected long timeGen() {
        return System.currentTimeMillis();
    }

    public static void main(String[] args) {
        SnowflakeIdGenerator idGenerator = new SnowflakeIdGenerator(1);
        System.out.println(idGenerator.nextId());
    }
}

代码解释

  • 检测时钟回拨

    • 在生成ID时,首先获取当前时间戳,并与上次生成ID的时间戳进行比较。
    • 如果当前时间戳小于上次生成ID的时间戳,说明发生了时钟回拨。
  • 等待机制

    • 如果时钟回拨的时间差小于等于5毫秒,生成器会等待时间追上上次生成ID的时间戳。
    • 如果时钟回拨的时间差大于5毫秒,抛出异常,拒绝生成ID。
  • 生成新的ID

    • 如果时钟没有回拨,或者等待时间追上后,生成新的ID。

总结

时钟回拨问题是分布式系统中使用雪花算法生成唯一ID时需要解决的一个重要问题。通过使用等待机制、扩展位、预留时间戳或逻辑时钟等方法,可以有效避免时钟回拨导致的ID重复问题。在实际应用中,可以根据具体需求选择合适的解决方案。

到此这篇关于java中雪花算法时钟回拨问题解决的文章就介绍到这了,更多相关java 雪花算法时钟回拨内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • Java中调用SQL Server存储过程详解

    Java中调用SQL Server存储过程详解

    这篇文章主要介绍了Java中调用SQL Server存储过程详解,本文讲解了使用不带参数的存储过程、使用带有输入参数的存储过程、使用带有输出参数的存储过程、使用带有返回状态的存储过程、使用带有更新计数的存储过程等操作实例,需要的朋友可以参考下
    2015-01-01
  • Java Spring事务使用及验证过程详解

    Java Spring事务使用及验证过程详解

    这篇文章主要介绍了Java Spring事务使用及验证过程详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-12-12
  • java如何去除图片中的白色背景

    java如何去除图片中的白色背景

    这篇文章主要为大家详细介绍了java去除图片中白色背景的方法,教大家如何将图片中的白色背景去掉,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2018-04-04
  • 参数校验Spring的@Valid注解用法解析

    参数校验Spring的@Valid注解用法解析

    这篇文章主要介绍了参数校验Spring的@Valid注解用法,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-08-08
  • SpringBoot集成xxl-job实现超牛的定时任务的步骤详解

    SpringBoot集成xxl-job实现超牛的定时任务的步骤详解

    XXL-JOB是一个分布式任务调度平台,其核心设计目标是开发迅速、学习简单、轻量级、易扩展,现已开放源代码并接入多家公司线上产品线,开箱即用,本文给大家介绍了SpringBoot集成xxl-job实现超牛的定时任务,需要的朋友可以参考下
    2023-10-10
  • 使用jenv工具管理多个JDK版本的方法步骤

    使用jenv工具管理多个JDK版本的方法步骤

    jenv是一个开源的 Java 环境管理工具,旨在帮助开发者在同一台机器上轻松管理和切换多个Java版本,这篇文章主要介绍了使用jenv工具管理多个JDK版本的方法步骤,需要的朋友可以参考下
    2025-06-06
  • 老生常谈java中的数组初始化

    老生常谈java中的数组初始化

    下面小编就为大家带来一篇老生常谈java中的数组初始化。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-04-04
  • Java 实战项目之诚途旅游系统的实现流程

    Java 实战项目之诚途旅游系统的实现流程

    读万卷书不如行万里路,只学书上的理论是远远不够的,只有在实战中才能获得能力的提升,本篇文章手把手带你用java+SpringBoot+Vue+maven+Mysql实现一个精美的物流管理系统,大家可以在过程中查缺补漏,提升水平
    2021-11-11
  • 微信公众号开发消息推送功能

    微信公众号开发消息推送功能

    微信公众号分为服务号、订阅号、企业号,订阅号可以个人申请,服务号和企业号要有企业资质才可以,这篇文章主要介绍了微信公众号开发消息推送功能,需要的朋友可以参考下
    2023-02-02
  • java实现线程阻塞式方法

    java实现线程阻塞式方法

    Java阻塞式方法会使线程暂停执行,不占用CPU资源直至条件满足,常见阻塞方法如Thread.sleep()、Object.wait()和I/O操作,具有一定的参考价值,感兴趣的可以了解一下
    2024-10-10

最新评论