go-redislock 是一个由 jefferyjob 开发的 Go 语言库，用于在分布式环境中实现基于 Redis 的高性能分布式锁。它提供了可靠的并发控制机制，确保多个节点在访问共享资源时的数据一致性和资源互斥。
使用以下命令安装 go-redislock：
Life is like a journey
go get -u github.com/jefferyjob/go-redislock
package main
import (
"context"
"fmt"
redislock "github.com/jefferyjob/go-redislock"
"github.com/redis/go-redis/v9"
)
func main() {
// 创建 Redis 客户端
redisClient := redis.NewClient(&redis.Options{
Addr: "localhost:6379",
Password: "",
DB: 0,
})
// 创建一个上下文，用于取消锁操作
ctx := context.Background()
// 创建 RedisLock 对象
lock := redislock.New(ctx, redisClient, "test_key")
// 获取锁
err := lock.Lock()
if err != nil {
fmt.Println("锁获取失败：", err)
return
}
defer lock.UnLock() // 解锁
// 在锁定期间执行任务
// ...
fmt.Println("任务执行完成")
}
您可以通过使用 WithToken 选项在自定义锁的token功能：
lock := redislock.New(ctx, redisClient, redislock.WithToken("your token") )
您可以通过使用 WithTimeout 选项在自定义锁的超时时间功能：
lock := redislock.New(ctx, redisClient, redislock.WithTimeout(time.Duration(10) * time.Second) )
您可以通过使用 WithAutoRenew 选项在获取锁时启用自动续约功能：
lock := redislock.New(ctx, redisClient, redislock.WithAutoRenew() )
当使用自动续约时，锁会在获取后自动定期续约，以防止锁过期。要手动续约锁，可以调用 Renew 方法。
自旋锁是一种尝试在锁可用之前反复获取锁的方式，可以使用 SpinLock 方法来实现自旋锁：
err := lock.SpinLock(time.Duration(5) * time.Second) // 尝试获取锁，最多等待5秒 if err != nil { fmt.Println("自旋锁超时：", err) return } defer lock.UnLock() // 解锁 // 在锁定期间执行任务 // ...
如果您希望手动释放锁而不等待锁超时，您可以使用 UnLock 方法：
err := lock.Lock() if err != nil { fmt.Println("锁获取失败：", err) return } // 执行任务 err = lock.UnLock() // 手动释放锁 if err != nil { fmt.Println("锁释放失败：", err) return }