分布式锁
进程内与 Redis/etcd 分布式锁
在线 Playground
在浏览器中直接体验本页相关 API，无需本地安装 Go 环境。
分布式锁
统一 Lock 接口，支持 mutex、Redis、etcd、PostgreSQL 等后端。
go get github.com/LingByte/ling-base/common/lock
go get github.com/LingByte/ling-base/common/lock/redis以下为
common/lock包 README 全文。
Unified distributed locking for Go services. All backends implement the same lock.Locker interface:
Lock(ctx)— block until acquired or context cancelledTryLock(ctx)— single attemptUnlock(ctx)— releaseRefresh(ctx)— extend lease where supported
Shared configuration uses functional options: WithTTL, WithRetryDelay, and WithValue (auto-generated token when empty).
On-demand modules
| Module path | Third-party deps |
|---|---|
github.com/LingByte/ling-base/common/lock | none (+ lock/memory) |
.../lock/redis | go-redis |
.../lock/redlock | lock/redis |
.../lock/etcd | etcd clientv3 |
.../lock/zookeeper | go-zookeeper/zk |
.../lock/consul | hashicorp/consul/api |
.../lock/mysql | database/sql only |
.../lock/postgres | database/sql only |
go get github.com/LingByte/ling-base/common/lock/redisBackends
| Package | Use case | TTL / lease | Refresh |
|---|---|---|---|
memory | Process-local (tests, single instance) | In-memory expiry | Yes |
redis | Single Redis node (SET NX + Lua unlock/refresh) | Required | Yes |
redlock | Multiple Redis nodes (quorum) | Required | Yes (quorum) |
etcd | etcd v3 lease + transactional create | ≥ 1s | KeepAlive |
zookeeper | Ephemeral sequential nodes | Session | No-op (session) |
consul | Session + KV lock | ≥ 1s | Session renew |
mysql | GET_LOCK / RELEASE_LOCK | N/A (connection) | No-op |
postgres | Advisory locks (pg_try_advisory_lock) | N/A (session) | No-op |
Quick start
import (
"context"
"time"
"github.com/LingByte/ling-base/common/lock"
lockredis "github.com/LingByte/ling-base/common/lock/redis"
goredis "github.com/redis/go-redis/v9"
)
func run(client *goredis.Client) error {
mu, err := lockredis.NewMutex(client, "orders:42",
lock.WithTTL(30*time.Second),
lock.WithRetryDelay(100*time.Millisecond),
)
if err != nil {
return err
}
ctx := context.Background()
if err := mu.Lock(ctx); err != nil {
return err
}
defer mu.Unlock(ctx)
return mu.Refresh(ctx)
}