pglock
在 PostgreSQL 内实现轻量级分布式锁服务
概览
| 扩展包名 | 版本 | 分类 | 许可证 | 语言 |
|---|---|---|---|---|
pglock | 1.0.0 | UTIL | PostgreSQL | SQL |
| ID | 扩展名 | Bin | Lib | Load | Create | Trust | Reloc | 模式 |
|---|---|---|---|---|---|---|---|---|
| 4140 | pglock | 否 | 否 | 否 | 是 | 否 | 否 | pglock |
| 相关扩展 | pg_cron pgmb pgmq pgq pg_cron |
|---|
Packaging patches the upstream pgmb.control mismatch and installs the extension as pglock.
版本
| 类型 | 仓库 | 版本 | PG 大版本 | 包名 | 依赖 |
|---|---|---|---|---|---|
| EXT | PIGSTY | 1.0.0 | 1817161514 | pglock | pg_cron |
| RPM | PIGSTY | 1.0.0 | 1817161514 | pglock_$v | pg_cron_$v |
| DEB | PIGSTY | 1.0.0 | 1817161514 | postgresql-$v-pglock | postgresql-$v-cron |
构建
您可以使用 pig build 命令构建 pglock 扩展的 RPM / DEB 包:
pig build pkg pglock # 构建 RPM / DEB 包
安装
您可以直接安装 pglock 扩展包的预置二进制包,首先确保 PGDG 和 PIGSTY 仓库已经添加并启用:
pig repo add pgsql -u # 添加仓库并更新缓存
使用 pig 或者是 apt/yum/dnf 安装扩展:
pig install pglock; # 当前活跃 PG 版本安装
pig ext install -y pglock -v 18 # PG 18
pig ext install -y pglock -v 17 # PG 17
pig ext install -y pglock -v 16 # PG 16
pig ext install -y pglock -v 15 # PG 15
pig ext install -y pglock -v 14 # PG 14
dnf install -y pglock_18 # PG 18
dnf install -y pglock_17 # PG 17
dnf install -y pglock_16 # PG 16
dnf install -y pglock_15 # PG 15
dnf install -y pglock_14 # PG 14
apt install -y postgresql-18-pglock # PG 18
apt install -y postgresql-17-pglock # PG 17
apt install -y postgresql-16-pglock # PG 16
apt install -y postgresql-15-pglock # PG 15
apt install -y postgresql-14-pglock # PG 14
创建扩展:
CREATE EXTENSION pglock CASCADE; -- 依赖: pg_cron
用法
- 来源:README
pglock 是一个在 PostgreSQL 内实现的轻量分布式锁服务。它把锁状态保存在 pglock.locks 中,并通过基于 TTL 的清理来回收陈旧行。
创建扩展
CREATE EXTENSION pglock;
上游 README 标明要求 PostgreSQL 9.1+ 和 plpgsql。
获取与释放锁
SELECT pglock.lock('worker-1', 'users');
SELECT pglock.unlock('worker-1', 'users');
pglock.lock(id, resource) 在成功拿到锁时返回 true,如果锁已被其他进程持有则返回 false。文档说明 pglock.unlock(id, resource) 是幂等的。
隔离级别与过期
README 建议在并发场景下使用 serializable isolation 以保证正确性:
SELECT pglock.set_serializable();
BEGIN ISOLATION LEVEL SERIALIZABLE;
SELECT pglock.lock('my-id', 'my-resource');
SELECT pglock.unlock('my-id', 'my-resource');
COMMIT;
陈旧锁通过下面的方式过期清理:
SELECT pglock.ttl();
文档给出的默认 TTL 是 5 分钟。如果环境里有 pg_cron,README 说明可以每分钟调度一次 pglock.ttl()。
锁表
上游模式中的锁表是 pglock.locks,包含 id、resource、locked、ttl、created_at 和 updated_at 列。主键为 (id, resource)。