V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
爱意满满的作品展示区。
zhengji
V2EX  ›  分享创造

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

  •  
  •   zhengji ·
    zheng-ji · 2016-03-06 09:22:38 +08:00 · 3881 次点击
    这是一个创建于 3186 天前的主题,其中的信息可能已经有所发展或是发生改变。

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

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

    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

    14 条回复    2016-03-17 11:09:58 +08:00
    barbery
        1
    barbery  
       2016-03-06 11:37:28 +08:00
    好像很犀利的样子
    forsigner
        2
    forsigner  
       2016-03-06 12:48:36 +08:00
    这个 UID 跟 GUID 和 UUID 有什么区别?
    JiShuTui
        3
    JiShuTui  
       2016-03-06 12:59:17 +08:00   ❤️ 1
    @forsigner 你了解一下 Twitter SnowFlake 就知道了
    leedstyh
        4
    leedstyh  
       2016-03-06 13:19:11 +08:00   ❤️ 1
    不错, star 了,目前把`mgo`里面的 ObjectID 的算法提出来了在用,下个项目试试这个!
    forsigner
        5
    forsigner  
       2016-03-06 15:44:04 +08:00
    @JiShuTui 好的哈
    zieglar
        6
    zieglar  
       2016-03-06 18:20:02 +08:00   ❤️ 1
    似乎无法反推是哪个 worker 生成的?
    sakeven
        7
    sakeven  
       2016-03-06 19:40:03 +08:00   ❤️ 1
    // Listen and Server in 0.0.0.0:8080
    r.Run(":8182")

    注释和写的不一样 - -
    zhengji
        8
    zhengji  
    OP
       2016-03-06 21:01:12 +08:00
    @sakeven 恩恩多谢,已改
    zhengji
        9
    zhengji  
    OP
       2016-03-08 09:10:29 +08:00
    @zieglar 这个是不能反推的
    devtiange
        10
    devtiange  
       2016-03-09 08:49:08 +08:00
    @zhengji 问一下为什么不能反推? 取出 worker node 那段不行吗?
    zhengji
        11
    zhengji  
    OP
       2016-03-09 10:48:05 +08:00
    @devtiange 毫秒时间戳,以及序列号你都是不知道的 ,就类似三元一次方程里面, 3 个未知数,我的理解是,无法求解, x+y+z = A
    devtiange
        12
    devtiange  
       2016-03-10 23:56:20 +08:00   ❤️ 1
    @zhengji 从你的描述上来看, worker node 的信息是在 41 - 51 位.
    我从 64bit 里拿出这 10 位, 不就能知道 worker node 了吗? 不知道是哪里理解的不对?
    zhengji
        13
    zhengji  
    OP
       2016-03-11 22:42:04 +08:00
    @devtiange sorry,我理解错你的意思了,你这样说是对的。可以递推回的。
    leedstyh
        14
    leedstyh  
       2016-03-17 11:09:58 +08:00
    `ts - CEpoch<<CTimeStampShift | iw.workerId<<CWorkerIdShift | iw.sequence`

    这段和 Twitter 原来的算法不太一样呢
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   实用小工具   ·   5678 人在线   最高记录 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 25ms · UTC 01:42 · PVG 09:42 · LAX 17:42 · JFK 20:42
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.