GoLang分布式鎖與snowflake雪花算法

更新時間：2022年12月22日 16:07:28 作者：alwaysrun

這篇文章主要介紹了GoLang分布式鎖與snowflake雪花算法，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧

分布式id生成器

Snowflake（雪花算法），由Twitter提出并開源，可在分布式環(huán)境下用于生成唯一ID的算法。

生成的Id是64位（int64）數(shù)值類型，包含4部分：

41bit的時間戳（毫秒）：一般是相對系統(tǒng)上線時間的毫秒數(shù)（可用69年）；
5bit的數(shù)據(jù)中心id+5bit的機器id：表示工作的計算機；實際使用時可根據(jù)情況調整兩者間的比例；
12bit序列號：區(qū)分同一個計算機在相同毫秒時間內的生產(chǎn)的ID（支持1毫秒4096條）；

github.com/bwmarrin/snowflake提供了一個輕量級的實現(xiàn)：

package main
import (
    "fmt"
    "github.com/bwmarrin/snowflake"
	"time"
)
func main() {
    n, err := snowflake.NewNode(time.Now().UnixMilli() % 1024)
    if err != nil {
        fmt.println(err)
        os.Exit(1)
    }
    for i := 0; i < 10; i++ {
        id := n.Generate()
        fmt.Println("id", id.Int64())
        fmt.Println(
            "node: ", id.Node(),
            "step: ", id.Step(),
            "time: ", id.Time(),
        )
    }
}

分布式鎖

可通過redis的setnx來模擬分布式鎖：

設定成功時，為上鎖；
釋放鎖時，刪除對應的鍵；

import (
    "fmt"
    "sync"
    "time"
    "github.com/go-redis/redis"
)
func incr() {
    client := redis.NewClient(&redis.Options{
        Addr:     "localhost:6379",
        Password: "", // no password set
        DB:       0,  // use default DB
    })
    var lockKey = "counter_lock"
    var counterKey = "counter"
    // lock
    resp := client.SetNX(lockKey, 1, time.Second*5)
    lockSuccess, err := resp.Result()
    if err != nil || !lockSuccess {
        fmt.Println(err, "lock result: ", lockSuccess)
        return
    }
    // counter ++
    getResp := client.Get(counterKey)
    cntValue, err := getResp.Int64()
    if err == nil {
        cntValue++
        resp := client.Set(counterKey, cntValue, 0)
        _, err := resp.Result()
        if err != nil {
            // log err
            println("set value error!")
        }
    }
    println("current counter is ", cntValue)
    // unlock
    delResp := client.Del(lockKey)
    unlockSuccess, err := delResp.Result()
    if err == nil && unlockSuccess > 0 {
        println("unlock success!")
    } else {
        println("unlock failed", err)
    }
}

也可通過zookeeper或etcd來模擬；