当前位置：首页 > news >正文

PostgreSQL 的 pg_advisory_lock 函数

news 来源：原创 2025/8/4 17:35:10

PostgreSQL 的 pg_advisory_lock 函数

pg_advisory_lock 是 PostgreSQL 提供的一种应用级锁机制，它不锁定具体的数据库对象（如表或行），而是通过数字键值来协调应用间的并发控制。

锁的基本概念

PostgreSQL 提供两种咨询锁(advisory lock)：

会话级咨询锁：锁在会话结束时自动释放
事务级咨询锁：锁在事务结束时自动释放

主要函数列表

函数	描述
pg_advisory_lock(key)	获取会话级咨询锁（阻塞）
pg_try_advisory_lock(key)	尝试获取会话级咨询锁（非阻塞）
pg_advisory_xact_lock(key)	获取事务级咨询锁（阻塞）
pg_try_advisory_xact_lock(key)	尝试获取事务级咨询锁（非阻塞）
pg_advisory_unlock(key)	释放会话级咨询锁
pg_advisory_unlock_all()	释放当前会话持有的所有咨询锁

函数详解

1 pg_advisory_lock(key bigint)

功能：获取一个会话级别的咨询锁（如果锁已被其他会话持有，则阻塞等待）

参数：

key：64位整数锁标识

示例：

SELECT pg_advisory_lock(123456);
-- 执行需要同步的操作
SELECT pg_advisory_unlock(123456);

2 pg_try_advisory_lock(key bigint)

功能：尝试获取会话级咨询锁（非阻塞，立即返回成功与否）

返回值：boolean（true表示获取成功）

示例：

DO $$
BEGINIF pg_try_advisory_lock(123456) THENRAISE NOTICE 'Lock acquired, performing work...';-- 执行受保护的操作PERFORM pg_advisory_unlock(123456);ELSERAISE NOTICE 'Could not acquire lock, skipping...';END IF;
END $$;

3 pg_advisory_xact_lock(key bigint)

功能：获取事务级咨询锁（锁在事务结束时自动释放）

示例：

BEGIN;
SELECT pg_advisory_xact_lock(123456);
-- 执行需要同步的操作
COMMIT; -- 锁自动释放

4 pg_try_advisory_xact_lock(key bigint)

功能：尝试获取事务级咨询锁（非阻塞）

示例：

BEGIN;
SELECT pg_try_advisory_xact_lock(123456);
-- 无论是否获取成功都继续执行
COMMIT;

锁的键值设计

咨询锁使用64位整数作为键值，有两种使用方式：

单键模式：使用一个64位整数
```
SELECT pg_advisory_lock(123456789);
```
双键模式：使用两个32位整数组合
```
SELECT pg_advisory_lock(123, 456);
```

实际应用场景

场景1：防止定时任务重复执行

-- 在定时任务开始时检查锁
DO $$
BEGINIF NOT pg_try_advisory_xact_lock(987654) THENRAISE NOTICE 'Task is already running in another process';RETURN;END IF;RAISE NOTICE 'Starting scheduled task...';-- 执行定时任务逻辑-- ...COMMIT; -- 锁自动释放
END $$;

场景2：应用级分布式锁

-- 应用1获取锁
SELECT pg_advisory_lock(555555) FROM my_table WHERE id = 1;-- 应用2尝试获取同样的锁
SELECT pg_try_advisory_lock(555555); -- 返回false-- 应用1释放锁
SELECT pg_advisory_unlock(555555);

场景3：确保单实例初始化

-- 系统初始化时确保只执行一次
DO $$
BEGIN-- 尝试获取锁，等待最多5秒FOR i IN 1..5 LOOPIF pg_try_advisory_lock(1357924680) THEN-- 检查是否已经初始化IF NOT EXISTS (SELECT 1 FROM system_status WHERE initialized = true) THEN-- 执行初始化INSERT INTO system_status(initialized) VALUES (true);RAISE NOTICE 'System initialized successfully';ELSERAISE NOTICE 'System already initialized';END IF;-- 显式释放锁（虽然会话结束会自动释放）PERFORM pg_advisory_unlock(1357924680);RETURN;END IF;PERFORM pg_sleep(1); -- 等待1秒END LOOP;RAISE EXCEPTION 'Could not acquire initialization lock after 5 seconds';
END $$;

