京东面试：600Wqps高并发ID如何设计？时钟回拨 如何解决？

文章很长，且持续更新，建议收藏起来，慢慢读！疯狂创客圈总目录 博客园版 为您奉上珍贵的学习资源 ：

免费赠送 :《尼恩Java面试宝典》 持续更新+ 史上最全 + 面试必备 2000页+ 面试必备 + 大厂必备 +涨薪必备
免费赠送 :《尼恩技术圣经+高并发系列PDF》 ，帮你 实现技术自由，完成职业升级， 薪酬猛涨！加尼恩免费领
免费赠送 经典图书:《Java高并发核心编程（卷1）加强版》 面试必备 + 大厂必备 +涨薪必备 加尼恩免费领
免费赠送 经典图书:《Java高并发核心编程（卷2）加强版》 面试必备 + 大厂必备 +涨薪必备 加尼恩免费领
免费赠送 经典图书:《Java高并发核心编程（卷3）加强版》 面试必备 + 大厂必备 +涨薪必备 加尼恩免费领

免费赠送 资源宝库： Java 必备 百度网盘资源大合集 价值>10000元 加尼恩领取

京东面试：600Wqps高并发ID如何设计？时钟回拨 如何解决？

尼恩特别说明： 尼恩的文章，都会在 《技术自由圈》 公号 发布， 并且维护最新版本。 如果发现图片 不可见， 请去 《技术自由圈》 公号 查找

尼恩说在前面

在40岁老架构师 尼恩的读者交流群(50+)中，最近有小伙伴拿到了一线互联网企业如得物、阿里、滴滴、极兔、有赞、shein 希音、shopee、百度、网易的面试资格，遇到很多很重要的面试题：

一个分布式 、高并发 的 ID系统，如何实现？

ID生产，如何实现100万 级别 的高并发？

前几天 小伙伴面试 京东，遇到了这个问题。但是由于 没有回答好，导致面试挂了。

小伙伴面试完了之后，来求助尼恩。

首先，分布式ID很重要，在所有的高并发核心组件中，分布式ID 是核心中的核心、重点中的重点 。

分布式ID 组件，是整个系统 黄金链路上的关键组件、黄金组件，

如果分布式ID 组件出现问题，整个黄金链路上关键动作都无法执行，这就会带来一场灾难，一定是P0级大灾难。

那么，遇到分布式ID 组件这个问题，该如何才能回答得很漂亮，才能 让面试官刮目相看、口水直流。

所以，尼恩给大家做一下系统化、体系化的梳理，使得大家内力猛增，可以充分展示一下大家雄厚的 “技术肌肉”，让面试官爱到 “不能自已、口水直流”，然后实现”offer直提”。

当然，这道面试题，以及参考答案，也会收入咱们的 《尼恩Java面试宝典》V145版本PDF集群，供后面的小伙伴参考，提升大家的 3高 架构、设计、开发水平。

最新《尼恩 架构笔记》《尼恩高并发三部曲》《尼恩Java面试宝典》的PDF，请关注本公众号【技术自由圈】获取，后台回复：领电子书

站上巨人肩膀上学习

高并发 的 ID有两种，一种是叶段id，一种是雪花id。关于叶段id的学习，具体请参见尼恩的视频：

顶奢、优质项目：1000W级qps ID组件 架构与实操

尼恩提示，在这里不展开 叶段id，仅 介绍另一个种高并发：雪花id。

而 高并发、分布式雪花算法的代表作： 非 百度的 UidGenerator 莫属。

UidGenerator是Java实现的, 基于Snowflake算法的唯一ID生成器。百度的UidGenerator用来生成全局的唯一ID，是雪花算法的改进版。

UidGenerator以组件形式工作在应用项目中, 支持自定义workerId位数和初始化策略，适用于docker等虚拟化环境下实例自动重启、漂移等场景。

github：https://github.com/baidu/uid-generator

在实现上, UidGenerator通过借用未来时间来解决sequence天然存在的并发限制;

采用RingBuffer来缓存已生成的UID, 并行化UID的生产和消费, 同时对CacheLine补齐，避免了由RingBuffer带来的硬件级「伪共享」问题.

结果是，最终单机QPS可达600万。

