redsync 锁获取失败：panic: redsync: failed to acquire lock
在使用 go-redsync 执行分布式锁时，遇到错误 "panic: redsync: failed to acquire lock"。本文将探讨该错误的原因并提供解决方案。
go-redsync 提供了一个分布式锁，用于协调多个 goroutine 对共享资源的访问。然而，如果您发现第二个 goroutine 执行时发生错误，可能是由于以下原因：
redsync 锁重试限制
redsync 的分布式锁具有内置的重试机制。如果在尝试获取锁时遇到冲突，它将尝试重试多次。但是，重试次数并不是无限的。如果在指定重试次数后仍无法获取锁，redsync 将抛出 errfailed 错误，这将导致 panic。
解决方案：
要解决这个问题，可以尝试以下方法：
- 增加重试次数： 您可以在创建 redsync 实例时设置自定义重试策略，以增加重试次数。
- 使用非阻塞锁： 您可以使用 redsync 提供的非阻塞锁，它将在不获取锁的情况下返回。
- 使用过期时间： 您可以设置锁的过期时间，以防止长时间持有锁而导致死锁。
- 优化 goroutine 并发性： 如果可能，请尝试减少同时尝试获取锁的 goroutine 数量，以降低冲突的可能性。
代码示例：
package main
import (
"fmt"
"sync"
"time"
goredislib "github.com/go-redis/redis/v8"
"github.com/go-redsync/redsync/v4"
"github.com/go-redsync/redsync/v4/redis/goredis/v8"
)
func main() {
var wg sync.WaitGroup
for i := 0; i < 3; i++ {
wg.Add(1)
go RedisLock(&wg)
}
wg.Wait()
}
func RedisLock(wg *sync.WaitGroup) {
defer wg.Done()
redisAddr := "192.168.31.51:6379"
client := goredislib.NewClient(&goredislib.Options{
Addr: redisAddr,
Password: "123456",
})
pool := goredis.NewPool(client)
// 自定义重试策略
retryPolicy := redsync.ExponentialBackoff(1000, 500*time.Millisecond)
rs := redsync.New(pool, redsync.Options{RetryPolicy: retryPolicy})
mutexname := "product@1"
mutex := rs.NewMutex(mutexname)
fmt.Println("Start Lock...")
err := mutex.Lock()
if err != nil {
// 处理错误
}
fmt.Println("Get Lock!")
time.Sleep(time.Second * 3)
fmt.Println("Unlock!")
ok, err := mutex.Unlock()
if !ok {
// 处理错误
}
if err != nil {
// 处理错误
}
fmt.Println("Release Lock!")
} 