监控咨询锁

查看当前持有的咨询锁

SELECT locktype, classid, objid, objsubid, mode, granted
FROM pg_locks
WHERE locktype = 'advisory';

查看所有咨询锁（包括已授予和等待的）

SELECT pid, locktype, mode, granted, fastpath, virtualtransaction
FROM pg_locks 
WHERE locktype = 'advisory';

注意事项

锁释放：
- 会话级锁必须显式释放或会话结束自动释放
- 事务级锁在事务结束时自动释放
死锁风险：
- 按固定顺序获取多个咨询锁以避免死锁
- 使用 pg_try_advisory_lock 可以降低死锁风险
性能影响：
- 咨询锁比表锁/行锁更轻量级
- 大量使用仍可能影响性能
集群环境：
- 咨询锁只在单个PostgreSQL实例内有效
- 不适用于跨多个数据库实例的协调
锁标识管理：
- 建议在应用中集中管理锁标识
- 使用有意义的常量而非魔法数字

高级用法

超时获取锁

DO $$
DECLARElock_acquired BOOLEAN := false;timeout INTERVAL := '5 seconds';start_time TIMESTAMP := clock_timestamp();
BEGINWHILE (clock_timestamp() - start_time) < timeout LOOPIF pg_try_advisory_lock(424242) THENlock_acquired := true;EXIT;END IF;PERFORM pg_sleep(0.1); -- 等待100msEND LOOP;IF lock_acquired THENRAISE NOTICE 'Lock acquired after %', clock_timestamp() - start_time;-- 执行受保护的操作PERFORM pg_advisory_unlock(424242);ELSERAISE EXCEPTION 'Could not acquire lock within timeout';END IF;
END $$;

使用咨询锁实现队列

-- 生产者
SELECT pg_advisory_lock(987); -- 全局写锁-- 插入队列项
INSERT INTO job_queue(job_data) VALUES ('some data');SELECT pg_advisory_unlock(987);-- 消费者
SELECT pg_advisory_lock(988); -- 全局读锁-- 获取并锁定一个作业
UPDATE job_queue 
SET status = 'processing', worker_id = pg_backend_pid(),claimed_at = NOW()
WHERE id = (SELECT id FROM job_queue WHERE status = 'pending' ORDER BY created_at LIMIT 1
)
RETURNING *;SELECT pg_advisory_unlock(988);

pg_advisory_lock 是 PostgreSQL 强大的应用级同步机制，合理使用可以解决复杂的并发控制问题，但需要谨慎设计以避免死锁和性能问题。

PostgreSQL 的 pg_advisory_lock 函数

