+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
|0|                    41位時(shí)間戳                     | 數(shù)據(jù)中心 | 機(jī)器 |   序列號(hào)   |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+

public class SnowflakeIdGenerator {
    // 基準(zhǔn)時(shí)間戳(可自定義)
    private final long epoch = 1609459200000L; // 2021-01-01 00:00:00
    // 各部分的位數(shù)
    private final long workerIdBits = 5L;
    private final long datacenterIdBits = 5L;
    private final long sequenceBits = 12L;
    // 最大值計(jì)算
    private final long maxWorkerId = -1L ^ (-1L << workerIdBits);
    private final long maxDatacenterId = -1L ^ (-1L << datacenterIdBits);
    // 移位偏移量
    private final long workerIdShift = sequenceBits;
    private final long datacenterIdShift = sequenceBits + workerIdBits;
    private final long timestampShift = sequenceBits + workerIdBits + datacenterIdBits;
    // 序列號(hào)掩碼
    private final long sequenceMask = -1L ^ (-1L << sequenceBits);
    // 工作節(jié)點(diǎn)參數(shù)
    private final long workerId;
    private final long datacenterId;
    // 序列號(hào)狀態(tài)
    private long sequence = 0L;
    private long lastTimestamp = -1L;
    /**
     * 構(gòu)造函數(shù)
     * @param workerId 工作節(jié)點(diǎn)ID (0-31)
     * @param datacenterId 數(shù)據(jù)中心ID (0-31)
     */
    public SnowflakeIdGenerator(long workerId, long datacenterId) {
        // 參數(shù)校驗(yàn)
        if (workerId > maxWorkerId || workerId < 0) {
            throw new IllegalArgumentException(
                String.format("Worker ID must be between 0 and %d", maxWorkerId));
        }
        if (datacenterId > maxDatacenterId || datacenterId < 0) {
            throw new IllegalArgumentException(
                String.format("Datacenter ID must be between 0 and %d", maxDatacenterId));
        }
        this.workerId = workerId;
        this.datacenterId = datacenterId;
    }
    /**
     * 生成下一個(gè)ID
     */
    public synchronized long nextId() {
        long timestamp = timeGen();
        // 時(shí)鐘回?fù)芴幚?
        if (timestamp < lastTimestamp) {
            throw new RuntimeException(
                String.format("Clock moved backwards. Refusing to generate id for %d milliseconds", 
                              lastTimestamp - timestamp));
        }
        // 同一毫秒內(nèi)序列號(hào)遞增
        if (lastTimestamp == timestamp) {
            sequence = (sequence + 1) & sequenceMask;
            // 序列號(hào)溢出，等待下一毫秒
            if (sequence == 0) {
                timestamp = tilNextMillis(lastTimestamp);
            }
        } else {
            // 新毫秒序列號(hào)重置
            sequence = 0L;
        }
        lastTimestamp = timestamp;
        // 組裝ID
        return ((timestamp - epoch) << timestampShift)
            | (datacenterId << datacenterIdShift)
            | (workerId << workerIdShift)
            | sequence;
    }
    /**
     * 阻塞到下一毫秒
     */
    protected long tilNextMillis(long lastTimestamp) {
        long timestamp = timeGen();
        while (timestamp <= lastTimestamp) {
            timestamp = timeGen();
        }
        return timestamp;
    }
    /**
     * 獲取當(dāng)前時(shí)間戳
     */
    protected long timeGen() {
        return System.currentTimeMillis();
    }
    /**
     * 解析ID中的信息
     */
    public void parseId(long id) {
        long timestamp = (id >> timestampShift) + epoch;
        long datacenterId = (id >> datacenterIdShift) & maxDatacenterId;
        long workerId = (id >> workerIdShift) & maxWorkerId;
        long sequence = id & sequenceMask;
        System.out.println("ID解析結(jié)果：");
        System.out.println("生成時(shí)間：" + new Date(timestamp));
        System.out.println("數(shù)據(jù)中心ID：" + datacenterId);
        System.out.println("工作節(jié)點(diǎn)ID：" + workerId);
        System.out.println("序列號(hào)：" + sequence);
    }
}

public synchronized long nextId() {
    long timestamp = timeGen();
    // 增強(qiáng)的時(shí)鐘回?fù)芴幚?
    if (timestamp < lastTimestamp) {
        long offset = lastTimestamp - timestamp;
        if (offset <= 5) {
            // 小范圍回?fù)?，等?
            try {
                wait(offset << 1); // 等待兩倍偏移時(shí)間
                timestamp = timeGen();
                if (timestamp < lastTimestamp) {
                    throw new RuntimeException("時(shí)鐘回?fù)芴幚硎?);
                }
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
                throw new RuntimeException("時(shí)鐘回?fù)艿却恢袛?, e);
            }
        } else {
            // 大范圍回?fù)?，直接?bào)錯(cuò)
            throw new RuntimeException(String.format(
                "嚴(yán)重時(shí)鐘回?fù)埽?d毫秒，系統(tǒng)時(shí)間可能被手動(dòng)調(diào)整", offset));
        }
    }
    // ...其余邏輯不變
}

// 使用ThreadLocalRandom替代同步塊
private long nextIdOptimized() {
    long timestamp = timeGen();
    if (timestamp < lastTimestamp.get()) {
        throw new RuntimeException("時(shí)鐘回?fù)?);
    }
    // 時(shí)間戳相同則增加序列號(hào)
    if (timestamp == lastTimestamp.get()) {
        sequence.set((sequence.get() + 1) & sequenceMask);
        if (sequence.get() == 0) {
            timestamp = tilNextMillis(lastTimestamp.get());
        }
    } else {
        // 時(shí)間戳變化，重置序列號(hào)
        sequence.set(ThreadLocalRandom.current().nextInt(100));
    }
    lastTimestamp.set(timestamp);
    return ((timestamp - epoch) << timestampShift)
        | (datacenterId << datacenterIdShift)
        | (workerId << workerIdShift)
        | sequence.get();
}

// 例如：調(diào)整時(shí)間戳為秒級(jí)，增加序列號(hào)位數(shù)
private final long timestampBits = 32L;  // 約136年
private final long sequenceBits = 20L;   // 每秒100萬ID