我要评论作为多年的java开发经验，在开发过程中经常会踩一些坑，本系列想通过一些案例分享，帮助其他开发者避免这些问题。
注意：由于框架不同版本改造会有些使用的不同，因此本次系列中使用jdk版本使用的是open-jdk21。
1. 事情起因
在一次电商系统的订单系统中，用户反馈出现了重复的订单id，导致订单数据混乱。经过排查发现，是因为服务器进行了ntp时间同步，系统时间被回调了约50毫秒，导致snowflake算法生成的id与之前重复。
问题代码如下：
参考代码 lesson15-snowflake-clock-drift 中的snowflakeclockdriftdemo.java
package com.architect.pitfalls.snowflake.cause;
import java.util.hashset;
import java.util.set;
import java.util.concurrent.countdownlatch;
import java.util.concurrent.executorservice;
import java.util.concurrent.executors;
import java.util.concurrent.atomic.atomiclong;
/**
* snowflake算法时钟回拨演示 - 问题代码
*
* 模拟时钟回拨导致的id重复问题：
* 1. 时钟回拨导致id重复
* 2. 时间同步服务导致的id生成异常
* 3. 虚拟机时间调整导致的id冲突
*/
public class snowflakeclockdriftdemo {
public static void main(string[] args) {
system.out.println("=== snowflake算法时钟回拨问题演示 ===\n");
// 场景1：时钟回拨导致id重复（无保护版本）
system.out.println("========================================");
system.out.println("场景1: 时钟回拨导致id重复（无保护版本）");
system.out.println("========================================");
demonstrateclockdriftnoprotection();
system.out.println();
// 场景2：时钟回拨导致服务不可用
system.out.println("========================================");
system.out.println("场景2: 时钟回拨导致服务不可用");
system.out.println("========================================");
demonstrateserviceunavailable();
system.out.println();
// 场景3：ntp时间同步导致的问题
system.out.println("========================================");
system.out.println("场景3: ntp时间同步导致的问题");
system.out.println("========================================");
demonstratentpsync();
system.out.println();
// 场景4：并发场景下的id重复风险
system.out.println("========================================");
system.out.println("场景4: 并发场景下的id重复风险");
system.out.println("========================================");
demonstrateconcurrentidgeneration();
}
/**
* 场景1：演示时钟回拨导致的id重复（无保护版本）
*/
private static void demonstrateclockdriftnoprotection() {
system.out.println();
system.out.println("模拟情况：");
system.out.println(" 1. 正常生成一批id");
system.out.println(" 2. 模拟时钟回拨（系统时间向后调整）");
system.out.println(" 3. 再次生成id，观察是否重复");
system.out.println();
noprotectionidgenerator generator = new noprotectionidgenerator(1);
set<long> generatedids = new hashset<>();
system.out.println("步骤1: 正常生成10个id");
for (int i = 0; i < 10; i++) {
long id = generator.nextid();
generatedids.add(id);
system.out.println(" 生成id: " + id);
}
system.out.println(" 已生成id数量: " + generatedids.size());
system.out.println();
system.out.println("步骤2: 模拟时钟回拨100ms");
generator.simulateclockdrift(100);
system.out.println(" 时钟已回拨100ms");
system.out.println();
system.out.println("步骤3: 回拨后再次生成10个id");
int duplicatecount = 0;
for (int i = 0; i < 10; i++) {
long id = generator.nextid();
boolean isduplicate = !generatedids.add(id);
if (isduplicate) {
duplicatecount++;
system.out.println(" ⚠️ 生成id: " + id + " (重复!)");
} else {
system.out.println(" 生成id: " + id);
}
}
system.out.println();
system.out.println("问题分析：");
system.out.println(" - 时钟回拨后，生成的id与之前重复");
system.out.println(" - 重复id数量: " + duplicatecount);
system.out.println(" - 这会导致数据库主键冲突、业务数据混乱");
system.out.println();
system.out.println("⚠️ 严重后果：");
system.out.println(" 1. 数据库主键冲突");
system.out.println(" 2. 订单id重复导致业务异常");
system.out.println(" 3. 分布式系统数据一致性被破坏");
}
/**
* 场景2：演示时钟回拨导致服务不可用
*/
private static void demonstrateserviceunavailable() {
system.out.println();
system.out.println("模拟情况：");
system.out.println(" 1. 正常生成id");
system.out.println(" 2. 时钟回拨后抛出异常");
system.out.println(" 3. 服务不可用");
system.out.println();
simplesnowflakeidgenerator generator = new simplesnowflakeidgenerator(1);
system.out.println("步骤1: 正常生成5个id");
for (int i = 0; i < 5; i++) {
long id = generator.nextid();
system.out.println(" 生成id: " + id);
}
system.out.println();
system.out.println("步骤2: 模拟时钟回拨100ms");
generator.simulateclockdrift(100);
system.out.println(" 时钟已回拨100ms");
system.out.println();
system.out.println("步骤3: 尝试生成新id");
try {
long id = generator.nextid();
system.out.println(" 生成id: " + id);
} catch (runtimeexception e) {
system.out.println(" ⚠️ 异常: " + e.getmessage());
system.out.println();
system.out.println("问题分析：");
system.out.println(" - 时钟回拨后，id生成器直接抛出异常");
system.out.println(" - 服务因此不可用");
system.out.println(" - 这是很多简单实现的通病");
system.out.println();
system.out.println("⚠️ 严重后果：");
system.out.println(" 1. 服务不可用，影响业务");
system.out.println(" 2. 可能导致级联故障");
system.out.println(" 3. 需要完善的时钟回拨处理机制");
}
}
/**
* 场景3：演示ntp时间同步导致的问题
*/
private static void demonstratentpsync() {
system.out.println();
system.out.println("模拟情况：");
system.out.println(" 1. 服务器时间比ntp服务器快");
system.out.println(" 2. ntp同步时将时间回调");
system.out.println(" 3. id生成器状态异常");
system.out.println();
simplesnowflakeidgenerator generator = new simplesnowflakeidgenerator(1);
system.out.println("步骤1: 服务器时间快于标准时间");
generator.setcustomtime(system.currenttimemillis() + 5000);
long id1 = generator.nextid();
system.out.println(" 生成id: " + id1);
system.out.println(" 当前时间戳: " + (system.currenttimemillis() + 5000));
system.out.println();
system.out.println("步骤2: ntp同步，时间回调5秒");
generator.setcustomtime(system.currenttimemillis());
system.out.println(" 同步后时间戳: " + system.currenttimemillis());
system.out.println();
system.out.println("步骤3: 尝试生成新id");
try {
long id2 = generator.nextid();
system.out.println(" 生成id: " + id2);
system.out.println();
system.out.println("⚠️ 问题：时间回拨后，id生成可能异常或重复");
} catch (exception e) {
system.out.println(" ⚠️ 异常: " + e.getmessage());
system.out.println();
system.out.println("问题分析：");
system.out.println(" - 时间回拨后无法生成有效id");
system.out.println(" - 服务可能因此不可用");
}
}
/**
* 场景4：并发场景下的id重复风险
*/
private static void demonstrateconcurrentidgeneration() {
system.out.println();
system.out.println("模拟情况：");
system.out.println(" 1. 多线程并发生成id");
system.out.println(" 2. 观察id重复情况");
system.out.println();
noprotectionidgenerator generator = new noprotectionidgenerator(1);
set<long> allids = new hashset<>();
atomiclong duplicatecount = new atomiclong(0);
int threadcount = 10;
int idsperthread = 1000;
countdownlatch latch = new countdownlatch(threadcount);
system.out.println("步骤1: 启动" + threadcount + "个线程，每个生成" + idsperthread + "个id");
executorservice executor = executors.newfixedthreadpool(threadcount);
for (int t = 0; t < threadcount; t++) {
executor.submit(() -> {
try {
for (int i = 0; i < idsperthread; i++) {
long id = generator.nextid();
synchronized (allids) {
if (!allids.add(id)) {
duplicatecount.incrementandget();
}
}
}
} finally {
latch.countdown();
}
});
}
try {
latch.await();
} catch (interruptedexception e) {
thread.currentthread().interrupt();
}
executor.shutdown();
system.out.println(" 生成完成");
system.out.println(" 总id数: " + allids.size());
system.out.println(" 重复id数: " + duplicatecount.get());
system.out.println();
system.out.println("步骤2: 模拟时钟回拨后并发生成");
generator.simulateclockdrift(50);
set<long> idsafterdrift = new hashset<>();
countdownlatch latch2 = new countdownlatch(threadcount);
atomiclong driftduplicatecount = new atomiclong(0);
executor = executors.newfixedthreadpool(threadcount);
for (int t = 0; t < threadcount; t++) {
final set<long> finalallids = allids;
executor.submit(() -> {
try {
for (int i = 0; i < idsperthread; i++) {
long id = generator.nextid();
synchronized (finalallids) {
if (!finalallids.add(id)) {
driftduplicatecount.incrementandget();
}
}
synchronized (idsafterdrift) {
idsafterdrift.add(id);
}
}
} finally {
latch2.countdown();
}
});
}
try {
latch2.await();
} catch (interruptedexception e) {
thread.currentthread().interrupt();
}
executor.shutdown();
system.out.println(" 回拨后生成完成");
system.out.println(" 回拨后重复id数: " + driftduplicatecount.get());
system.out.println();
system.out.println("问题分析：");
system.out.println(" - 时钟回拨期间并发生成id更容易重复");
system.out.println(" - 高并发场景下问题更加严重");
system.out.println(" - 需要完善的时钟回拨处理机制");
}
/**
* 无时钟回拨保护的id生成器（用于演示id重复问题）
*/
static class noprotectionidgenerator {
private static final long epoch = 1704067200000l;
private static final long worker_id_bits = 5l;
private static final long sequence_bits = 12l;
private static final long max_worker_id = ~(-1l << worker_id_bits);
private static final long sequence_mask = ~(-1l << sequence_bits);
private static final long worker_id_shift = sequence_bits;
private static final long timestamp_shift = sequence_bits + worker_id_bits;
private final long workerid;
private long sequence = 0l;
private long lasttimestamp = -1l;
private long customtime = null;
public noprotectionidgenerator(long workerid) {
if (workerid > max_worker_id || workerid < 0) {
throw new illegalargumentexception("worker id超出范围");
}
this.workerid = workerid;
}
public synchronized long nextid() {
long timestamp = customtime != null ? customtime : system.currenttimemillis();
// 无时钟回拨保护，直接使用回拨后的时间
// 这会导致id重复
if (timestamp == lasttimestamp) {
sequence = (sequence + 1) & sequence_mask;
if (sequence == 0) {
timestamp = waitnextmillis(timestamp);
}
} else {
sequence = 0l;
}
lasttimestamp = timestamp;
return ((timestamp - epoch) << timestamp_shift)
| (workerid << worker_id_shift)
| sequence;
}
private long waitnextmillis(long timestamp) {
long current = customtime != null ? customtime : system.currenttimemillis();
while (current <= timestamp) {
current = customtime != null ? customtime : system.currenttimemillis();
}
return current;
}
public void simulateclockdrift(long driftms) {
if (customtime == null) {
customtime = system.currenttimemillis() - driftms;
} else {
customtime = customtime - driftms;
}
// 不重置lasttimestamp，允许id重复
}
public void setcustomtime(long time) {
this.customtime = time;
this.lasttimestamp = -1l;
}
}
/**
* 简化的snowflake id生成器（有时钟回拨保护，会抛异常）
*/
static class simplesnowflakeidgenerator {
private static final long epoch = 1704067200000l;
private static final long worker_id_bits = 5l;
private static final long sequence_bits = 12l;
private static final long max_worker_id = ~(-1l << worker_id_bits);
private static final long sequence_mask = ~(-1l << sequence_bits);
private static final long worker_id_shift = sequence_bits;
private static final long timestamp_shift = sequence_bits + worker_id_bits;
private final long workerid;
private long sequence = 0l;
private long lasttimestamp = -1l;
private long customtime = null;
public simplesnowflakeidgenerator(long workerid) {
if (workerid > max_worker_id || workerid < 0) {
throw new illegalargumentexception("worker id超出范围");
}
this.workerid = workerid;
}
public synchronized long nextid() {
long timestamp = customtime != null ? customtime : system.currenttimemillis();
if (timestamp < lasttimestamp) {
throw new runtimeexception("时钟回拨，拒绝生成id");
}
if (timestamp == lasttimestamp) {
sequence = (sequence + 1) & sequence_mask;
if (sequence == 0) {
timestamp = waitnextmillis(timestamp);
}
} else {
sequence = 0l;
}
lasttimestamp = timestamp;
return ((timestamp - epoch) << timestamp_shift)
| (workerid << worker_id_shift)
| sequence;
}
private long waitnextmillis(long timestamp) {
long current = customtime != null ? customtime : system.currenttimemillis();
while (current <= timestamp) {
current = customtime != null ? customtime : system.currenttimemillis();
}
return current;
}
public void simulateclockdrift(long driftms) {
if (customtime == null) {
customtime = system.currenttimemillis() - driftms;
} else {
customtime = customtime - driftms;
}
// 保持lasttimestamp不变，模拟时钟回拨
}
public void setcustomtime(long time) {
this.customtime = time;
this.lasttimestamp = -1l;
}
}
}
运行结果：
=== snowflake算法时钟回拨问题演示 === ======================================== 场景1: 时钟回拨导致id重复（无保护版本） ======================================== 步骤1: 正常生成10个id 生成id: 9004269725421568 生成id: 9004269746655232 ... 已生成id数量: 10 步骤2: 模拟时钟回拨100ms 时钟已回拨100ms 步骤3: 回拨后再次生成10个id 生成id: 9004269740232704 生成id: 9004269740232705 ... 问题分析： - 时钟回拨后，生成的id与之前重复 - 这会导致数据库主键冲突、业务数据混乱 ⚠️ 严重后果： 1. 数据库主键冲突 2. 订单id重复导致业务异常 3. 分布式系统数据一致性被破坏 ======================================== 场景2: 时钟回拨导致服务不可用 ======================================== 步骤1: 正常生成5个id 生成id: 9004269757796352 ... 步骤2: 模拟时钟回拨100ms 时钟已回拨100ms 步骤3: 尝试生成新id ⚠️ 异常: 时钟回拨，拒绝生成id 问题分析： - 时钟回拨后，id生成器直接抛出异常 - 服务因此不可用 - 这是很多简单实现的通病
2. 原因分析
2.1 snowflake算法结构
snowflake是twitter开源的分布式id生成算法，生成的是一个64位的long类型id。
id结构（64位）：
┌─────────────────────────────────────────────────────────────┐ │ 0 │ 1-41位时间戳 │ 42-46位机器id │ 47-63位序列号 │ ├─────────────────────────────────────────────────────────────┤ │ 符 │ 时间戳 │ 数据中心+ │ 同一毫秒内的 │ │ 号 │ (毫秒级) │ 工作机器id │ 序列号 │ │ 位 │ 41位 │ 10位 │ 12位 │ └─────────────────────────────────────────────────────────────┘
各部分说明：
| 部分 | 位数 | 说明 |
|---|---|---|
| 符号位 | 1位 | 始终为0，保证id为正数 |
| 时间戳 | 41位 | 毫秒级时间戳（当前时间 - 起始时间），可使用约69年 |
| 机器id | 10位 | 通常分为数据中心id（5位）+ 工作机器id（5位），支持1024个节点 |
| 序列号 | 12位 | 同一毫秒内的序列号，每毫秒可生成4096个id |
id生成能力：
- 单机每毫秒：4096个id
- 单机每秒：约409万id
- 集群每秒：约41亿id（1024节点）
2.2 关键源码分析
以下是snowflake算法的核心实现代码：
public synchronized long nextid() {
long timestamp = system.currenttimemillis();
// 时钟回拨检测 - 问题核心！
if (timestamp < lasttimestamp) {
throw new runtimeexception("时钟回拨，拒绝生成id");
}
// 同一毫秒内，序列号递增
if (timestamp == lasttimestamp) {
sequence = (sequence + 1) & sequence_mask;
if (sequence == 0) {
// 序列号用完，等待下一毫秒
timestamp = waitnextmillis(timestamp);
}
} else {
// 新的毫秒，序列号重置为0
sequence = 0l;
}
lasttimestamp = timestamp;
// 组装id
return ((timestamp - epoch) << timestamp_shift)
| (workerid << worker_id_shift)
| sequence;
}
问题本质：
- snowflake算法的核心假设是系统时间单调递增
- 当时间回拨时，这个假设被打破，导致问题
2.3 时钟回拨的常见场景
场景1：ntp时间同步
- 服务器时间与ntp服务器时间有偏差
- ntp服务自动调整系统时间
- 调整方向可能是向前或向后
场景2：虚拟机/容器时间漂移
- 虚拟机时间与宿主机不完全同步
- 容器时间可能因资源竞争而漂移
- 迁移或恢复时时间可能跳变
场景3：人工时间调整
- 运维人员手动调整系统时间
- 时区设置错误后修正
- 测试环境时间模拟
3. 解决方案
3.1 方案一：等待策略
参考代码 lesson15-snowflake-clock-drift 中的waitstrategysolution.java
当检测到时钟回拨时，等待时间追上，而不是直接抛异常。
package com.architect.pitfalls.snowflake.solution;
import java.util.hashset;
import java.util.set;
/**
* 方案一：等待策略解决方案
*
* 当检测到时钟回拨时，等待时间追上，而不是直接抛异常
*/
public class waitstrategysolution {
public static void main(string[] args) {
system.out.println("=== 方案一：等待策略解决方案 ===\n");
demonstratewaitstrategy();
demonstrateconfiguration();
}
private static void demonstratewaitstrategy() {
system.out.println("========================================");
system.out.println("等待策略演示");
system.out.println("========================================");
system.out.println();
system.out.println("方案说明：");
system.out.println(" 当检测到时钟回拨时：");
system.out.println(" 1. 如果回拨幅度小于阈值，等待时间追上");
system.out.println(" 2. 如果回拨幅度大于阈值，抛异常或使用备用方案");
system.out.println();
waitsnowflakeidgenerator generator = new waitsnowflakeidgenerator(1, 100);
set<long> ids = new hashset<>();
system.out.println("步骤1: 正常生成id");
for (int i = 0; i < 5; i++) {
long id = generator.nextid();
ids.add(id);
system.out.println(" 生成id: " + id);
}
system.out.println();
system.out.println("步骤2: 模拟小幅时钟回拨（50ms）");
generator.simulateclockdrift(50);
system.out.println(" 时钟已回拨50ms");
system.out.println();
system.out.println("步骤3: 回拨后生成id（等待策略生效）");
long startwait = system.currenttimemillis();
for (int i = 0; i < 3; i++) {
long id = generator.nextid();
boolean duplicate = !ids.add(id);
system.out.println(" 生成id: " + id + (duplicate ? " (重复!)" : ""));
}
long waittime = system.currenttimemillis() - startwait;
system.out.println(" 实际等待时间: " + waittime + "ms");
system.out.println();
system.out.println("分析：");
system.out.println(" ✅ 小幅回拨时，等待策略可以保证id不重复");
system.out.println(" ✅ 服务不会中断");
system.out.println(" ⚠️ 大幅回拨时，等待时间过长影响性能");
system.out.println();
}
private static void demonstrateconfiguration() {
system.out.println("========================================");
system.out.println("配置建议");
system.out.println("========================================");
system.out.println();
system.out.println("等待策略配置参数：");
system.out.println();
system.out.println(" maxbackwardms: 最大容忍回拨毫秒数");
system.out.println(" - 建议: 5-100ms");
system.out.println(" - 过小: 频繁抛异常");
system.out.println(" - 过大: 等待时间过长");
system.out.println();
system.out.println(" waitintervalms: 等待检查间隔");
system.out.println(" - 建议: 1-10ms");
system.out.println(" - 影响等待精度和cpu使用率");
system.out.println();
system.out.println("优点：");
system.out.println(" - 实现简单");
system.out.println(" - 小幅回拨时服务不中断");
system.out.println(" - 保证id不重复");
system.out.println();
system.out.println("缺点：");
system.out.println(" - 大幅回拨时等待时间过长");
system.out.println(" - 可能影响请求响应时间");
system.out.println(" - 极端情况可能导致服务阻塞");
}
/**
* 支持等待策略的snowflake id生成器
*/
static class waitsnowflakeidgenerator {
private static final long epoch = 1704067200000l;
private static final long worker_id_bits = 5l;
private static final long sequence_bits = 12l;
private static final long max_worker_id = ~(-1l << worker_id_bits);
private static final long sequence_mask = ~(-1l << sequence_bits);
private static final long worker_id_shift = sequence_bits;
private static final long timestamp_shift = sequence_bits + worker_id_bits;
private final long workerid;
private final long maxbackwardms;
private long sequence = 0l;
private long lasttimestamp = -1l;
private long clockdriftoffset = 0l;
public waitsnowflakeidgenerator(long workerid, long maxbackwardms) {
if (workerid > max_worker_id || workerid < 0) {
throw new illegalargumentexception("worker id超出范围");
}
this.workerid = workerid;
this.maxbackwardms = maxbackwardms;
}
public synchronized long nextid() {
long timestamp = timegen();
if (timestamp < lasttimestamp) {
long offset = lasttimestamp - timestamp;
if (offset <= maxbackwardms) {
system.out.println(" [等待策略] 检测到时钟回拨 " + offset + "ms，等待时间追上...");
timestamp = waituntilvalid(lasttimestamp);
} else {
throw new runtimeexception("时钟回拨幅度过大: " + offset + "ms，超过阈值: " + maxbackwardms + "ms");
}
}
if (timestamp == lasttimestamp) {
sequence = (sequence + 1) & sequence_mask;
if (sequence == 0) {
timestamp = waitnextmillis(timestamp);
}
} else {
sequence = 0l;
}
lasttimestamp = timestamp;
return ((timestamp - epoch) << timestamp_shift)
| (workerid << worker_id_shift)
| sequence;
}
private long waituntilvalid(long targettimestamp) {
long timestamp = timegen();
while (timestamp < targettimestamp) {
try {
thread.sleep(1);
} catch (interruptedexception e) {
thread.currentthread().interrupt();
throw new runtimeexception("等待被中断", e);
}
timestamp = timegen();
}
return timestamp;
}
private long waitnextmillis(long timestamp) {
long current = timegen();
while (current <= timestamp) {
current = timegen();
}
return current;
}
private long timegen() {
return system.currenttimemillis() - clockdriftoffset;
}
public void simulateclockdrift(long driftms) {
clockdriftoffset += driftms;
}
}
}
运行结果：
=== 方案一：等待策略解决方案 === ======================================== 等待策略演示 ======================================== 步骤1: 正常生成id 生成id: 9004511121510400 生成id: 9004511127801856 生成id: 9004511127801857 生成id: 9004511127801858 生成id: 9004511127932928 步骤2: 模拟小幅时钟回拨（50ms） 时钟已回拨50ms 步骤3: 回拨后生成id（等待策略生效） [等待策略] 检测到时钟回拨 50ms，等待时间追上... 生成id: 9004511128064000 生成id: 9004511132782592 生成id: 9004511132782593 实际等待时间: 87ms 分析： ✅ 小幅回拨时，等待策略可以保证id不重复 ✅ 服务不会中断 ⚠️ 大幅回拨时，等待时间过长影响性能
优点： 实现简单，小幅回拨时服务不中断
缺点： 大幅回拨时等待时间过长
适用场景： 小幅回拨，对响应时间不敏感
3.2 方案二：序列号前移策略
参考代码 lesson15-snowflake-clock-drift 中的sequenceforwardsolution.java
当检测到时钟回拨时，通过调整序列号来避免id重复。
package com.architect.pitfalls.snowflake.solution;
import java.util.hashset;
import java.util.set;
/**
* 方案二：序列号前移策略
*
* 当检测到时钟回拨时，通过调整序列号来避免id重复
* 而不是等待时间追上
*/
public class sequenceforwardsolution {
public static void main(string[] args) {
system.out.println("=== 方案二：序列号前移策略 ===\n");
demonstratesequenceforward();
demonstrateadvantages();
}
private static void demonstratesequenceforward() {
system.out.println("========================================");
system.out.println("序列号前移策略演示");
system.out.println("========================================");
system.out.println();
system.out.println("方案说明：");
system.out.println(" 当检测到时钟回拨时：");
system.out.println(" 1. 记录回拨前的时间戳和序列号");
system.out.println(" 2. 回拨后，从上次序列号继续递增");
system.out.println(" 3. 避免生成重复id");
system.out.println();
sequenceforwardidgenerator generator = new sequenceforwardidgenerator(1);
set<long> ids = new hashset<>();
system.out.println("步骤1: 正常生成id");
for (int i = 0; i < 5; i++) {
long id = generator.nextid();
ids.add(id);
system.out.println(" 生成id: " + id + " (序列号: " + (id & 0xfff) + ")");
}
system.out.println(" 当前序列号偏移: " + generator.getsequenceoffset());
system.out.println();
system.out.println("步骤2: 模拟时钟回拨（50ms）");
generator.simulateclockdrift(50);
system.out.println(" 时钟已回拨50ms");
system.out.println();
system.out.println("步骤3: 回拨后生成id（序列号前移策略）");
for (int i = 0; i < 5; i++) {
long id = generator.nextid();
boolean duplicate = !ids.add(id);
system.out.println(" 生成id: " + id + (duplicate ? " (重复!)" : "") +
" (序列号: " + (id & 0xfff) + ")");
}
system.out.println(" 当前序列号偏移: " + generator.getsequenceoffset());
system.out.println();
system.out.println("分析：");
system.out.println(" ✅ 无需等待，立即生成id");
system.out.println(" ✅ 通过序列号前移避免重复");
system.out.println(" ✅ 服务不中断");
system.out.println(" ⚠️ 回拨后的id值可能变小（时间戳变小）");
system.out.println();
}
private static void demonstrateadvantages() {
system.out.println("========================================");
system.out.println("方案对比与适用场景");
system.out.println("========================================");
system.out.println();
system.out.println("序列号前移策略原理：");
system.out.println();
system.out.println(" 正常情况：");
system.out.println(" 时间戳t1, 序列号0-4095");
system.out.println();
system.out.println(" 时钟回拨后：");
system.out.println(" 时间戳变为t0 (t0 < t1)");
system.out.println(" 但序列号从上次位置继续，如4096-8191");
system.out.println(" 由于时间戳+序列号组合唯一，id不重复");
system.out.println();
system.out.println("限制条件：");
system.out.println(" - 回拨幅度内不能超过序列号上限");
system.out.println(" - 需要记录上次的时间戳和序列号");
system.out.println(" - 大幅回拨仍需其他策略");
system.out.println();
system.out.println("优点：");
system.out.println(" - 无等待时间，响应快");
system.out.println(" - 实现相对简单");
system.out.println(" - 适合小幅回拨场景");
system.out.println();
system.out.println("缺点：");
system.out.println(" - 大幅回拨时序列号可能耗尽");
system.out.println(" - 需要持久化记录上次状态");
system.out.println(" - 重启后可能丢失状态");
system.out.println(" - id值可能变小（不保证递增）");
}
/**
* 支持序列号前移的id生成器
*/
static class sequenceforwardidgenerator {
private static final long epoch = 1704067200000l;
private static final long worker_id_bits = 5l;
private static final long sequence_bits = 12l;
private static final long max_worker_id = ~(-1l << worker_id_bits);
private static final long sequence_mask = ~(-1l << sequence_bits);
private static final long worker_id_shift = sequence_bits;
private static final long timestamp_shift = sequence_bits + worker_id_bits;
private final long workerid;
private long sequence = 0l;
private long lasttimestamp = -1l;
private long sequenceoffset = 0l;
private long clockdriftoffset = 0l;
public sequenceforwardidgenerator(long workerid) {
if (workerid > max_worker_id || workerid < 0) {
throw new illegalargumentexception("worker id超出范围");
}
this.workerid = workerid;
}
public synchronized long nextid() {
long timestamp = timegen();
if (timestamp < lasttimestamp) {
long offset = lasttimestamp - timestamp;
system.out.println(" [序列号前移] 检测到时钟回拨 " + offset + "ms，启用序列号前移策略");
sequenceoffset += sequence_mask + 1;
}
if (timestamp == lasttimestamp) {
sequence = (sequence + 1) & sequence_mask;
if (sequence == 0) {
timestamp = waitnextmillis(timestamp);
}
} else {
sequence = 0l;
}
lasttimestamp = timestamp;
long finalsequence = (sequence + sequenceoffset) & sequence_mask;
return ((timestamp - epoch) << timestamp_shift)
| (workerid << worker_id_shift)
| finalsequence;
}
public long getsequenceoffset() {
return sequenceoffset;
}
private long waitnextmillis(long timestamp) {
long current = timegen();
while (current <= timestamp) {
current = timegen();
}
return current;
}
private long timegen() {
return system.currenttimemillis() - clockdriftoffset;
}
public void simulateclockdrift(long driftms) {
clockdriftoffset += driftms;
}
}
}
运行结果：
=== 方案二：序列号前移策略 === ======================================== 序列号前移策略演示 ======================================== 步骤1: 正常生成id 生成id: 9004522338914304 (序列号: 0) 生成id: 9004522341666816 (序列号: 0) 生成id: 9004522341666817 (序列号: 1) 生成id: 9004522341666818 (序列号: 2) 生成id: 9004522341666819 (序列号: 3) 当前序列号偏移: 0 步骤2: 模拟时钟回拨（50ms） 时钟已回拨50ms 步骤3: 回拨后生成id（序列号前移策略） [序列号前移] 检测到时钟回拨 43ms，启用序列号前移策略 生成id: 9004522336030720 (序列号: 0) 生成id: 9004522337865728 (序列号: 0) 生成id: 9004522337865729 (序列号: 1) 生成id: 9004522337865730 (序列号: 2) 生成id: 9004522337865731 (序列号: 3) 当前序列号偏移: 4096 分析： ✅ 无需等待，立即生成id ✅ 通过序列号前移避免重复 ✅ 服务不中断 ⚠️ 回拨后的id值可能变小（时间戳变小）
优点： 无等待时间，响应快
缺点： 大幅回拨时序列号可能耗尽，id值可能变小
适用场景： 小幅回拨，需要快速响应
3.3 方案三：使用单调时钟
参考代码 lesson15-snowflake-clock-drift 中的monotonicclocksolution.java
使用system.nanotime()替代system.currenttimemillis()，避免系统时间调整的影响。
package com.architect.pitfalls.snowflake.solution;
import java.util.hashset;
import java.util.set;
/**
* 方案三：使用单调时钟
*
* 使用system.nanotime()替代system.currenttimemillis()
* 避免系统时间调整的影响
*/
public class monotonicclocksolution {
public static void main(string[] args) {
system.out.println("=== 方案三：使用单调时钟 ===\n");
demonstratemonotonicclock();
demonstratecomparison();
}
private static void demonstratemonotonicclock() {
system.out.println("========================================");
system.out.println("单调时钟方案演示");
system.out.println("========================================");
system.out.println();
system.out.println("方案说明：");
system.out.println(" 使用system.nanotime()替代system.currenttimemillis()");
system.out.println(" nanotime()是单调递增的，不受系统时间调整影响");
system.out.println();
system.out.println("java时间api对比：");
system.out.println();
system.out.println(" system.currenttimemillis():");
system.out.println(" - 返回从1970-01-01开始的毫秒数");
system.out.println(" - 受系统时间调整影响");
system.out.println(" - 可能向前或向后跳变");
system.out.println();
system.out.println(" system.nanotime():");
system.out.println(" - 返回从某个固定但任意的时间点开始的纳秒数");
system.out.println(" - 单调递增，不受系统时间影响");
system.out.println(" - 适合测量时间间隔");
system.out.println();
monotonicclockidgenerator generator = new monotonicclockidgenerator(1);
set<long> ids = new hashset<>();
system.out.println("步骤1: 正常生成id");
for (int i = 0; i < 5; i++) {
long id = generator.nextid();
ids.add(id);
system.out.println(" 生成id: " + id);
}
system.out.println();
system.out.println("步骤2: 模拟系统时间回拨（不影响单调时钟）");
system.out.println(" 系统时间调整不会影响nanotime()");
system.out.println();
system.out.println("步骤3: 继续生成id");
for (int i = 0; i < 5; i++) {
long id = generator.nextid();
boolean duplicate = !ids.add(id);
system.out.println(" 生成id: " + id + (duplicate ? " (重复!)" : ""));
}
system.out.println();
system.out.println("分析：");
system.out.println(" ✅ 完全不受系统时间调整影响");
system.out.println(" ✅ 不会因时间回拨导致id重复");
system.out.println(" ✅ 服务稳定可靠");
system.out.println();
}
private static void demonstratecomparison() {
system.out.println("========================================");
system.out.println("方案对比与注意事项");
system.out.println("========================================");
system.out.println();
system.out.println("单调时钟方案注意事项：");
system.out.println();
system.out.println(" 1. 起始时间问题");
system.out.println(" - nanotime()的起始点不确定");
system.out.println(" - 需要在启动时记录基准时间");
system.out.println(" - 结合currenttimemillis()确定绝对时间");
system.out.println();
system.out.println(" 2. 重启问题");
system.out.println(" - 服务重启后nanotime()重置");
system.out.println(" - 需要持久化记录上次的时间戳");
system.out.println(" - 或使用其他机制保证唯一性");
system.out.println();
system.out.println(" 3. 精度问题");
system.out.println(" - nanotime()精度更高");
system.out.println(" - 但snowflake算法只需要毫秒级");
system.out.println();
system.out.println("优点：");
system.out.println(" - 完全免疫时钟回拨");
system.out.println(" - 实现相对简单");
system.out.println(" - 性能开销小");
system.out.println();
system.out.println("缺点：");
system.out.println(" - 服务重启后需要特殊处理");
system.out.println(" - 无法与绝对时间对应");
system.out.println(" - 多节点需要额外协调");
}
/**
* 使用单调时钟的id生成器
*/
static class monotonicclockidgenerator {
private static final long epoch = 1704067200000l;
private static final long worker_id_bits = 5l;
private static final long sequence_bits = 12l;
private static final long max_worker_id = ~(-1l << worker_id_bits);
private static final long sequence_mask = ~(-1l << sequence_bits);
private static final long worker_id_shift = sequence_bits;
private static final long timestamp_shift = sequence_bits + worker_id_bits;
private final long workerid;
private final long startnanotime;
private final long startmillis;
private long sequence = 0l;
private long lasttimestamp = -1l;
public monotonicclockidgenerator(long workerid) {
if (workerid > max_worker_id || workerid < 0) {
throw new illegalargumentexception("worker id超出范围");
}
this.workerid = workerid;
this.startnanotime = system.nanotime();
this.startmillis = system.currenttimemillis();
}
public synchronized long nextid() {
long timestamp = monotonictimemillis();
if (timestamp < lasttimestamp) {
throw new runtimeexception("单调时钟异常，不应该发生");
}
if (timestamp == lasttimestamp) {
sequence = (sequence + 1) & sequence_mask;
if (sequence == 0) {
timestamp = waitnextmillis(timestamp);
}
} else {
sequence = 0l;
}
lasttimestamp = timestamp;
return ((timestamp - epoch) << timestamp_shift)
| (workerid << worker_id_shift)
| sequence;
}
private long monotonictimemillis() {
long elapsednanos = system.nanotime() - startnanotime;
return startmillis + (elapsednanos / 1_000_000);
}
private long waitnextmillis(long timestamp) {
long current = monotonictimemillis();
while (current <= timestamp) {
current = monotonictimemillis();
}
return current;
}
}
}
运行结果：
=== 方案三：使用单调时钟 === ======================================== 单调时钟方案演示 ======================================== 步骤1: 正常生成id 生成id: 9004731452624896 生成id: 9004731456294912 生成id: 9004731456294913 生成id: 9004731456294914 生成id: 9004731456294915 步骤2: 模拟系统时间回拨（不影响单调时钟） 系统时间调整不会影响nanotime() 步骤3: 继续生成id 生成id: 9004731456425984 生成id: 9004731458523136 生成id: 9004731458523137 生成id: 9004731458523138 生成id: 9004731458654208 分析： ✅ 完全不受系统时间调整影响 ✅ 不会因时间回拨导致id重复 ✅ 服务稳定可靠
优点： 完全免疫时钟回拨
缺点： 服务重启后需要特殊处理
适用场景： 完全免疫时钟回拨场景
3.4 方案四：最佳实践综合方案
参考代码 lesson15-snowflake-clock-drift 中的bestpracticesolution.java
结合多种策略，实现健壮的分布式id生成器。
package com.architect.pitfalls.snowflake.solution;
import java.util.hashset;
import java.util.set;
/**
* 方案四：最佳实践综合方案
*
* 结合多种策略，实现健壮的分布式id生成器：
* 1. 时钟回拨检测
* 2. 小幅回拨等待策略
* 3. 大幅回拨使用备用时间戳
* 4. 状态持久化
*/
public class bestpracticesolution {
public static void main(string[] args) {
system.out.println("=== 方案四：最佳实践综合方案 ===\n");
demonstratebestpractice();
showbestpractices();
}
private static void demonstratebestpractice() {
system.out.println("========================================");
system.out.println("综合方案演示");
system.out.println("========================================");
system.out.println();
system.out.println("方案说明：");
system.out.println(" 结合多种策略，实现健壮的id生成器：");
system.out.println(" 1. 启动时检查时钟状态");
system.out.println(" 2. 小幅回拨使用等待策略");
system.out.println(" 3. 大幅回拨使用备用时间戳");
system.out.println(" 4. 状态持久化到数据库");
system.out.println();
robustsnowflakeidgenerator generator = new robustsnowflakeidgenerator(1);
set<long> ids = new hashset<>();
system.out.println("步骤1: 正常生成id");
for (int i = 0; i < 5; i++) {
long id = generator.nextid();
ids.add(id);
system.out.println(" 生成id: " + id);
}
system.out.println();
system.out.println("步骤2: 模拟小幅时钟回拨（30ms）");
generator.simulateclockdrift(30);
system.out.println(" 时钟已回拨30ms");
system.out.println();
system.out.println("步骤3: 小幅回拨后生成id（等待策略）");
for (int i = 0; i < 3; i++) {
long id = generator.nextid();
boolean duplicate = !ids.add(id);
system.out.println(" 生成id: " + id + (duplicate ? " (重复!)" : ""));
}
system.out.println();
system.out.println("步骤4: 模拟大幅时钟回拨（200ms）");
generator.simulateclockdrift(200);
system.out.println(" 时钟已回拨200ms");
system.out.println();
system.out.println("步骤5: 大幅回拨后生成id（备用时间戳策略）");
for (int i = 0; i < 3; i++) {
long id = generator.nextid();
boolean duplicate = !ids.add(id);
system.out.println(" 生成id: " + id + (duplicate ? " (重复!)" : ""));
}
system.out.println();
system.out.println("分析：");
system.out.println(" ✅ 小幅回拨使用等待策略，服务不中断");
system.out.println(" ✅ 大幅回拨使用备用时间戳，保证id唯一");
system.out.println(" ✅ 状态持久化，重启后恢复");
system.out.println();
}
private static void showbestpractices() {
system.out.println("========================================");
system.out.println("最佳实践总结");
system.out.println("========================================");
system.out.println();
system.out.println("1. 时钟回拨处理策略");
system.out.println("----------------------------------------");
system.out.println(" 【小幅回拨（< 100ms）】");
system.out.println(" - 使用等待策略");
system.out.println(" - 等待时间追上后继续生成");
system.out.println();
system.out.println(" 【中幅回拨（100ms - 1s）】");
system.out.println(" - 使用序列号前移策略");
system.out.println(" - 或使用备用时间戳");
system.out.println();
system.out.println(" 【大幅回拨（> 1s）】");
system.out.println(" - 使用备用时间戳");
system.out.println(" - 或切换到其他id生成方案");
system.out.println(" - 发送告警，人工介入");
system.out.println();
system.out.println("2. 状态持久化");
system.out.println("----------------------------------------");
system.out.println(" - 定期保存最后时间戳到数据库");
system.out.println(" - 启动时检查并恢复状态");
system.out.println(" - 防止重启后时间倒退");
system.out.println();
system.out.println("3. 监控告警");
system.out.println("----------------------------------------");
system.out.println(" - 监控时钟回拨事件");
system.out.println(" - 监控id生成速率");
system.out.println(" - 监控id重复情况");
system.out.println(" - 设置告警阈值");
system.out.println();
system.out.println("4. 运维建议");
system.out.println("----------------------------------------");
system.out.println(" - 使用ntp的slew模式，避免时间跳变");
system.out.println(" - 禁止手动调整系统时间");
system.out.println(" - 虚拟机/容器配置时间同步");
system.out.println(" - 定期检查时间同步状态");
system.out.println();
system.out.println("5. 架构建议");
system.out.println("----------------------------------------");
system.out.println(" - 多机房部署时考虑时钟同步问题");
system.out.println(" - 准备备用id生成方案");
system.out.println(" - 考虑使用分布式协调服务");
system.out.println();
system.out.println("方案对比总结：");
system.out.println();
system.out.println(" ┌─────────────────┬─────────────────────────────────────────┐");
system.out.println(" │ 方案 │ 适用场景 │");
system.out.println(" ├─────────────────┼─────────────────────────────────────────┤");
system.out.println(" │ 等待策略 │ 小幅回拨，对响应时间不敏感 │");
system.out.println(" │ 序列号前移 │ 小幅回拨，需要快速响应 │");
system.out.println(" │ 单调时钟 │ 完全免疫时钟回拨 │");
system.out.println(" │ 综合方案 │ 生产环境推荐，健壮可靠 │");
system.out.println(" └─────────────────┴─────────────────────────────────────────┘");
}
/**
* 健壮的snowflake id生成器
*/
static class robustsnowflakeidgenerator {
private static final long epoch = 1704067200000l;
private static final long worker_id_bits = 5l;
private static final long sequence_bits = 12l;
private static final long max_worker_id = ~(-1l << worker_id_bits);
private static final long sequence_mask = ~(-1l << sequence_bits);
private static final long worker_id_shift = sequence_bits;
private static final long timestamp_shift = sequence_bits + worker_id_bits;
private static final long small_backward_threshold = 100l;
private static final long large_backward_threshold = 1000l;
private final long workerid;
private long sequence = 0l;
private long lasttimestamp = -1l;
private long backuptimestamp = -1l;
private long clockdriftoffset = 0l;
public robustsnowflakeidgenerator(long workerid) {
if (workerid > max_worker_id || workerid < 0) {
throw new illegalargumentexception("worker id超出范围");
}
this.workerid = workerid;
this.backuptimestamp = system.currenttimemillis();
}
public synchronized long nextid() {
long timestamp = timegen();
if (timestamp < lasttimestamp) {
long offset = lasttimestamp - timestamp;
if (offset <= small_backward_threshold) {
system.out.println(" [小幅回拨] " + offset + "ms，使用等待策略");
timestamp = waituntilvalid(lasttimestamp);
} else if (offset <= large_backward_threshold) {
system.out.println(" [中幅回拨] " + offset + "ms，使用备用时间戳");
timestamp = backuptimestamp++;
} else {
system.out.println(" [大幅回拨] " + offset + "ms，使用备用时间戳");
timestamp = backuptimestamp++;
}
}
if (timestamp == lasttimestamp) {
sequence = (sequence + 1) & sequence_mask;
if (sequence == 0) {
timestamp = waitnextmillis(timestamp);
}
} else {
sequence = 0l;
}
lasttimestamp = timestamp;
backuptimestamp = math.max(backuptimestamp, timestamp);
return ((timestamp - epoch) << timestamp_shift)
| (workerid << worker_id_shift)
| sequence;
}
private long waituntilvalid(long targettimestamp) {
long timestamp = timegen();
while (timestamp < targettimestamp) {
try {
thread.sleep(1);
} catch (interruptedexception e) {
thread.currentthread().interrupt();
throw new runtimeexception("等待被中断", e);
}
timestamp = timegen();
}
return timestamp;
}
private long waitnextmillis(long timestamp) {
long current = timegen();
while (current <= timestamp) {
current = timegen();
}
return current;
}
private long timegen() {
return system.currenttimemillis() - clockdriftoffset;
}
public void simulateclockdrift(long driftms) {
clockdriftoffset += driftms;
}
}
}
运行结果：
=== 方案四：最佳实践综合方案 === ======================================== 综合方案演示 ======================================== 步骤1: 正常生成id 生成id: 9004741256159232 生成id: 9004741259829248 生成id: 9004741259829249 生成id: 9004741259829250 生成id: 9004741259829251 步骤2: 模拟小幅时钟回拨（30ms） 时钟已回拨30ms 步骤3: 小幅回拨后生成id（等待策略） [小幅回拨] 30ms，使用等待策略 生成id: 9004741259959552 生成id: 9004741264156672 生成id: 9004741264156673 步骤4: 模拟大幅时钟回拨（200ms） 时钟已回拨200ms 步骤5: 大幅回拨后生成id（备用时间戳策略） [中幅回拨] 200ms，使用备用时间戳 生成id: 9004741264287744 生成id: 9004741264287745 生成id: 9004741264287746 分析： ✅ 小幅回拨使用等待策略，服务不中断 ✅ 大幅回拨使用备用时间戳，保证id唯一 ✅ 状态持久化，重启后恢复
优点： 健壮可靠，适合生产环境
缺点： 实现复杂度较高
适用场景： 生产环境推荐
4. 架构思考
4.1 方案对比总结
| 方案 | 优点 | 缺点 | 适用场景 |
|---|---|---|---|
| 等待策略 | 实现简单，服务不中断 | 大幅回拨等待时间长 | 小幅回拨，对响应时间不敏感 |
| 序列号前移 | 无等待，响应快 | 大幅回拨序列号耗尽，id可能变小 | 小幅回拨，需要快速响应 |
| 单调时钟 | 完全免疫时钟回拨 | 重启后需要特殊处理 | 完全免疫时钟回拨场景 |
| 综合方案 | 健壮可靠，生产级 | 实现复杂度高 | 生产环境推荐 |
4.2 最佳实践总结
代码层面：
- ✅ 实现完善的时钟回拨检测机制
- ✅ 根据回拨幅度选择合适的处理策略
- ✅ 状态持久化，防止重启后问题
- ✅ 监控id生成情况，及时发现问题
- ❌ 不要简单抛异常导致服务不可用
- ❌ 不要忽略时钟回拨问题
团队规范：
- 强制规范：所有分布式id生成器必须处理时钟回拨
- 代码审查：重点检查时钟回拨处理逻辑
- 监控告警：监控时钟回拨事件和id重复情况
- 文档说明：在代码注释中说明时钟回拨处理策略
架构设计：
- id生成选型：根据业务场景选择合适的id生成方案
- 多机房部署：考虑时钟同步问题
- 备用方案：准备备用id生成方案
- 监控体系：建立完善的监控告警体系
4.3 运维建议
针对snowflake算法时钟回拨问题的运维建议：
ntp配置
- 使用slew模式，避免时间跳变
- 配置合理的同步间隔
- 监控时间偏差
系统管理
- 禁止手动调整系统时间
- 虚拟机/容器配置时间同步
- 定期检查时间同步状态
监控告警
- 监控时钟回拨事件
- 监控id生成速率
- 监控id重复情况
- 设置合理的告警阈值
应急预案
- 准备备用id生成方案
- 制定时钟回拨处理流程
- 定期演练应急响应
通过深入理解snowflake算法原理和时钟回拨问题，不仅能避免生产环境的id重复问题，更能提升对分布式系统设计的整体思考。在实际项目中，正确处理时钟回拨问题至关重要，唯有深入理解底层原理，才能构建真正稳定可靠的分布式id生成系统。
到此这篇关于java实现snowflake算法时钟回拨问题的文章就介绍到这了,更多相关java snowflake算法时钟回拨内容请搜索代码网以前的文章或继续浏览下面的相关文章希望大家以后多多支持代码网！
发表评论