导读:本期聚焦于林则安创作的《PostgreSQL应用锁是什么?如何用advisory lock避免并发冲突》,敬请观看详情。PostgreSQL 的 advisory lock 并不是表级锁或行级锁,而是数据库提供的一种独立锁机制。它允许应用自己定义一个整数或两个整数作为锁键,由数据库承担锁冲突判断和等待队列管理,但锁的业务含义完全由应用层解释。这种锁分为会话级和事务级两类,会话级锁需要显式释放,事务级锁在事务结束时自动清理,同时支持排它锁与共享锁两种互斥模式。常见的函数包括 pg_advisory_lock、pg_try_advisory_lock、pg_advisory_xact_lock 等。在分布式定时任务、跨服务资源协调、数据库层面的临界区保护等场景中,advisory lock 能有效避免重复执行和数据竞争。不过它也有一些容易踩坑的地方,比如连接池导致的锁泄漏、锁键冲突设计不当、会话级锁忘记释放等,本文将结合代码示例详细说明这些细节。

PostgreSQL 的 advisory lock 通常被翻译为应用锁或咨询锁,它允许应用在数据库层面申请一把完全由自己定义含义的锁,而不需要绑定到任何具体的表或行。与行级锁、表级锁不同,advisory lock 的锁目标是一个应用自定义的整数或两个整数组合,数据库只负责提供加锁、解锁、冲突判断等原语,至于这个数字代表某个用户余额操作、某个定时任务批次还是某条外部资源记录,完全由应用层解释。这种设计使得 advisory lock 成为跨行、跨表甚至跨服务协调并发的一种轻量级工具。

PostgreSQL应用锁是什么?如何用advisory lock避免并发冲突

一、advisory lock 的锁模式与函数分类

PostgreSQL 提供的 advisory lock 从生命周期上可以分为会话级和事务级两类。会话级锁一旦获取,会一直保留到当前数据库会话结束或显式调用解锁函数为止;事务级锁则只在当前事务内有效,事务提交或回滚后自动释放,即使发生异常也不会残留。这个区别在实际使用中非常重要,因为它直接决定了锁的清理方式和连接池场景下的安全性。

从互斥强度来看,advisory lock 又分为排它锁和共享锁。排它锁与任何其他锁都互斥,共享锁之间可以共存,但共享锁与排它锁互斥。这个设计很像读写锁,允许多个会话同时持有一把共享锁用于只读操作,而写操作需要排它锁。常用的函数包括 pg_advisory_lock、pg_try_advisory_lock、pg_advisory_lock_shared,以及对应的事务级版本 pg_advisory_xact_lock、pg_advisory_xact_lock_shared 等。

下面的 SQL 展示了会话级锁的基本用法,其中 pg_try_advisory_lock 是非阻塞版本,拿不到锁时立即返回 false,而不是等待。

-- 会话级排它锁:阻塞直到获取成功
SELECT pg_advisory_lock(100);

-- 非阻塞尝试获取排它锁,成功返回 true,失败返回 false
SELECT pg_try_advisory_lock(100);

-- 会话级共享锁:多个会话可同时持有共享锁
SELECT pg_advisory_lock_shared(100);

-- 释放会话级排它锁
SELECT pg_advisory_unlock(100);

-- 释放会话级共享锁
SELECT pg_advisory_unlock_shared(100);

PostgreSQL 还允许使用两个 32 位整数来构造一个 64 位的锁键,例如 pg_advisory_lock(classid, objid)。这种方式在锁键需要携带更多语义时非常有用,比如 classid 表示业务模块,objid 表示具体资源 ID。数据库在内部会把这些参数转换成同一个哈希键,因此 pg_advisory_lock(1, 2) 与 pg_advisory_lock(2, 1) 是两把完全不同的锁。

二、典型场景:用 advisory lock 实现分布式任务互斥

一个最常见的场景是定时任务的多实例部署。假设同一个应用部署了多个实例,每个实例都会在固定时间触发清理任务,如果不加控制,可能出现多个实例同时处理同一批数据,导致重复执行或数据不一致。这时可以利用 advisory lock 来保证同一时刻只有一个实例能执行任务。

实现思路很简单:每个实例启动任务时,用同一个固定整数作为锁键去尝试获取排它锁。只有获取成功的实例才继续执行业务逻辑,获取失败的实例直接跳过本轮或进入等待。为了不让任务阻塞在等待锁上,一般使用 pg_try_advisory_lock,这样拿不到锁的实例可以快速退出,避免堆积大量等待连接。

DO $$
DECLARE
    lock_acquired boolean;
BEGIN
    lock_acquired := pg_try_advisory_lock(42);
    IF lock_acquired THEN
        -- 执行业务逻辑
        PERFORM pg_sleep(5);
        PERFORM pg_advisory_unlock(42);
    ELSE
        RAISE NOTICE 'another worker is already running';
    END IF;
END $$;

这段代码模拟了一个任务执行骨架。锁键 42 可以替换为业务相关的常量,例如任务 ID。需要注意的是,这里使用的是会话级锁,所以最后必须手动调用 pg_advisory_unlock 释放。如果业务逻辑执行过程中抛出了异常,PL/pgSQL 块并不会自动释放这把锁,除非在异常处理中也显式释放,或者改用事务级锁。

另一个值得注意的问题是连接池。会话级 advisory lock 绑定在物理连接上,而不是应用层逻辑会话上。如果应用从连接池借出一个连接获取了锁,执行业务后又把连接归还给连接池,那么这把锁依然被这个物理连接持有。当下一个请求从连接池拿到同一个连接时,它可能会意外继承这把锁,或者因为锁未释放而阻碍其他任务。因此,在连接池环境下,更推荐使用事务级 advisory lock,或者确保锁获取与释放严格配对,并且释放后再归还连接。

