PgQue 靠两个快照定义批次，代价是秒级延迟 RSS

Christophe Pettus 拆解了 PgQue 的做法：消费时完全不改事件表。事件写进轮转的表，事务 ID 作列默认值；一个 ticker 每秒抓一次 pg_snapshot，相邻两个快照之间就是一个批次，消费端据此判断可见性；三张表靠 TRUNCATE 轮转，不做垃圾回收。算法出自 Marko Kreen 2007 年前后的设计。代价是事件要等下一个 tick 才可见，端到端一到两秒。

发布于 2026-09-10T10:59:39.829706Z · Christophe Pettus · thebuild.com

PgQue 消息队列

Christophe Pettus 拆解了 PgQue 的做法：消费时完全不改事件表。事件写进轮转的表，事务 ID 作列默认值；一个 ticker 每秒抓一次 pg_snapshot，相邻两个快照之间就是一个批次，消费端据此判断可见性；三张表靠 TRUNCATE 轮转，不做垃圾回收。算法出自 Marko Kreen 2007 年前后的设计。代价是事件要等下一个 tick 才可见，端到端一到两秒。

Christophe Pettus 拆解了 PgQue 的做法：消费时完全不改事件表。事件写进轮转的表，事务 ID 作列默认值；一个 ticker 每秒抓一次 pg_snapshot，相邻两个快照之间就是一个批次，消费端据此判断可见性；三张表靠 TRUNCATE 轮转，不做垃圾回收。算法出自 Marko Kreen 2007 年前后的设计。代价是事件要等下一个 tick 才可见，端到端一到两秒。

原始来源 ↗

来源记录

• center.info_item · 916b4af079ebacf8 · 2026-10-03T04:08:35.169032Z
• pgweb.info_item · 916b4af079ebacf8 · 2026-10-03T04:08:55.967155Z