一个实现 Twitter SnowFlake 算法 的 Go 分布式 UID 生成器

[zhengji]

根据 Twitter SnowFlake 算法, 实现的分布式线程安全 UID 生成器

源码地址：https://github.com/zheng-ji/goSnowFlake

Feature

• 线程安全的 UID 生成器
• 绿色可插拔，无需依赖 Redis,Mysql,无状态
• 适合分布式系统
• 实现 Twitter SnowFlake 理论

Description

0               41             51           64
+---------------+----------------+-----------+
|timestamp(ms)  | worker node id | sequence  |
+---------------+----------------+-----------+

id  = timestamp | workerid | sequence (eg. 1451063443347648410)

由三部分与运算组合而成，分别是毫秒级别的时间戳，机器 workerid, 以及为了解决冲突的序列号

Installation

go get github.com/zheng-ji/goSnowFlake

Example

import (
    "fmt"
    "github.com/zheng-ji/goSnowFlake"
)

func main() {
    // Params: Given the workerId, 0 < workerId < 1024
    iw, err := goSnowFlake.NewIdWorker(1) 
    if err!= nil {
        fmt.Println(err)
    }
    for i := 0; i < 100; i++ {
        if id, err := iw.NextId(); err != nill {
            fmt.Println(id)
        }
    }
}

Documentation

• Twitter Blog Reference
• Reddit Discuss

[barbery]

好像很犀利的样子

[forsigner]

这个 UID 跟 GUID 和 UUID 有什么区别？

[JiShuTui]

@forsigner 你了解一下 Twitter SnowFlake 就知道了

[leedstyh]

不错， star 了，目前把`mgo`里面的 ObjectID 的算法提出来了在用，下个项目试试这个！

[forsigner]

@JiShuTui 好的哈

[zieglar]

似乎无法反推是哪个 worker 生成的？

[sakeven]

// Listen and Server in 0.0.0.0:8080
r.Run(":8182")

注释和写的不一样 - -

[zhengji]

@sakeven 恩恩多谢，已改

[zhengji]

@zieglar 这个是不能反推的

[devtiange]

@zhengji 问一下为什么不能反推? 取出 worker node 那段不行吗?

[zhengji]

@devtiange 毫秒时间戳，以及序列号你都是不知道的 ，就类似三元一次方程里面， 3 个未知数，我的理解是，无法求解， x+y+z = A

[devtiange]

@zhengji 从你的描述上来看, worker node 的信息是在 41 - 51 位.
我从 64bit 里拿出这 10 位, 不就能知道 worker node 了吗? 不知道是哪里理解的不对?

[zhengji]

@devtiange sorry,我理解错你的意思了，你这样说是对的。可以递推回的。

[leedstyh]

`ts - CEpoch<<CTimeStampShift | iw.workerId<<CWorkerIdShift | iw.sequence`

这段和 Twitter 原来的算法不太一样呢