分布式鎖一般有三種實(shí)現(xiàn)方式：1. 數(shù)據(jù)庫樂觀鎖；2. 基于Redis的分布式鎖；3. 基于ZooKeeper的分布式鎖。本篇博客將介紹第二種方式，基于Redis實(shí)現(xiàn)分布式鎖。雖然網(wǎng)上已經(jīng)有各種介紹Redis分布式鎖實(shí)現(xiàn)的博客，然而他們的實(shí)現(xiàn)卻有著各種各樣的問題，為了避免誤人子弟，本篇博客將詳細(xì)介紹如何正確地實(shí)現(xiàn)Redis分布式鎖。

項(xiàng)目地址： https://github.com/Spongecaptain/redisLock

1. Go 原生的互斥鎖

Go 原生的互斥鎖即 sync 包下的 Mutex 結(jié)構(gòu)體，利用此結(jié)構(gòu)體的 Lock 以及 Unlock 方法能夠?qū)崿F(xiàn)鎖的占據(jù)以及釋放。

關(guān)于 sync.Mutex，我們可以總結(jié)出如下的特性：

• 支持自旋鎖，在并發(fā)沖突不嚴(yán)重的背景下提高鎖的使用效率；
• 支持鎖的公平性，能夠避免鎖導(dǎo)致的線程饑餓問題；
• 不支持鎖的重入，持有鎖的協(xié)程再次申請鎖資源會導(dǎo)致死鎖；
• 任何協(xié)程都可以調(diào)用 Mutex.Unlock 方法來解鎖，并不只允許占據(jù)鎖資源的協(xié)程進(jìn)行解鎖；
• 不支持超時(shí)鎖獲取，也不支持 TryLock 機(jī)制

Go 語言中 sync.Mutex 的特性與 Java 中 java.util.concurrent.locks.Lock 相比，API 語義簡單不少，這也符合 Go 語言對于簡單化的追求。

下面看看本項(xiàng)目-基于 Redis 的分布式鎖能夠提供哪些分布鎖特性。

2. redisLock 的特性

github-redisLock 是一個(gè)基于 go-redis/redis 客戶端的 Redis 分布式鎖。其擁有的如下的特性：

• 原子性：利用 Lua 腳本實(shí)現(xiàn)原子性語義；
• 阻塞喚醒：利用 Redis 的發(fā)布訂閱來實(shí)現(xiàn)鎖的阻塞喚醒；
• 鎖自動過期：避免因?yàn)殄礄C(jī)導(dǎo)致的死鎖問題；
• 鎖的自動續(xù)期：利用 Go 協(xié)程實(shí)現(xiàn)鎖資源的自動續(xù)期，避免出現(xiàn)業(yè)務(wù)時(shí)間>鎖超時(shí)時(shí)間導(dǎo)致并發(fā)安全問題
• TryLock：嘗試獲取一次鎖，獲取失敗后阻塞
• 自旋鎖：提供自旋鎖 API 來實(shí)現(xiàn)分布式鎖的自旋獲取
  

github-redisLock 同時(shí)不支持如下特性：

重入性：分布式鎖不可重入，Go 語言并沒有優(yōu)雅的方式來實(shí)現(xiàn) Java 中的 ThreadLocal 機(jī)制
非公平性：分布式鎖存在非公平問題，在極端情況下會導(dǎo)致饑餓問題

3. Quick Start

Install redisLock:

go get github.com/Spongecaptain/redisLock

Create redis client:

import(
 "github.com/go-redis/redis"
)
var redisClient = redis.NewClient(&redis.Options{
 Addr:     "localhost:6379",
 Password: "", // no password set
 DB:       0,  // use default DB
})

Create redisLock:

key := "reids-lock-key"
value := "redis-lock-value"
lock := redisLock.NewRedisLock(redisClient, key, value)

err := lock.Lock()
if err != nil {
  fmt.Println(err.Error())
  return
}
fmt.Println("get redis lock success")
defer func() {
  err = lock.Unlock()
  if err != nil {
    fmt.Println(err.Error())
    return
  }
  fmt.Println("release redis lock success")
}()

4. API 說明

（1）構(gòu)造分布式鎖實(shí)例
利用 NewRedisLock 以及 NewRedisLockWithExpireTime 函數(shù)能夠構(gòu)造出一個(gè)分布式鎖實(shí)例，NewRedisLockWithExpireTime 的區(qū)別在于其能夠自定義鎖的過期時(shí)間。

NewRedisLock 方法接收的 key 決定了分布式鎖的粒度，value 決定了只有 value 值相同才能夠進(jìn)行解鎖。

（2）TryLock
TryLock 僅嘗試一次鎖的獲取，如果失敗，那么不會阻塞，直接返回。

（3）Lock
Lock 會不斷嘗試索取分布式鎖，這會導(dǎo)致調(diào)用此方法的協(xié)程阻塞。

（4）Unlock
Unlock 方法用于解鎖，由于涉及網(wǎng)絡(luò)通信，解鎖可能失敗， error!=nil 意味著解鎖失敗。

（5）LockWithTimeout
Lock 方法會在獲取鎖資源成功或者超時(shí)后返回。

（6）SpinLock
支持指定次數(shù)地進(jìn)行自旋式的鎖獲取。

以上就是Go 語言下基于 Redis 的分布式鎖的詳細(xì)內(nèi)容，更多關(guān)于Go 分布式鎖的資料請關(guān)注腳本之家其它相關(guān)文章！

最新評論