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

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.dtcms.com/a/250834.html

相关文章:

  • 香橙派Zero3结合Docker部署私有音乐实践过程
  • vscode通过ssh连接
  • Flink与Kubernetes集成
  • RV1126+OPENCV对视频流单独进行视频膨胀/腐蚀操作
  • 微软Bing正式推出AI视频生成工具:Bing Video Creator,由Sora技术驱动,限时免费体验!
  • Docker + PyFlink1.17 数据写入 MySQL
  • 05-mcp-server案例分享-用豆包大模型 1.6 手搓文生图视频 MCP-server发布到PyPI官网
  • ESP32 005 MicroPython I2S 实现音频传输与播放
  • 性能优化 - 案例篇:11种优化接口性能的通用方案
  • Bootstrap 5学习教程,从入门到精通, Bootstrap 5 列表组(List Group)语法知识点及案例(14)
  • AWS EC2 终极指南:如何选择预装 GPU 驱动和特定功能的最佳 AMI
  • AWS 解决方案深度剖析:Amazon QLDB — 构建可信赖、不可变的数据审计基石
  • 基于AWS无服务器架构的区块链API集成:零基础设施运维实践
  • 微软azure抢跑aws和谷歌云的区别
  • 线性代数(2)几何角度来理解线性方程组
  • Java面试题022:一文深入了解微服务网关Gateway
  • 【微服务】134:SpringCloud
  • SLB、Nginx、Gateway 与 ECS 的关系详解
  • Leetcode 刷题记录 15 —— 二分查找
  • Java可变参数方法的常见错误与最佳实践
  • 【锂电池剩余寿命预测】XGBoost锂电池剩余寿命预测(Pytorch完整源码和数据)
  • 深入理解Kafka Consumer:从理论到实战
  • SAP代理商——哲讯科技,助力企业数字化转型
  • 大数据实时风控引擎:Spark Streaming、Kafka、Flink与Doris的融合实践
  • 纺织行业SAP解决方案:无锡哲讯科技助力企业智能化升级
  • 国产替代新标杆|盟接之桥EDI软件让中国制造连接世界更安全、更简单、更有底气
  • 个人笔记-- TCL 替换
  • web3-区块链的技术安全/经济安全以及去杠杆螺旋(经济稳定)
  • Web3-代币ERC20/ERC721以及合约安全溢出和下溢的研究
  • go.work