原文地址: https://pkg.go.dev/github.com/go-redsync/redsync/v4#section-readme
package main
import (
goredislib "github.com/redis/go-redis/v9"
"github.com/go-redsync/redsync/v4"
"github.com/go-redsync/redsync/v4/redis/goredis/v9"
)
func main() {
// 使用go-redis(或redigo)创建池,这是redisync在与Redis通信时将使用的池。
//这也可以是实现`redis.Pool`接口的任何池。
client := goredislib.NewClient(&goredislib.Options{
Addr: "192.168.182.128:6379",
Password: "1234",
})
pool := goredis.NewPool(client) // or, pool := redigo.NewPool(...)
// 创建要用于获取互斥锁的redisync实例。
rs := redsync.New(pool)
// 通过对需要相同锁的所有实例使用相同的名称来获取新的互斥体。
mutexname := "my-global-mutex"
mutex := rs.NewMutex(mutexname)
//获取给定互斥体的锁。 成功后,在我们解锁之前,其他任何人都不能获得相同的锁(相同的互斥体名称)。.
if err := mutex.Lock(); err != nil {
panic(err)
}
// 我们的业务代码
// 释放锁,以便其他进程或线程可以获得锁。
if ok, err := mutex.Unlock(); !ok || err != nil {
panic("unlock failed")
}
}