如何查询PostgreSQL NOTIFY/LISTEN消息队列当前长度？

首先得明确你用的是哪种队列实现，因为PostgreSQL本身没有内置的持久化消息队列，常见的触发器+队列的组合主要有以下几种情况，对应的查询方式也不同：

1. 自定义队列表（最常见的场景） #

如果你的触发器是把事件写入一个专门的队列表（比如event_queue），worker从这个表中读取未处理的记录，那队列长度就是表中未被处理的记录数。

假设你的队列表有一个标记字段（比如is_processed、status）来区分已处理/待处理的消息，查询语句可以是：

-- 统计待处理消息数量
SELECT COUNT(*) AS queue_length FROM event_queue WHERE is_processed = FALSE;

-- 或者按状态区分（如果有pending/processing/failed等多状态）
SELECT COUNT(*) AS queue_length FROM event_queue WHERE status = 'pending';

如果表数据量很大，COUNT(*)可能会比较慢，可以考虑用近似计数（比如用pg_stat_user_tables中的n_live_tup减去已处理的近似值），或者给状态字段加索引来优化查询速度。

2. LISTEN/NOTIFY 轻量级通知机制 #

如果你的触发器是通过pg_notify()发送通知，worker用LISTEN接收，那要注意：PostgreSQL的NOTIFY是无持久化的——如果没有客户端在LISTEN，发送的通知会直接丢弃，不存在“队列”的概念。这种情况下不存在“队列长度”，因为消息不会被存储。

如果你的场景需要持久化消息（避免丢失），通常的做法是先把事件写入队列表，再发送NOTIFY通知worker去读取表中的数据，这时候还是回到第一种情况，查询队列表的待处理记录数即可。

3. 第三方队列扩展 #

如果是用了PostgreSQL的第三方队列扩展（比如pg_boss、pg_queue等），这些扩展会有自己的表结构和查询方式。以pg_boss为例，查询待处理队列长度的语句是：

SELECT COUNT(*) AS queue_length FROM job WHERE state = 'ready';

具体的查询语句需要参考你使用的扩展文档，不同扩展的表和状态字段会有差异。

为什么你在文档里找不到通用的查询方法？ #

因为PostgreSQL本身没有内置的“消息队列”组件，LISTEN/NOTIFY只是通知机制，而真正的队列通常是用户自己用表实现的，或者依赖第三方扩展——所以没有统一的查询语句，完全取决于你的队列实现方式。

内容的提问来源于stack exchange，提问作者dizzyf