当前位置: 首页 > ai >正文

Java面试题:分布式ID时钟回拨怎么处理?序列号耗尽了怎么办?

欢迎来到啾啾的博客🐱。
记录学习点滴。分享工作思考和实用技巧,偶尔也分享一些杂谈💬。
有很多很多不足的地方,欢迎评论交流,感谢您的阅读和评论😄。

目录

  • 1 分布式ID
  • 2 问题
    • 2.1 时钟回拨
      • 2.1.1 毫秒级时钟回拨则进行等待
      • 2.1.2 引入时钟回拨位
      • 2.1.3 基于外部
      • 2.1.4 混合时间戳
    • 2.2 序列号耗尽
      • 2.2.1 等待时间戳
      • 2.2.2 调整结构,增加序列号位数
      • 2.2.3 多ID生成器

现在典型的八股都是凝练了问题,背后有着对问题的认知和解决思路。
一直想写一个八股系列,从问题到原理。从这篇开始吧。

面试题:分布式ID时钟回拨怎么处理?序列号耗尽了怎么办?

1 分布式ID

分布式ID均会有一些需求。
高性能:有序
可维护:包含时间
可用:唯一

结构经常是多段结构,以UUIDv7为例

[ 48位毫秒时间戳 ] [ 4位版本号'7' ] [ 76位随机数 ]

基于此,经常面临的问题如下。

2 问题

2.1 时钟回拨

2.1.1 毫秒级时钟回拨则进行等待

毫秒级时钟回拨,且对延迟不敏感场景。让ID生成器等待系统时钟追赶上上一次时间。

long generateId() {long currentTimestamp = getCurrentTimeMillis();while (currentTimestamp < lastTimestamp) {// 检测到时钟回拨,等待Thread.sleep(1);currentTimestamp = getCurrentTimeMillis();}// 继续生成IDif (currentTimestamp == lastTimestamp) {sequence = (sequence + 1) & 4095; // 序列号递增if (sequence == 0) {// 序列号用尽,等待下一毫秒currentTimestamp = waitNextMillis(currentTimestamp);}} else {sequence = 0; // 新毫秒,重置序列号}lastTimestamp = currentTimestamp;return (currentTimestamp << 22) | (machineId << 12) | sequence;
}

2.1.2 引入时钟回拨位

引入时钟回拨位。在ID结构中预留几位作为“时钟回拨位”(rollback bits),当检测到时钟回拨时,递增回拨位以区分ID,避免重复。

2.1.3 基于外部

即给予外部服务的时钟,避免依赖本地时钟,如使用Redis生成递增ID。

  • 在Redis中每天生成一个Key(如date:20250615),通过INCR操作生成递增序列号。
  • ID格式:日期 + 机器ID + Redis递增序列号。

2.1.4 混合时间戳

结合物理时钟和逻辑时钟,生成混合时间戳,确保即使发生回拨,ID仍保持唯一性和递增性。

使用Google的TrueTime或类似机制,维护一个时间区间([min, max]),确保时间戳在安全范围内。
检测到回拨时,使用逻辑计数器递增,确保ID唯一。

2.2 序列号耗尽

在分布式ID生成中(如Snowflake算法),序列号耗尽是指在同一时间戳(通常是毫秒级)内,序列号部分达到了最大值(例如,12位序列号的最大值是4095),无法继续生成新的唯一ID。这是一个常见问题,尤其在高并发场景下,同一毫秒内可能需要生成大量ID。

2.2.1 等待时间戳

毫秒级的方案等待下一毫秒,纳秒级的方案等待下一纳秒。

long generateId() {long currentTimestamp = getCurrentTimeMillis();if (currentTimestamp < lastTimestamp) {// 处理时钟回拨(参考上一回答)handleClockRollback();}if (currentTimestamp == lastTimestamp) {sequence = (sequence + 1) & 4095; // 递增序列号if (sequence == 0) {// 序列号耗尽,等待下一毫秒currentTimestamp = waitNextMillis(currentTimestamp);}} else {sequence = 0; // 新时间戳,重置序列号}lastTimestamp = currentTimestamp;return (currentTimestamp << 22) | (machineId << 12) | sequence;
}long waitNextMillis(long lastTimestamp) {long current = getCurrentTimeMillis();while (current <= lastTimestamp) {current = getCurrentTimeMillis();}return current;
}

2.2.2 调整结构,增加序列号位数

通过调整ID结构,增加序列号的位数(例如从12位增加到14位),从而支持每毫秒生成更多ID。

2.2.3 多ID生成器

通过引入多个ID生成器实例或分片,分散ID生成压力,降低单个实例的序列号耗尽概率。
比如雪花ID的Snowflake,可以为每个节点分配多个机器ID(例如,节点A使用机器ID 1-4,节点B使用5-8)。
当序列号耗尽时,切换到另一个实例生成ID。

http://www.xdnf.cn/news/14258.html

相关文章:

  • VINS-Fusion 简介、安装、编译、数据集/相机实测
  • 传统数据仓库正在被 Agentic AI 吞噬
  • 超高速总线CDCTL01A 芯片在机器人领域的应用解析
  • SLB、Nginx、Gateway 与 ECS 的关系详解
  • Node.js 中的 Token 认证机制详解
  • 【Docker 05】Container - 容器
  • volatile 对 int 和 long 修改的区别
  • 如何制定适用于多项目的统一流程规范
  • 关于AUTOSAR AP 开发流程的研究
  • (83)课102:过程里的条件判断 IF 条件1 THEN .. ELSEIF 条件2 THEN .. ELSE .. END IF;
  • # 把 ISO 写入 U 盘(相关了解)
  • VBA使用字典统计
  • 金蝶云星空BOS开发
  • 搜索问答技术概述:基于知识图谱与MRC的创新应用
  • OAC: Output-adaptive Calibration for Accurate Post-training Quantization
  • 痉挛性斜颈:认识颈部的 “异常挛动”
  • Java-String
  • 如何快速提升英文听力?
  • PCB设计杂谈之一
  • Amazon Q in QuickSight 实战:自然语言秒级生成数据报表与深度洞察
  • 打牙祭是什么意思
  • 快速读取数据
  • 006__C++类的特殊用法
  • 2.3.3 07年T2
  • GeoTools:gt-referencing模块
  • LoadRunner 2023 安装部署
  • 如何稳定地更新你的大模型知识(算法篇)
  • DataX HdfsReader 插件:快速上手与深入解析
  • 《P1878 舞蹈课》
  • 基于Docker编译运行orb-slam2_with_semantic_labelling