redis數(shù)據(jù)庫(kù)怎么利用go-redis實(shí)現(xiàn)一個(gè)分布式鎖

發(fā)布時(shí)間：2020-12-10 14:18:49 來(lái)源：億速云閱讀：672 作者：Leah 欄目：開發(fā)技術(shù)

這篇文章給大家介紹redis數(shù)據(jù)庫(kù)怎么利用go-redis實(shí)現(xiàn)一個(gè)分布式鎖，內(nèi)容非常詳細(xì)，感興趣的小伙伴們可以參考借鑒，希望對(duì)大家能有所幫助。

分布式鎖的幾個(gè)原則;

1.「鎖的互斥性」：在分布式集群應(yīng)用中，共享資源的鎖在同一時(shí)間只能被一個(gè)對(duì)象獲取。

2. 「可重入」：為了避免死鎖，這把鎖是可以重入的，并且可以設(shè)置超時(shí)。

3. 「高效的加鎖和解鎖」：能夠高效的加鎖和解鎖，獲取鎖和釋放鎖的性能也好。

4. 「阻塞、公平」：可以根據(jù)業(yè)務(wù)的需要，考慮是使用阻塞、還是非阻塞，公平還是非公平的鎖。

redis實(shí)現(xiàn)分布式鎖主要靠setnx命令

1. 當(dāng)key存在時(shí)失敗 , 保證互斥性

2.設(shè)置了超時(shí) , 避免死鎖

3.利用mutex保證當(dāng)前程序不存在并發(fā)沖突問題

package redis

import (
 "context"
 "github.com/go-redis/redis/v8"
 "github.com/taoshihan1991/miaosha/setting"
 "log"
 "sync"
 "time"
)

var rdb *redis.Client
var ctx = context.Background()
var mutex sync.Mutex

func NewRedis() {
 rdb = redis.NewClient(&redis.Options{
  Addr:  setting.Redis.Ip + ":" + setting.Redis.Port,
  Password: "", // no password set
  DB:  0, // use default DB
 })
}
func Lock(key string) bool {
 mutex.Lock()
 defer mutex.Unlock()
 bool, err := rdb.SetNX(ctx, key, 1, 10*time.Second).Result()
 if err != nil {
  log.Println(err.Error())
 }
 return bool
}
func UnLock(key string) int64 {
 nums, err := rdb.Del(ctx, key).Result()
 if err != nil {
  log.Println(err.Error())
  return 0
 }
 return nums
}

關(guān)于redis數(shù)據(jù)庫(kù)怎么利用go-redis實(shí)現(xiàn)一個(gè)分布式鎖就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，可以學(xué)到更多知識(shí)。如果覺得文章不錯(cuò)，可以把它分享出去讓更多的人看到。

向AI問一下細(xì)節(jié)

redis數(shù)據(jù)庫(kù)怎么利用go-redis實(shí)現(xiàn)一個(gè)分布式鎖

猜你喜歡

最新資訊

相關(guān)推薦

相關(guān)標(biāo)簽