bsm/redislock 是一个用于 在 Go 语言中实现基于 Redis 的分布式锁（distributed lock） 的开源库，由 bsm 组织开发和维护。
它实现了基于 Redis 的 SET NX PX 命令模式的分布式锁，兼容 Redlock 算法的核心思想，但更简单和轻量。
Life is like a journey
SET resource-name value NX PX max-lock-time 模式go get github.com/bsm/redislock
import (
"context"
"fmt"
"log"
"time"
"github.com/bsm/redislock"
"github.com/redis/go-redis/v9"
)
func main() {
// Connect to redis.
client := redis.NewClient(&redis.Options{
Network: "tcp",
Addr: "127.0.0.1:6379",
})
defer client.Close()
// Create a new lock client.
locker := redislock.New(client)
ctx := context.Background()
// Try to obtain lock.
lock, err := locker.Obtain(ctx, "my-key", 100*time.Millisecond, nil)
if err == redislock.ErrNotObtained {
fmt.Println("Could not obtain lock!")
} else if err != nil {
log.Fatalln(err)
}
// Don't forget to defer Release.
defer lock.Release(ctx)
fmt.Println("I have a lock!")
// Sleep and check the remaining TTL.
time.Sleep(50 * time.Millisecond)
if ttl, err := lock.TTL(ctx); err != nil {
log.Fatalln(err)
} else if ttl > 0 {
fmt.Println("Yay, I still have my lock!")
}
// Extend my lock.
if err := lock.Refresh(ctx, 100*time.Millisecond, nil); err != nil {
log.Fatalln(err)
}
// Sleep a little longer, then check.
time.Sleep(100 * time.Millisecond)
if ttl, err := lock.TTL(ctx); err != nil {
log.Fatalln(err)
} else if ttl == 0 {
fmt.Println("Now, my lock has expired!")
}
}
你可以对锁进行续期以延长其有效期：
err := lock.Refresh(ctx, 10*time.Second, nil)
RetryStrategy：设置重试策略（如使用 backoff 重试机制）Metadata：设置锁的元数据（可选）示例：
opts := &redislock.Options{
RetryStrategy: redislock.LinearBackoff(500 * time.Millisecond),
}
lock, err := locker.Obtain(ctx, "my-key", 10*time.Second, opts)
ok, err := lock.Valid(ctx)
如果 ok == false，表示锁已经过期或被其他客户端释放/抢占。