PostgreSQL 的 pg_advisory_lock 函数 pg_advisory_lock 是 PostgreSQL 提供的一种应用级锁机制，它不锁定具体的数据库对象（如表或行），而是通过数字键值来协调应用间的并发控制。锁的基本概念 PostgreSQL 提供两种咨询锁(advi…...

编程日记 2025/8/4 17:35:10

NLP基础

1. 基本概念自然语言处理（Natural Language Processing，简称NLP）是人工智能和语言学领域的一个分支，它涉及到计算机和人类（自然）语言之间的相互作用。它的主要目标是让计算机能够理解、解释和生成人类语言…...

编程日记 2025/8/4 6:30:16

[AI Tools] Dify 工具插件上传指南：如何将插件发布到官方市场

Dify 作为开源的 LLM 应用开发平台，不仅支持本地化插件开发，也提供了插件市场机制，让开发者能够将自己构建的插件发布并供他人使用。本文将详细介绍如何将你开发的 Dify Tools 插件上传至官方插件市场，包括 README 编写、插件打包、仓库 PR 等核心步骤。一、准备 README 文…...

编程日记 2025/7/31 1:30:53

Qt读写XML文档

XML 结构与概念简介 XML（可扩展标记语言） 是一种用于存储和传输结构化数据的标记语言。其核心特性包括： 1、树状结构：XML 数据以层次化的树形结构组织，包含一个根元素（Root Element）&#xff…...

编程日记 2025/7/31 1:30:51

htmlUnit和Selenium的区别以及使用BrowserMobProxy捕获网络请求

1. Selenium：浏览器自动化之王核心定位： 跨平台、跨语言的浏览器操控框架，通过驱动真实浏览器实现像素级用户行为模拟。技术架构： 核心特性： 支持所有主流浏览器（含移动端模拟） 精…...

编程日记 2025/8/4 6:19:53

C#黑魔法：鸭子类型(Duck Typing)

C#黑魔法：鸭子类型(Duck Typing) 如果它走起路来像鸭子，叫起来像鸭子，那么它就是鸭子。鸭子类型，主要应用于动态语言类型，比如JS、Python等，核心理念为：关注对象的行为（方法或属性…...

编程日记 2025/7/31 1:30:49

2025 年数维杯数学建模B题完整论文代码模型

《2025 年数维杯数学建模B题完整论文代码模型》 B题完整论文一、赛事背景与题目总览 2025 年第十届数维杯大学生数学建模挑战赛的 B 题聚焦于“马拉松经济的高质量发展思路探索”。近年来，我国马拉松赛事如同一颗颗璀璨的星星，在城市的天空中闪耀&am…...

编程日记 2025/7/31 1:30:46

C++23 中的 views::chunk：深入探索与应用

文章目录一、views::chunk 的背景与动机二、views::chunk 的基本用法语法与参数示例代码三、views::chunk 的高级用法处理不完整块与 views::drop 和 views::take 结合四、性能分析五、应用场景1. 批量处理数据2. 分页显示3. 并行处理六、与其他范围适配器的组合1. 与 view…...

编程日记 2025/7/31 1:30:42

库室指静脉人脸门禁机 LK-BM-S10C/JR

1、采用大于等于四核处理器，主频大于1G； 2、内存≥4G DDR3；存储≥8G 3、核心模块采用国产工业级处理芯片和嵌入式Android实时多任务系统，采用模块化设计,模块间通过标准接口相连； 4、大于等于10英寸电容屏&#xf…...

编程日记 2025/8/4 1:25:44

低成本自动化改造的18个技术锚点深度解析

执行摘要本文旨在深入剖析四项关键的低成本自动化技术，这些技术为工业转型提供了显著的运营和经济效益。文章将提供实用且深入的指导，涵盖老旧设备联网、AGV车队优化、空压机系统智能能耗管控以及此类项目投资回报率（ROI）的严谨…...

编程日记 2025/7/31 1:30:33

线程中常用的方法

知识点详细说明 Java线程的核心方法集中在Thread类和Object类中，以下是新增整合后的常用方法分类解析： 1. 线程生命周期控制方法作用注意事项start()启动新线程，JVM调用run()方法多次调用会抛出IllegalThreadStateException（线程状态不可逆）。run()线程的任务逻辑直接调…...

编程日记 2025/8/4 4:35:21

运维体系架构规划

运维体系架构规划是一个系统性工程，旨在构建高效、稳定、安全的运维体系，保障业务系统的持续运行。下面从规划目标、核心模块、实施步骤等方面进行详细阐述： 一、规划目标高可用性：确保业务系统 724 小时不间断运行&#xff0c…...

编程日记 2025/8/1 7:38:07

C++结构体介绍

结构体的定义在C中，结构体（struct）是一种用户定义的数据类型，允许将不同类型的数据组合在一起。结构体的定义使用struct关键字，后跟结构体名称和一对花括号{}，花括号内包含成员变量的声明。 struct Pers…...

编程日记 2025/7/31 1:30:27

RoPE长度外推:外插内插

RoPE:假定 α \alpha α是定值其中一半位置是用cos表示的 cos ⁡ ( k α − 2 i d ) \cos(k\alpha^{-\frac{2i}{d}}) cos(kα−d2i)(另一半是sin)(d是词嵌入维度) 当太长如何解决: 1 直接不管—外插缺点:超过一定长度性能急剧下降。(较大时，对应的很多位置编码…...

编程日记 2025/7/30 12:12:24

牛客练习赛138-题解

牛客练习赛138-题解 https://ac.nowcoder.com/acm/contest/109081#question A-小s的签到题题目描述给定一个比赛榜单： 第一行是 n 个不同的大写字母，代表题号第二行是 n 个形如a/b的字符串，表示每道题的通过人数和提交人数找到通过人…...

编程日记 2025/7/31 3:50:56

MySQL高可用方案全攻略：选型指南与AI运维实践

MySQL高可用方案全攻略：选型指南与AI运维实践引言：当数据库成为业务生命线在数字化时代，数据库就是企业的"心脏"。一次数据库宕机可能导致：电商网站每秒损失上万元订单游戏公司遭遇玩家大规模流失金融系统引发连锁反应本文将为你揭秘： MySQL主流高可用方案…...

编程日记 2025/7/31 0:24:21

【库（Library）、包（Package）和模块（Module）解析】

在Python中，**库（Library）、包（Package）和模块（Module）**是代码组织的不同层级，而import语句的导入行为与它们密切相关。以下是详细对比和解释： 📦 1. 核心概…...

编程日记 2025/8/3 18:03:04

记录一次使用thinkphp使用PhpSpreadsheet扩展导出数据，解决身份证号码等信息科学计数法问题处理

PhpSpreadsheet官网 PhpSpreadsheet安装 composer require phpoffice/phpspreadsheet使用composer安装时一定要下载php对应的版本，下载之前使用php -v检查当前php版本简单使用 <?php require vendor/autoload.php;use PhpOffice\PhpSpreadsheet\Spreadshee…...

编程日记 2025/7/31 0:24:17

为什么业务总是被攻击？使用游戏盾解决方案

业务频繁遭受攻击的核心原因在于攻防资源不对等，攻击者利用技术漏洞、利益驱动及企业防护短板发起攻击，而游戏盾通过针对性架构设计实现高效防御。以下是具体分析与解决方案： 一、业务被攻击的根源利益驱动攻击勒索与数…...

编程日记 2025/8/3 18:52:12

4.1【LLaMA-Factory 实战】医疗领域大模型：从数据到部署的全流程实践

【LLaMA-Factory实战】医疗领域大模型：从数据到部署的全流程实践一、引言在医疗AI领域，构建专业的疾病诊断助手需要解决数据稀缺、知识专业性强、安全合规等多重挑战。本文基于LLaMA-Factory框架，详细介绍如何从0到1打造一个垂直领域的医…...

编程日记 2025/7/31 0:24:13

二维旋转矩阵：让图形动起来的数学魔法 ✨

大家好！今天我们要聊一个超酷的数学工具——旋转矩阵。它就像数学中的"旋转魔法"，能让图形在平面上优雅地转圈圈。别被"矩阵"这个词吓到，其实它就是一个数字表格，但功能超级强大！ 一、什么是旋转…...

编程日记 2025/7/31 0:24:11

go语言封装、继承与多态：

1.封装： 封装是通过将数据和操作数据的方法绑定在一起来实现的。在Go语言中，封装通过结构体（struct）和方法（method）来实现。结构体的字段可以通过大小写来控制访问权限。 package stutype Person struct …...

编程日记 2025/8/4 1:22:55

golang -- 如何获取变量类型

目录前言获取变量类型一、fmt.Printf二、类型断言三、类型选择四、反射 reflect.TypeOf五、reflect.Value的Type()方法前言在学习反射的时候，对reflect包中获取变量类型的函数很迷惑比如下面这个用Type获取变量类型的方法（在下面提到） …...

编程日记 2025/8/4 9:14:41

Missashe考研日记-day36（改版说明）

Missashe考研日记-day36 改版说明经过一天的思考、纠结和尝试，博主决定对更新内容进行改版，如下：1.不再每天都发一篇日记，改为一周发一篇包含一周七天学习进度的周记，但为了标题和以前相同（强迫症&#…...

编程日记 2025/7/31 0:24:04

opencv中的图像特征提取

图像的特征，一般是指图像所表达出的该图像的特有属性，其实就是事物的图像特征，由于图像获得的多样性（拍摄器材、角度等），事物的图像特征有时并不特别突出或与无关物体混杂在一起，因此图像的特征…...

编程日记 2025/7/31 0:24:02

一文了解氨基酸的分类、代谢和应用

氨基酸（Amino acids）是在分子中含有氨基和羧基的一类化合物。氨基酸是生命的基石，人类所有的疾病与健康状况都与氨基酸有直接或间接的关系。氨基酸失衡可引起肝硬化、神经系统感染性疾病、糖尿病、免疫性疾病、心血管疾病、肾病、肿瘤等各类疾…...

编程日记 2025/8/4 1:41:41

Linux 系统安装Minio详细教程

一、🔍 MinIO 简介 MinIO 是一个高性能的对象存储服务，兼容 Amazon S3 接口，适用于大数据、AI、云原生等场景，支持分布式部署和高可用性，可作为轻量级的私有云对象存储解决方案。二、📦 安装准备 ✅ 系…...

编程日记 2025/7/31 0:23:58

排序算法-归并排序

归并排序是一种分治算法（Divide and Conquer）。对于给定的一组数据，利用递归与分治技术将数据序列划分成为越来越小的半子表，在对半子表排序后，再用递归方法将排好序的半子表合并成为越来越大的有序序列。核心思想分…...

编程日记 2025/8/4 8:25:34

js 两个数组中的指定参数（id）相同，为某个对象设置disabled属性

在JavaScript中，如果想要比较两个数组并根据它们的id属性来设置某个对象的disabled属性为true，你可以使用几种不同的方法。这里我将介绍几种常用的方法： 方法1：使用循环和条件判断 const array1 [{ id: 1, name: Item 1 },{ id…...

编程日记 2025/7/31 3:50:54

【Java基础】——集合篇

目标： 1.每个集合用的场景 2.每个集合的底层一.概述二. 三.Collection 1.通用方法其中，contains方法，它的底层一定调用了equals方法进行比对，而且一定重写了equals方法，如果不重写equals方法，就是调用…...

编程日记 2025/8/4 4:54:43

小红书视频无水印下载方法

下载小红书（RED/Xiaohongshu）视频并去除水印可以通过以下几种方法实现，但请注意尊重原创作者版权，下载内容仅限个人使用，避免侵权行为。方法一：使用在线解析工具（推荐） 复制视频链…...

编程日记 2025/7/31 3:50:50

代发考试战报：思科华为HCIP HCSE CCNP 考试通过

CCNP 300-410考试通过战报，HCIP云计算通过，HCIP数通 H12-821考试通过，H12-831考试通过，HCSP金融 H19-611考试通过，HCSE金融 H21-293 考试通过报名考试一定要找正规报名，避免后续考试成绩被取消&#xff0…...

编程日记 2025/7/31 3:50:48

辉芒微离线烧录器“文件格式错误”问题解决

最近在使用辉芒微离线烧录器烧录程序时，提示“文件格式错误”，记录一下解决方法。一、问题现象经过多次尝试和排查，发现以下几种情况： 情况一：使用离线烧录器导入固件1（boot程序）&#xff0c…...

编程日记 2025/8/4 1:22:59

系统的从零开始学习电子的相关知识，该如何规划？

一、基础理论奠基（6-12个月） 1.1 数学与物理基础核心内容： 微积分与线性代数（高频电路建模必备）复变函数与概率论（信号处理与通信系统基础）电磁场基础（麦克斯韦方程组的物理意义&…...

编程日记 2025/7/31 3:50:44

网络研讨会开发注册中, 5月15日特励达力科，“了解以太网”

在线研讨会主题 Understanding Ethernet - from basics to testing & optimization 了解以太网 - 从基础知识到测试和优化注册链接# https://register.gotowebinar.com/register/2823468241337063262 时间北京时间 2025 年 5 月 15 日星期四下午 3:30 - 4:30 适宜…...

编程日记 2025/7/31 3:50:42

LSTM的简单模型

好的，我来用通俗易懂的语言解释一下这个 LSTMTagger 类是如何工作的。 1️⃣ 类的目的这个 LSTMTagger 类是一个用于自然语言处理（NLP）任务的模型，目的是标注输入的句子，通常用于词性标注（例如&#xff…...

编程日记 2025/7/31 3:50:40

聊聊Spring AI autoconfigure模块的拆分

序本文主要研究一下Spring AI autoconfigure模块的拆分 v1.0.0-M6版本 (base) ➜ spring-ai-spring-boot-autoconfigure git:(v1.0.0-M6) tree -L 9 . ├── pom.xml ├── src │ ├── main │ │ ├── java │ │ │ └── org │ │ │ └…...

编程日记 2025/7/31 3:50:38

LVGL源码学习之渲染、更新过程(3)---绘制和刷写

LVGL版本：8.1 往期回顾： LVGL源码学习之渲染、更新过程(1)---标记和激活 LVGL源码学习之渲染、更新过程(2)---无效区域的处理前文提到，在处理完无效区域后，会得到一个个需要重新绘制的对象，这些对象将在DRAW事件中…...

编程日记 2025/7/31 3:50:36

CTF-DAY11

[NSSRound#16 Basic]了解过PHP特性吗题目： <?php error_reporting(0); highlight_file(__FILE__); include("rce.php"); $checker_1 FALSE; $checker_2 FALSE; $checker_3 FALSE; $checker_4 FALSE; $num $_GET[num]; if (preg_match("/…...

编程日记 2025/8/2 7:17:30

手动修改uart16550的FIFO深度？

参考：修改AXI UART D16550 FIFO深度的过程记录 - lmore - 博客园...

编程日记 2025/7/31 3:50:32

Unity按钮事件冒泡

今天unity写程序时，我做了一个透明按钮，没图片，只绑了点击事件，把子对象文字组件也删了，空留一个透明按钮，此时运行时点击按钮是没有反应的，网上的教程说必须指定target graphic（目标…...

编程日记 2025/8/4 5:22:57

基于Llama3的开发应用（一）：Llama模型的简单部署

Llama模型的简单部署 0 前言1 环境准备1.1 硬件环境1.2 软件环境 2 Meta-Llama-3-8B-Instruct 模型简介2.1 Instruct含义2.2 模型下载 3 简单调用4 FastAPI 部署4.1 通过FastAPI简单部署4.2 测试 5 使用 streamlit 构建简易聊天界面6 总结 0 前言本系列文章是基于Meta-Llama-…...

编程日记 2025/7/31 3:50:28

人工智能机器学习期末考试题

自测试卷2 一、选择题 1．下面哪个属性不是NumPy中数组的属性（ ）。 A．ndim B．size C．shape D．add 2．一个简单的Series是由（ ）的数据组成的。 A．两…...

编程日记 2025/8/4 6:39:04

修改docker为国内源

一、编辑docker配置文件 vi /etc/docker/daemon.json二、配置国内源和修改docker数据目录 {"registry-mirrors":["http://hub-mirror.c.163.com","https://mirrors.tuna.tsinghua.edu.cn","http://mirrors.sohu.com","https://u…...

编程日记 2025/7/31 3:50:24

C++八股 —— vector底层

vector底层为动态数组类构成 class vector : protected _Vector_base_Vector_base: _M_start：容器元素开始的位置_M_finish：容器元素结束的位置_M_end_of_storage：动态内存最后一个元素的下一个位置构造函数无参构造根据性能优先规则&a…...

编程日记 2025/7/31 3:50:22

postgresql 参数wal_level

wal_level决定多少信息写入到 WAL 中。默认值是replica，它会写入足够的数据以支持WAL归档和复制，包括在后备服务器上运行只读查询。minimal会去掉除从崩溃或者立即关机中进行恢复所需的信息之外的所有记录。最后，logical会增加支持逻辑解码所…...

编程日记 2025/7/31 3:50:20

Lightweight App Alternatives

The tech industry’s business model thrives on constant churn: new features, fancier designs, and heavier apps — not because they’re essential, but because they keep consumers upgrading. Stripping your phone back to basics is an act of tech self-defense.…...

编程日记 2025/7/31 3:50:18

PostgreSQL 的 pg_advisory_lock 函数

锁的基本概念

主要函数列表

函数详解

1 pg_advisory_lock(key bigint)

2 pg_try_advisory_lock(key bigint)

3 pg_advisory_xact_lock(key bigint)

4 pg_try_advisory_xact_lock(key bigint)

锁的键值设计

实际应用场景

场景1：防止定时任务重复执行

场景2：应用级分布式锁

场景3：确保单实例初始化

监控咨询锁

查看当前持有的咨询锁

查看所有咨询锁（包括已授予和等待的）

注意事项

高级用法

超时获取锁

使用咨询锁实现队列

相关文章：