GoLang分布式鎖與snowflake雪花算法

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

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

分布式id生成器

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

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

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

github.com/bwmarrin/snowflake提供了一個(gè)輕量級(jí)的實(shí)現(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(),
        )
    }
}

分布式鎖

可通過(guò)redis的setnx來(lái)模擬分布式鎖：

設(shè)定成功時(shí)，為上鎖；
釋放鎖時(shí)，刪除對(duì)應(yīng)的鍵；

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)
    }
}

也可通過(guò)zookeeper或etcd來(lái)模擬；