UidGenerator 依赖版本：

  • Java8及以上版本,
  • MySQL(内置WorkerID分配器, 启动阶段通过DB进行分配; 如自定义实现, 则DB非必选依赖）

Snowflake的二进制位段 设计

Snowflake是Twitter开源的一种分布式ID生成算法，用于在分布式系统中生成全局唯一的ID。

它的设计目标是高性能、低延迟和趋势递增的ID生成。

Snowflake的二进制位段 设计，大致为4段 （如果不包括前面的符号位，就是3段）

在这里插入图片描述

Snowflake生成的ID是一个64位的整数，由以下部分组成：

  1. sign(1bit) 固定1bit符号标识，即生成的UID为正数。

  2. 时间戳（41位）：使用41位存储毫秒级的时间戳，表示自定义的起始时间（Epoch）到生成ID的时间之间的毫秒数。

41bit-时间可以表示（1L<<41）/(1000L*3600*24*365)=69年的时间。
  1. 节点ID（10位）：用于标识不同的节点或机器。在分布式系统中，每个节点应具有唯一的节点ID。
10bit-机器可以表示1024台机器。
如果对IDC划分有需求，还可以将10-bit分5-bit给IDC，分5-bit给工作机器。
这样就可以表示32个IDC，每个IDC下可以有32台机器。
  1. 序列号（12位）：在同一毫秒内生成的序列号。如果在同一毫秒内生成的ID数量超过了12位能够表示的范围，那么会等待下一毫秒再生成ID。
12个自增序列号可以表示2^12个ID，理论上snowflake方案的QPS约为409.6w/s。

Snowflake生成的ID具有趋势递增的特点，因为高位部分是基于时间戳生成的。

Snowflake算法描述：指定机器 & 同一时刻 & 某一并发序列，是唯一的。

据此可生成一个64 bits的唯一ID（long）。

UidGenerator 的二进制位段 设计

百度的 UidGenerator 依然是以划分命名空间的方式将 64-bit位分割成多个部分，默认划分方式有别于雪花算法：它默认是由 1-28-22-13 的格式进行划分，可调整各个字段占用的位数。
UidGenerator 的二进制位段 设计，为4段（如果不包括前面的符号位，就是3段）

在这里插入图片描述

  • 第1位：标志位
    • 仍然占用1bit，其值始终是0：即生成的UID为 正数，不是负数
  • 第2位开始的28bit：时间戳（当前时间，相对于epoch时间的增量值）
    • 可表示2^28个数，不再是以毫秒为单位，而是以秒为单位，可用（1L<<28）/ (360024365) ≈ 8.51 年（最多可用8.7年，后边讲解）。
    • epoch时间：指使用 UidGenerator生成分布式ID服务，第一次上线的时间，epoch可配置，默认的epoch时间是2016-09-20，不配置的话，会浪费好几年的可用时间。
  • 第29位开始的22bit：中间的 workId （数据中心+工作机器，可以其他组成方式）
    • 可表示 2^22 = 4194304个工作ID（最多可支持约420w次机器启动）。
    • 内置实现：在启动时由数据库分配；默认分配策略：用后即弃；后续可提供复用策略。
  • 最后的13-bit位：并发序列（自增）
    • 表示每秒的并发数量，默认为2
    • ^13 = 8192个并发（即：默认qps为8192）。

43岁老架构师尼恩提示，UidGenerator 的二进制位段 ，每一段的长度是可以变化的，可以配置的。

以上UidGenerator 的二进制位段 设计 参数，可均 通过Spring进行自定义

UidGeneratorQuick Start

这里介绍如何在基于Spring的项目中使用UidGenerator, 具体流程如下:

步骤1: 安装依赖

先下载Java8, MySQL和Maven

设置环境变量

maven无须安装, 设置好MAVEN_HOME即可. 可像下述脚本这样设置JAVA_HOME和MAVEN_HOME, 如已设置请忽略.

export MAVEN_HOME=/xxx/xxx/software/maven/apache-maven-3.3.9
export PATH=$MAVEN_HOME/bin:$PATH
JAVA_HOME="/Library/Java/JavaVirtualMachines/jdk1.8.0_91.jdk/Contents/Home";
export JAVA_HOME;

步骤2: 创建表WORKER_NODE

运行sql脚本以导入表WORKER_NODE, 脚本如下:

DROP DATABASE IF EXISTS `xxxx`;
CREATE DATABASE `xxxx` ;
use `xxxx`;
DROP TABLE IF EXISTS WORKER_NODE;
CREATE TABLE WORKER_NODE
(
ID BIGINT NOT NULL AUTO_INCREMENT COMMENT 'auto increment id',
HOST_NAME VARCHAR(64) NOT NULL COMMENT 'host name',
PORT VARCHAR(64) NOT NULL COMMENT 'port',
TYPE INT NOT NULL COMMENT 'node type: ACTUAL or CONTAINER',
LAUNCH_DATE DATE NOT NULL COMMENT 'launch date',
MODIFIED TIMESTAMP NOT NULL COMMENT 'modified time',
CREATED TIMESTAMP NOT NULL COMMENT 'created time',
PRIMARY KEY(ID)
)COMMENT='DB WorkerID Assigner for UID Generator',ENGINE = INNODB;

修改mysql.properties配置中, jdbc.url, jdbc.username和jdbc.password, 确保库地址, 名称, 端口号, 用户名和密码正确.

步骤3: 修改Spring配置

提供了两种生成器: DefaultUidGenerator、CachedUidGenerator。

如对UID生成性能有要求, 请使用CachedUidGenerator

对应Spring配置分别为: https://github.com/baidu/uid-generator/blob/master/default-uid-spring.xml、cached-uid-spring.xml

官方给的DefaultUidGenerator配置
<!-- DefaultUidGenerator -->
<bean id="defaultUidGenerator" class="com.baidu.fsg.uid.impl.DefaultUidGenerator" lazy-init="false"><property name="workerIdAssigner" ref="disposableWorkerIdAssigner"/><!-- Specified bits & epoch as your demand. No specified the default value will be used --><property name="timeBits" value="29"/><property name="workerBits" value="21"/><property name="seqBits" value="13"/><property name="epochStr" value="2016-09-20"/>
</bean><!-- 用完即弃的WorkerIdAssigner，依赖DB操作 -->
<bean id="disposableWorkerIdAssigner" class="com.baidu.fsg.uid.worker.DisposableWorkerIdAssigner" />
官方给的CachedUidGenerator配置
<!-- CachedUidGenerator -->
<bean id="cachedUidGenerator" class="com.baidu.fsg.uid.impl.CachedUidGenerator"><property name="workerIdAssigner" ref="disposableWorkerIdAssigner" /><!-- 以下为可选配置, 如未指定将采用默认值 --><!-- Specified bits & epoch as your demand. No specified the default value will be used --><property name="timeBits" value="29"/><property name="workerBits" value="21"/><property name="seqBits" value="13"/><property name="epochStr" value="2016-09-20"/><!-- RingBuffer size扩容参数, 可提高UID生成的吞吐量. --><!-- 默认:3， 原bufferSize=8192, 扩容后bufferSize= 8192 << 3 = 65536 --><property name="boostPower" value="3"></property><!-- 指定何时向RingBuffer中填充UID, 取值为百分比(0, 100), 默认为50 --><!-- 举例: bufferSize=1024, paddingFactor=50 -> threshold=1024 * 50 / 100 = 512. --><!-- 当环上可用UID数量 < 512时, 将自动对RingBuffer进行填充补全 --><property name="paddingFactor" value="50"></property><!-- 另外一种RingBuffer填充时机, 在Schedule线程中, 周期性检查填充 --><!-- 默认:不配置此项, 即不实用Schedule线程. 如需使用, 请指定Schedule线程时间间隔, 单位:秒 --><property name="scheduleInterval" value="60"></property><!-- 拒绝策略: 当环已满, 无法继续填充时 --><!-- 默认无需指定, 将丢弃Put操作, 仅日志记录. 如有特殊需求, 请实现RejectedPutBufferHandler接口(支持Lambda表达式) --><property name="rejectedPutBufferHandler" ref="XxxxYourPutRejectPolicy"></property><!-- 拒绝策略: 当环已空, 无法继续获取时 --><!-- 默认无需指定, 将记录日志, 并抛出UidGenerateException异常. 如有特殊需求, 请实现RejectedTakeBufferHandler接口(支持Lambda表达式) --><property name="rejectedTakeBufferHandler" ref="XxxxYourTakeRejectPolicy"></property></bean><!-- 用完即弃的WorkerIdAssigner, 依赖DB操作 -->
<bean id="disposableWorkerIdAssigner" class="com.baidu.fsg.uid.worker.DisposableWorkerIdAssigner" />
官方给的Mybatis配置

mybatis-spring.xml配置说明如下:

<!-- Spring annotation扫描 -->
<context:component-scan base-package="com.baidu.fsg.uid" /><bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"><property name="dataSource" ref="dataSource" /><property name="mapperLocations" value="classpath:/META-INF/mybatis/mapper/M_WORKER*.xml" />
</bean><!-- 事务相关配置 -->
<tx:annotation-driven transaction-manager="transactionManager" order="1" /><bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"><property name="dataSource" ref="dataSource" />
</bean><!-- Mybatis Mapper扫描 -->
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer"><property name="annotationClass" value="org.springframework.stereotype.Repository" /><property name="basePackage" value="com.baidu.fsg.uid.worker.dao" /><property name="sqlSessionFactoryBeanName" value="sqlSessionFactory" />
</bean><!-- 数据源配置 -->
<bean id="dataSource" parent="abstractDataSource"><property name="driverClassName" value="${mysql.driver}" /><property name="maxActive" value="${jdbc.maxActive}" /><property name="url" value="${jdbc.url}" /><property name="username" value="${jdbc.username}" /><property name="password" value="${jdbc.password}" />
</bean><bean id="abstractDataSource" class="com.alibaba.druid.pool.DruidDataSource" destroy-method="close"><property name="filters" value="${datasource.filters}" /><property name="defaultAutoCommit" value="${datasource.defaultAutoCommit}" /><property name="initialSize" value="${datasource.initialSize}" /><property name="minIdle" value="${datasource.minIdle}" /><property name="maxWait" value="${datasource.maxWait}" /><property name="testWhileIdle" value="${datasource.testWhileIdle}" /><property name="testOnBorrow" value="${datasource.testOnBorrow}" /><property name="testOnReturn" value="${datasource.testOnReturn}" /><property name="validationQuery" value="${datasource.validationQuery}" /><property name="timeBetweenEvictionRunsMillis" value="${datasource.timeBetweenEvictionRunsMillis}" /><property name="minEvictableIdleTimeMillis" value="${datasource.minEvictableIdleTimeMillis}" /><property name="logAbandoned" value="${datasource.logAbandoned}" /><property name="removeAbandoned" value="${datasource.removeAbandoned}" /><property name="removeAbandonedTimeout" value="${datasource.removeAbandonedTimeout}" />
</bean><bean id="batchSqlSession" class="org.mybatis.spring.SqlSessionTemplate"><constructor-arg index="0" ref="sqlSessionFactory" /><constructor-arg index="1" value="BATCH" />
</bean>

步骤4: 运行示例单测

运行单测CachedUidGeneratorTest, 展示UID生成、解析等功能

@Resource
private UidGenerator uidGenerator;@Test
public void testSerialGenerate() {// Generate UIDlong uid = uidGenerator.getUID();// Parse UID into [Timestamp, WorkerId, Sequence]// {"UID":"180363646902239241","parsed":{    "timestamp":"2017-01-19 12:15:46",    "workerId":"4",    "sequence":"9"        }}System.out.println(uidGenerator.parseUID(uid));}

DefaultUidGenerator 的底层原理 和核心源码 学习

DefaultUidGenerator的代码很简单，尼恩带着大家，围绕三段进行介绍。

前面讲到，UidGenerator 的二进制位段 设计，为3段（不包括前面的符号位，就是3段），

在这里插入图片描述

第一位段：delta seconds

这个值是指当前时间与epoch时间的时间差，且单位为秒。

epoch时间就是指集成UidGenerator生成ID服务第一次上线的时间，可配置，也一定要根据你的上线时间进行配置，因为默认的epoch时间可是2016-09-20，不配置的话，会浪费好几年的可用时间。

第二位段：workerId

UidGenerator是如何给worker id赋值的？搭建UidGenerator的话，需要创建一个表：

DROP TABLE IF EXISTS WORKER_NODE;
CREATE TABLE WORKER_NODE(ID BIGINT NOT NULL AUTO_INCREMENT PRIMARY KEY ,HOST_NAME VARCHAR(64) NOT NULL COMMENT 'host name',PORT VARCHAR(64) NOT NULL COMMENT 'port',TYPE INT NOT NULL COMMENT 'node type: ACTUAL or CONTAINER',LAUNCH_DATE DATE NOT NULL COMMENT 'launch date',MODIFIED DATETIME NOT NULL COMMENT 'modified time',CREATED DATEIMTE NOT NULL COMMENT 'created time'
)COMMENT='DB WorkerID Assigner for UID Generator',ENGINE = INNODB;

UidGenerator会在集成用它生成分布式ID的实例启动的时候，往这个表中插入一行数据，得到的id值就是准备赋给workerId的值。

由于workerId默认22位，那么，集成UidGenerator生成分布式ID的所有实例重启次数是不允许超过4194303次（即2^22-1），否则会抛出异常。

生成workerId的核心代码来自 DisposableWorkerIdAssigner.java中，当然，你也可以实 WorkerIdAssigner.java 接口，自定义生成workerId。

第三位段：sequence （秒内的序号）

核心代码如下，几个实现的关键点：

  • synchronized保证线程安全；
  • 如果时间有任何的回拨，那么直接抛出异常；
  • 如果当前时间和上一次是同一秒时间，那么sequence自增。如果同一秒内自增值超过2^13-1，那么就会自旋等待下一秒（getNextSecond）；
  • 如果是新的一秒，那么sequence重新从0开始；
protected synchronized long nextId() {long currentSecond = getCurrentSecond();if (currentSecond < lastSecond) {long refusedSeconds = lastSecond - currentSecond;throw new UidGenerateException("Clock moved backwards. Refusing for %d seconds", refusedSeconds);}if (currentSecond == lastSecond) {sequence = (sequence + 1) & bitsAllocator.getMaxSequence();if (sequence == 0) {currentSecond = getNextSecond(lastSecond);}} else {sequence = 0L;}lastSecond = currentSecond;return bitsAllocator.allocate(currentSecond - epochSeconds, workerId, sequence);
}

CachedUidGenerator 的底层原理 和核心源码 学习

UidGenerator 提供了两种生成唯一ID方式，分别是 DefaultUidGenerator 和 CachedUidGenerator，官方建议如果有性能考虑的话使用 CachedUidGenerator 方式实现.

CachedUidGenerator 是性能较高的 生成方式，采用的是预生产id的方式：

  • 使用 RingBuffer 缓存预生产 id。数组每个元素成为一个slot。

  • RingBuffer容量，默认为Snowflake算法中sequence最大值（2^13 = 8192）。可通过 boostPower 配置进行扩容，以提高 RingBuffer 读写吞吐量。

CachedUidGenerator实现原理

因为delta seconds部分是以秒为单位的，所以1个worker 1秒内最多生成的id书为8192个（2的13次方）。从上可知，支持的最大qps为8192，所以，需要通过缓存id来提高吞吐量。

本质上，CachedUidGenerator 通过预生产+缓冲的方式，借用未来时间来解决sequence天然存在的并发限制

  • CachedUidGenerator 采用RingBuffer （或者环形队列）来缓存已生成的UID,

  • CachedUidGenerator 把 ID的生产 和 ID消费 并行化 ,

  • CachedUidGenerator 对CacheLine补齐，避免了由RingBuffer带来的硬件级「伪共享」问题.

通过优化，CachedUidGenerator 最终单机QPS可达600万。

为什么，叫借助未来时间？

因为每秒最多生成8192个id，当1秒获取id数多于8192时，RingBuffer中的id很快消耗完毕，在填充RingBuffer时，生成的id的delta seconds 部分只能使用未来的时间。

CachedUidGenerator的环形队列设计

CachedUidGenerator 采用RingBuffer来缓存预生产的ID, 实现了并行化ID的生产和消费

使用RingBuffer缓存生成的id。RingBuffer是个环形数组，默认大小为8192个，里面缓存着生成的id。

在这里插入图片描述

  1. 获取id
    1. Consumer 会从ringbuffer中拿一个id，
    2. 支持 Consumer 并发获取
  2. 填充id
    1. RingBuffer填充时机 为3种： 初始化预填充、即时填充、定时填充
    2. 初始化预填充：程序启动时，将RingBuffer填充满，缓存着8192个id
    3. 即时填充: 调用getUID()获取id时，检测到RingBuffer中的剩余id个数小于总个数的50%，将RingBuffer填充满，使其缓存8192个id
    4. 定时填充: 可配置是否使用以及定时任务的周期, 通过Schedule线程，定时补全空闲slots。可通过scheduleInterval配置，以应用定时填充功能，并指定Schedule时间间隔。
  3. Tail指针、Cursor指针用于环形数组上读写slot.

啰嗦一下，RingBuffer填充时机

  • 初始化预填充
    RingBuffer初始化时，预先填充满整个RingBuffer.
  • 即时填充
    Take消费时，即时检查剩余可用slot量(tail- cursor)，如小于设定阈值，则补全空闲slots。阈值可通过paddingFactor来进行配置，请参考Quick Start中CachedUidGenerator配置
  • 定时填充
    通过Schedule线程，定时补全空闲slots。可通过scheduleInterval配置，以应用定时填充功能，并指定Schedule时间间隔

CachedUidGenerator双RingBuffer设计

CachedUidGenerator采用了双RingBuffer：

  • Uid-RingBuffer
  • Flag-RingBuffer

Uid-RingBuffer用于存储Uid、Flag-RingBuffer用于存储Uid状态(是否可填充、是否可消费)

在这里插入图片描述

Tail指针、Cursor指针用于环形数组上读写slot：

  • Tail指针 （Producer 生产指针）
    表示Producer生产的最大序号(此序号从0开始，持续递增)。Tail不能超过Cursor，即生产者不能覆盖未消费的slot。当Tail已赶上curosr，此时可通过rejectedPutBufferHandler指定PutRejectPolicy
  • Cursor指针 （Consumer 消费指针）
    表示Consumer消费到的最小序号(序号序列与Producer序列相同)。Cursor不能超过Tail，即不能消费未生产的slot。当Cursor已赶上tail，此时可通过rejectedTakeBufferHandler指定TakeRejectPolicy

RingBuffer环形数组，数组每个元素成为一个slot。RingBuffer容量，默认为Snowflake算法中sequence最大值，且为2^N。

可通过boostPower配置进行扩容，以提高RingBuffe 读写吞吐量。

CachedUidGenerator 通过CacheLine补齐解决伪共享

由于数组元素在内存中是连续分配的，可最大程度利用CPU cache以提升性能。

但同时会带来「伪共享」FalseSharing问题，为此在Tail、Cursor指针、Flag-RingBuffer中采用了CacheLine
补齐方式。

在这里插入图片描述

如何解决 Snowflake 的时钟回拨问题？

什么是Snowflake 时间回拨问题？

  • 雪花算法通过时间来即将作为id的区分标准之一,对于同一台id生成机器,它通过时间和序号保证id不重复
  • 当机器出现问题,时间可能回到之前,此时,时间就不能区分
  • 又或者因为闰秒的出现,导致时间回拨

如何解决

方法1 直接抛出异常

  • 不管3X7==21,直接抛出异常
  • 将问题交给人工解决
  • 这种方法也是原始的雪花算法,百度的uid-generator采用的
  • 太过简单,显然不好

方法2 延迟等待

  • 这种时间回拨(回跳)或许只出现一次,也许只是机器出现了小问题,所以产生
  • 对于这种场景,没有必要抛出异常,中断业务
  • 此时,将当前线程阻塞3ms,之后再获取时间,看时间是否比上一次请求的时间大
  • 如果大了,说明恢复正常了,则不用管
  • 如果还小,说明真出问题了,则抛出异常,呼唤程序员处理
  • 实际应用项目: 美团的leaf, 用如果时间差在5ms内,则等待 时间差<<1, 然后再判断

方法3 备用机

  • 当前机器出现问题,则换一台机器
  • 通过高可用来解决该问题

方法4 采用之前最大时间

  • 本身得出时间回拨结论就是通过当前时间和上次最后(大)的时间进行比较
  • 那么此时可以采用上次最大时间的最大序号之后的序号来进行继续使用
  • 从而保证了唯一性
方法5 追赶时间
  • 可以采取这样的暴力思路,因为当前的时间回拨了,比之前的时间慢
  • 那么我们便加速追赶时间
  • 首先,不返回id
  • 然后将我们的seq增加比如1024个,然后判断是否回拨,如果不是,再加1024
  • 当seq超过了12位的maxSeq时,按照雪花算法的逻辑,时间便会进位,借用下个时间的seq
  • 此时就实现了时间的加速
  • 经过若干个加速,则可以实现时间正常

UidGenerator 如何解决了时钟回拨问题

百度开源的 UidGenerator 是基于Java语言实现的唯一ID生成器，是在雪花算法 snowflake 的基础上做了一些改进（解决了时钟回拨问题）。

总体来说，UidGenerator 通过两个位段自增 彻底 解决了时钟回拨问题

第一：workerId位段自增：

UidGenerator的workerId在实例每次重启时初始化，workerId 属于数据库 自增ID，

由于 workerId 不断增长，所以不同的工作节点，不会有任何workerId冲突。

第二：delta seconds时间位段递增：

传统的雪花算法实现都是通过System.currentTimeMillis()来获取时间， 并与上一次时间进行比较，严重依赖服务器的时间，而服务器的时间容易造成时钟回拨，从而产生时间冲突。

而UidGenerator的时间类型是AtomicLong，且通过incrementAndGet()方法获取下一次的时间，从而脱离了对服务器时间的依赖，也就不会有时钟回拨的问题

关于雪花id、叶段id的学习，具体请参考 43岁资深老架构师尼恩的视频

顶奢、优质项目：1000W级qps ID组件 架构与实操

说在最后：有问题找老架构取经‍

通过对分布式ID的深度解答，可以充分展示一下大家雄厚的 “技术肌肉”，让面试官爱到 “不能自已、口水直流”，然后实现”offer直提”。

在面试之前，建议大家系统化的刷一波 5000页《尼恩Java面试宝典PDF》，里边有大量的大厂真题、面试难题、架构难题。

很多小伙伴刷完后， 吊打面试官， 大厂横着走。

在刷题过程中，如果有啥问题，大家可以来 找 40岁老架构师尼恩交流。

另外，如果没有面试机会，可以找尼恩来改简历、做帮扶。

遇到职业难题，找老架构取经， 可以省去太多的折腾，省去太多的弯路。

尼恩指导了大量的小伙伴上岸，前段时间，刚指导一个40岁+被裁小伙伴，拿到了一个年薪100W的offer。

狠狠卷，实现 “offer自由” 很容易的， 前段时间一个武汉的跟着尼恩卷了2年的小伙伴， 在极度严寒/痛苦被裁的环境下， offer拿到手软， 实现真正的 “offer自由” 。

技术自由的实现路径：

实现你的 架构自由：

《吃透8图1模板，人人可以做架构》

《10Wqps评论中台，如何架构？B站是这么做的！！！》

《阿里二面：千万级、亿级数据，如何性能优化？ 教科书级 答案来了》

《峰值21WQps、亿级DAU，小游戏《羊了个羊》是怎么架构的？》

《100亿级订单怎么调度，来一个大厂的极品方案》

《2个大厂 100亿级 超大流量 红包 架构方案》

… 更多架构文章，正在添加中

实现你的 响应式 自由：

《响应式圣经：10W字，实现Spring响应式编程自由》

这是老版本 《Flux、Mono、Reactor 实战（史上最全）》

实现你的 spring cloud 自由：

《Spring cloud Alibaba 学习圣经》 PDF

《分库分表 Sharding-JDBC 底层原理、核心实战（史上最全）》

《一文搞定：SpringBoot、SLF4j、Log4j、Logback、Netty之间混乱关系（史上最全）》

实现你的 linux 自由：

《Linux命令大全：2W多字，一次实现Linux自由》

实现你的 网络 自由：

《TCP协议详解 (史上最全)》

《网络三张表：ARP表, MAC表, 路由表，实现你的网络自由！！》

实现你的 分布式锁 自由：

《Redis分布式锁（图解 - 秒懂 - 史上最全）》

《Zookeeper 分布式锁 - 图解 - 秒懂》

实现你的 王者组件 自由：

《队列之王： Disruptor 原理、架构、源码 一文穿透》

《缓存之王：Caffeine 源码、架构、原理（史上最全，10W字 超级长文）》

《缓存之王：Caffeine 的使用（史上最全）》

《Java Agent 探针、字节码增强 ByteBuddy（史上最全）》

实现你的 面试题 自由：

4800页《尼恩Java面试宝典 》 40个专题

免费获取11个技术圣经PDF：

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/787305.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

[笔记]（更新中）CSP-S 2024 查漏补缺

[笔记]（更新中）CSP-S 2024 查漏补缺

复习内容部分来自NOI大纲中入门级和提高级的内容。 联合体（Union） 联合体是一种复合数据类型，其的定义上与结构体的定义类似。 与结构体不同，联合体中的所有元素共用一块内存，所以它占空间大小一般是最大成员的大小（不考虑对齐的情况下），相应地，任意时刻只有一个成员带…
阅读更多...
推荐2款实用的持续集成与部署（CICD）自动化工具

推荐2款实用的持续集成与部署（CICD）自动化工具

前言 最近DotNetGuide技术社区交流群有不少同学在咨询：持续集成与部署（CI&CD）自动化工具有什么好用的推荐？今天大姚给大家推荐2款实用且免费的持续集成与部署（CI&CD）自动化工具，希望可以帮助到有需要的同学。 持续集成与部署工具的作用 持续集成（CI）和持续交付…
阅读更多...
.NET周刊【8月第3期 2024-08-18】

.NET周刊【8月第3期 2024-08-18】

国内文章 Roslyn 简单实现代码智能提示补全功能 https://www.cnblogs.com/lindexi/p/18365261 相信有很多伙伴热衷于编写 IDE 应用，在 dotnet 系下，通过 Roslyn 友好的 API 和强大的能力，实现一个代码智能提示是非常简单的事情。本文将和大家简单介绍一下如何使用 Roslyn 实…
阅读更多...
视野修炼-技术周刊第98期 | Node原生支持TS

视野修炼-技术周刊第98期 | Node原生支持TS

① Node 22.7 支持直接运行TS ② js 模糊搜索库 ③ Favicon 一键获取 ④ fuite - 网页内存泄露分析工具 ⑤ logtape - 0依赖日志库 ⑥ Volta 2.0 ⑦ AI 昆虫图识别欢迎来到第 98 期的【视野修炼 - 技术周刊】，下面是本期的精选内容简介 🔥强烈推荐Node 22.7 支持直接运行TS …
阅读更多...
创建环境

创建环境

python -m venv cuda cuda\Scripts\activate
阅读更多...
最容易理解的Swin transformer模型(通俗易懂版)

最容易理解的Swin transformer模型(通俗易懂版)

Swin Transformer: Hierarchical Vision Transformer using Shifted Windows 1. 论文信息 原文地址：https://arxiv.org/abs/2103.14030 官网地址：https://github.com/microsoft/Swin-Transformer 2. 网络框架 2.1 swim VS vit 从图中可以得到，Swin相较于ViT的区别在于：Swim…
阅读更多...
ArrayList声明,Add(), Insert();

ArrayList声明,Add(), Insert();

ArrayList提供了3个构造器，通过这3个构造器可以有3种声明方式。 (1)默认构造器，会以默认大小（16位）初始化内部数组。构造器格式如下。ArrayList List = new ArrayList();//实例化一个ArrayList,命名为List;for (int i = 0; i < 10; i++)//添加10个元素到List中;{List.Ad…
阅读更多...
【整理】【信息收集】敏感目录

【整理】【信息收集】敏感目录

一、敏感目录类型二、敏感目录收集2.1 在线查询一、敏感目录类型 数据文件、配置信息、上传目录、后台登录目录、安装页面、数据库版本、PHP版本、后台压缩包、未授权访问等。 二、 敏感目录收集 2.1 在线查询 （1）Google语法 1）site:查找与指定的网站有联系的URL。 用法：s…
阅读更多...
物理

物理

阅读更多...
FAQ about Python threading.Lock()

FAQ about Python threading.Lock()

(Over)
阅读更多...
centos 配置nginx

centos 配置nginx

1.检查系统版本，安装nginxcat /etc/redhat-release，//这个命令会显示你的CentOS发行版名称以及大致的版本号rpm -q CentOS-release，//这将返回当前安装的CentOS版本的具体编号uname -r，//内核的完整版本字符串。2.安装nginxsudo yum install epel-release -y # 如果还没…
阅读更多...
题解：P7952 [✗✓OI R1] 天动万象

题解：P7952 [✗✓OI R1] 天动万象

提供一种和第一篇题解不同的理解思路。 题目分析 看到操作 \(1\)：拿 dfs 序水水就行了。 看到操作 \(2\)：？？？ 特殊情况 我们考虑一下特殊情况下操作 \(2\) 怎么处理。 假如这棵树是一条链。设从根到叶节点权值如下：（随便赋的）节点编号 1 2 3 4 5 6权值 1 2 3 4 5 6如果…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023