pglock

概览

Packaging patches the upstream pgmb.control mismatch and installs the extension as pglock.

版本

构建

您可以使用 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)。