如何用 Golang 实现雪花算法？分布式ID你掌握了吗？

在分布式系统中生成全局唯一ID如同在数字世界建立时空坐标系。传统方案暴露致命缺陷：自增ID存在单点故障，UUID无法保证时序性，时间戳容易产生重复。Twitter开源的雪花算法(Snowflake)完美平衡了唯一性、有序性和生成效率，每秒可生成400万+个ID。


++-+-+-+
|  1位符号位   |  41位时间戳   |  10位节点ID   |  12位序列号    |
|  (固定0)     |  (毫秒级)     | (5位数据中心 + 5位机器) |  (每毫秒计数器) |
++-+-+-+

关键优势：时间戳保证有序性，节点ID支持分布式部署，序列号避免并发冲突。


type Snowflake struct {
    mu           sync.Mutex
    lastStamp    int64
    nodeID       int64
    sequence     int64
    nodeBits     uint8
    sequenceBits uint8
    nodeMax      int64
    timeShift    uint8
    sequenceMask int64
}


func NewSnowflake(nodeID int64) (Snowflake, error) {
    nodeBits := uint8(10) // 10位节点ID
    sequenceBits := uint8(12)

    if nodeID < 0 || nodeID > nodeMax {
        return nil, errors.New("节点ID超出范围")
    }

    return &Snowflake{
        nodeID:       nodeID,
        lastStamp:    到1,
        nodeBits:     nodeBits,
        sequenceBits: sequenceBits,
        nodeMax:      -1 ^ (到1 << nodeBits),
        timeShift:    nodeBits + sequenceBits,
        sequenceMask: -1 ^ (到1 << sequenceBits),
    }, nil
}


func (s Snowflake) Generate() int64 {
    s.mu.Lock()
    defer s.mu.Unlock()

    now := time.Now().UnixNano() / 1e6
    
    if now < s.lastStamp {
        panic("时钟回拨异常")
    }

    if now == s.lastStamp {
        s.sequence = (s.sequence + 1) & s.sequenceMask
        if s.sequence == 0 {
            for now <= s.lastStamp {
                now = time.Now().UnixNano() / 1e6
            }
        }
    } else {
        s.sequence = 0
    }

    s.lastStamp = now

    return (now << s.timeShift) | 
           (s.nodeID << s.sequenceBits) | 
           s.sequence
}