三、事务级锁与异常安全性分析

事务级 advisory lock 通过 pg_advisory_xact_lock 系列函数获取,它不需要显式调用解锁函数。当事务提交或回滚时,锁会被 PostgreSQL 自动释放。这个特性让事务级锁在异常安全方面表现更好,因为即使业务代码抛出异常,只要事务结束,锁就不会残留。

下面是一个事务级锁的示例。事务开始后获取锁,然后更新任务队列中的一条记录,最后提交事务。提交后锁自动释放,不需要在业务逻辑中处理释放问题。

BEGIN;
-- 获取事务级排它锁,事务结束自动释放
SELECT pg_advisory_xact_lock(200);
-- 执行受保护的操作
UPDATE task_queue SET status = 'processing' WHERE id = 1;
COMMIT;

事务级锁特别适合短事务场景,比如数据库内的状态转换、资源抢占、防重复扣费操作等。它的缺点是锁的持有时间由事务长度决定。如果事务中包含长时间运行的计算或者外部网络调用,锁会被持有更久,增加其他会话的等待时间。所以在长事务中,要谨慎使用事务级锁,必要时可以拆分成小事务,或者将长耗时操作放在事务外。

无论是会话级还是事务级锁,都可以通过查询 pg_locks 视图来观察当前的锁状态。下面的 SQL 可以查看所有 advisory lock 的持有情况,方便定位锁冲突和未释放的锁。

SELECT
    l.locktype,
    l.mode,
    l.granted,
    l.pid,
    l.classid,
    l.objid,
    a.query
FROM pg_locks l
LEFT JOIN pg_stat_activity a ON a.pid = l.pid
WHERE l.locktype = 'advisory';

其中 granted 为 true 表示锁已经被成功授予,false 表示该会话正在等待锁。通过关联 pg_stat_activity,可以看到等待锁的会话正在执行什么 SQL,这对排查锁等待问题很有帮助。

四、常见误区和排查方法

第一个常见误区是认为 advisory lock 会自动保护数据。实际上它只是一把由数据库管理的命名锁,并不会阻止其他连接修改真实数据。如果业务中有一条规则要求某个用户同一时刻只能有一笔扣款操作,那么所有涉及该用户扣款的代码都必须遵守同一套锁协议,即先获取该用户编号对应的 advisory lock,再操作相关表。只要有一个入口没有遵守这个协议,锁保护就会被绕过。

第二个误区是锁键设计过于随意。不同业务模块如果使用相同的整数作为锁键,会导致无关业务互相阻塞。例如两个不同的后台任务都用 1 作为锁键,那么它们永远不能并发执行。为了避免这种情况,建议对锁键做统一规划,比如使用业务前缀加上资源 ID 的哈希值,或者使用两个 32 位整数分别表示模块和资源。锁键的值可以是任意 bigint,因此有足够大的空间来分配不同的业务域。

第三个常见问题是会话级锁忘记释放。虽然数据库连接断开时锁会自动清理,但在连接池环境中连接通常不会断开,所以忘记释放就会造成锁长期占用,后续请求持续失败。排查这类问题时,可以先查询 pg_locks 中 locktype = 'advisory' 的记录,找到长期持有且从未变化的 pid,再通过 pg_stat_activity 查看该连接最近的查询。如果确认是泄漏,可以通过 pg_terminate_backend(pid) 强制结束该连接来释放锁,但更根本的方案还是加强代码中的解锁逻辑或改用事务级锁。

advisory lock 是 PostgreSQL 提供的一种灵活而高效的并发控制手段,合理使用可以解决很多行级锁难以覆盖的场景。关键在于理解会话级与事务级的区别、排它锁与共享锁的语义,以及在连接池和异常路径下锁的释放行为。设计锁键时做好业务隔离,再配合 pg_locks 的监控手段,就能把应用锁的作用发挥到最大。

PostgreSQLadvisory lock应用锁修改时间:2026-09-25 20:29:45

免责声明:已尽一切努力确保本网站所含信息的准确性。网站作品多为原创整理与精心创作,观点力求客观中立。本站旨在免费分享,内容仅供个人学习、研究或参考使用。若引用了第三方作品,版权归原作者所有。如内容涉及您的权益,请联系我们进行处理Email:chomcom@qq.com。
引用或转载本作品时,请注明当前出处:https://www.ipipp.com/html/0925/61848.html,基于非商业用途的前提下,欢迎转载或二创本作品。
内容垂直聚焦
专注技术核心技术栏目,确保每篇文章深度聚焦于实用技能。从代码技巧到架构设计,为用户提供无干扰的纯技术知识沉淀,精准满足专业提升需求。
知识结构清晰
覆盖从开发到部署的全链路。AI、前端、编程、数据库、服务器、建站、系统层层递进,构建清晰学习路径,帮助用户系统化掌握开发与运维所需的核心技术。
深度技术解析
拒绝泛泛而谈,深入技术细节与实践难点。无论是数据库优化还是服务器配置,均结合真实场景与代码示例进行剖析,致力于提供可直接应用于工作的解决方案。
专业领域覆盖
精准对应开发生命周期。从前端界面到后端编程,从数据库操作到服务器运维,形成完整闭环,一站式满足全栈工程师和运维人员的技术需求。
即学即用高效
内容强调实操性,步骤清晰、代码完整。用户可根据教程直接复现和应用于自身项目,显著缩短从学习到实践的距离,快速解决开发中的具体问题。
持续更新保障
专注既定技术方向进行长期、稳定的内容输出。确保各栏目技术文章持续更新迭代,紧跟主流技术发展趋势,为用户提供经久不衰的学习价值。