go-redsync/redsync/v4 是一个 Go 语言的分布式锁库，它基于 Redis 实现了一个强大的、可靠的分布式锁机制。这个库可以用于在分布式系统中管理共享资源的访问，避免多个实例或进程同时访问同一资源而导致的数据不一致或冲突。
Life is like a journey
go-redsync 支持多个 Redis 实例来提高容错性。要使用 go-redsync/redsync/v4 库，首先需要通过 Go Modules 安装该库：
go get github.com/go-redsync/redsync/v4
Redsync 实例首先，导入 go-redsync/redsync/v4 库，并初始化 Redis 连接池。Redsync 对象是进行分布式锁操作的核心。
package main
import (
"fmt"
"github.com/go-redsync/redsync/v4"
"github.com/go-redis/redis/v8"
"log"
"time"
"context"
)
var redisClient *redis.Client
func main() {
// 创建 Redis 客户端
redisClient = redis.NewClient(&redis.Options{
Addr: "localhost:6379", // Redis 服务器地址
})
// 创建 Redsync 实例
rs := redsync.New([]redis.UniversalClient{redisClient})
// 获取锁
mutex := rs.NewMutex("mylock")
// 尝试获取锁
if err := mutex.Lock(); err != nil {
log.Fatalf("could not acquire lock: %v", err)
}
// 模拟工作
fmt.Println("Lock acquired! Performing work...")
time.Sleep(5 * time.Second)
// 释放锁
if err := mutex.Unlock(); err != nil {
log.Fatalf("could not release lock: %v", err)
}
fmt.Println("Lock released!")
}
在上面的示例中，我们创建了一个 mutex 锁对象。锁的获取和释放非常简单：
mutex.Lock() 来获取锁。如果锁已经被其他实例持有，当前实例会阻塞，直到获取到锁。mutex.Unlock() 来释放锁。一般来说，锁会在持有锁的操作完成后被释放。为了避免死锁问题，go-redsync/redsync 库允许你设置锁的超时时间。如果一个实例在持有锁后崩溃或无法正常释放锁，其他实例会在超时时间后自动尝试获取锁。
// 创建锁并设置过期时间（例如，5秒）
mutex := rs.NewMutex("mylock", redsync.WithExpiry(5*time.Second))
// 获取锁
if err := mutex.Lock(); err != nil {
log.Fatalf("could not acquire lock: %v", err)
}
// 释放锁
if err := mutex.Unlock(); err != nil {
log.Fatalf("could not release lock: %v", err)
}
在上面的代码中，WithExpiry(5*time.Second) 表示如果锁在 5 秒内没有释放，其他实例将可以获取该锁。
go-redsync 提供了两种方式来获取锁：
mutex.Lock() 会一直阻塞，直到成功获取锁。mutex.TryLock() 来尝试获取锁。如果锁已经被其他实例持有，TryLock() 会立即返回 false，而不是阻塞当前实例。// 尝试获取锁，如果无法获取则立即返回
if locked, err := mutex.TryLock(); err != nil || !locked {
if err != nil {
log.Fatalf("could not acquire lock: %v", err)
}
log.Println("Lock not acquired")
} else {
// 成功获取锁
fmt.Println("Lock acquired!")
time.Sleep(5 * time.Second) // 模拟工作
// 释放锁
if err := mutex.Unlock(); err != nil {
log.Fatalf("could not release lock: %v", err)
}
fmt.Println("Lock released!")
}
go-redsync 也支持锁的重试机制。你可以在无法立即获取锁时设置重试次数和间隔时间。例如，如果某个进程正在持有锁，其他进程可以根据配置尝试获取锁。
// 创建锁并设置重试配置
mutex := rs.NewMutex("mylock", redsync.WithRetryDelay(100*time.Millisecond), redsync.WithRetryMax(3))
// 尝试获取锁
if err := mutex.Lock(); err != nil {
log.Fatalf("could not acquire lock: %v", err)
}
fmt.Println("Lock acquired!")
// 释放锁
if err := mutex.Unlock(); err != nil {
log.Fatalf("could not release lock: %v", err)
}
默认情况下，go-redsync 中的分布式锁是不可重入的，这意味着一个已经持有锁的进程无法再次获取同样的锁。如果你需要锁的可重入性，可以通过 WithRetryDelay 和 WithRetryMax 配置来控制重试策略。
go-redsync 支持多个 Redis 实例，这对于高可用性和容错性非常有帮助。如果一个 Redis 实例不可用，go-redsync 会自动尝试其他 Redis 实例。
rs := redsync.New([]redis.UniversalClient{
redis.NewClient(&redis.Options{Addr: "localhost:6379"}),
redis.NewClient(&redis.Options{Addr: "localhost:6380"}),
})
go-redsync 适合用于分布式系统中需要协调访问共享资源的场景，例如：
go-redsync/redsync/v4 是一个高效、易用的分布式锁库，主要特点包括：
它广泛适用于需要在分布式系统中进行资源管理的场景，如分布式任务调度、分布式计数器等。