【免费下载链接】PgQuePgQue – Zero-bloat Postgres queue built on top of on battle-proven Skypes PgQ. One SQL file to install, pg_cron to tick https://pgque.dev项目地址https://gitcode.com/gh_mirrors/pg/PgQue点击查看免费下载PgQue 是一款零膨胀Zero-bloat的 Postgres 消息队列基于 Skype 久经考验的 PgQ 架构重构用纯 SQL 实现一个 SQL 文件即可安装。本指南带你完整掌握 PgQue 的重试机制与死信队列DLQ通过nack延迟重投、max_retries控制重试上限以及dlq_inspect/dlq_replay/dlq_purge检查、回放与清理死信构建不丢消息、不重复投递的可靠投递模式。为什么 Postgres 队列需要重试和 DLQ任何消息系统都会遇到两类失败瞬时故障下游服务暂时不可用、网络抖动、数据库短暂锁冲突——这类失败等几十秒后重试往往就能成功永久性故障数据校验失败、代码 bug、下游契约变更——无限重试只会造成重试风暴拖垮整个队列。SKIP LOCKED风格的队列PGMQ、River、pg-boss 等在重试时依赖UPDATEDELETE反复失败的消息会产生大量死元组最终撞上 VACUUM 瓶颈。而 PgQue 的热路径从不删除行重试和死信都走独立的retry_queue与dead_letter表主事件流保持零膨胀——这正是零膨胀重试模式的价值所在。PgQue 的投递模型是快照批量生产者send事件ticker 每 100ms 打一个 tick消费端的receive按 tick 之间的批次读取。重试消息到期后重新插回事件流下一次 tick 就会再次可见。下图是 PgQue 官方 tick 速率基准测试测得的端到端投递延迟分布可以直观理解重试间隔 tick 周期如何构成重投延迟PgQue 重试机制如何工作nack 与 retry_after 详解重试的入口是nack负确认。消费循环的标准形态是-- 处理成功整批确认游标前进 select pgque.ack(batch_id); -- 处理失败单条 nack延迟 60 秒后重投并记录原因 perform pgque.nack(batch_id, msg, interval 60 seconds, validation failed);pgque.nack(batch_id, msg, retry_after, reason)的行为源码见 receive.sql若该事件的ev_retry小于队列的max_retries有效默认值 5把事件放进pgque.retry_queue并设置重投时间 当前时间 retry_after若ev_retry max_retries则路由进死信表pgque.dead_letter到期后由维护函数pgque.maint_retry_events()把到期事件搬回事件表生产环境由pgque.start()每 30 秒自动调度无需手动调用。两个容易踩坑的点nack与ack是配合关系不是二选一。nack逐条安排重试或死信ack逐批确认并推进消费位点不做ack消费者就永远卡在这一个 batch 上retry_after默认 60 秒。实现指数退避时可以依据返回消息中的retry_count字段动态计算如60 * 2^retry_count秒。receive返回的每行都带retry_count首次投递为 NULL天然支持逐级退避。完整的逐步演练发送坏消息 → nack → 观察retry_count递增 → 进入 DLQ → 回放请阅读官方教程 docs/tutorial.md 的 Step 7 与 Step 8。max_retries 配置与死信路由规则每个队列可独立设置重试上限select pgque.set_queue_config(orders, max_retries, 10);queue_max_retries列的默认值是 SQLNULLnack内部按coalesce(queue_max_retries, 5)计算所以有效默认值是 5 次重试详见 docs/reference.md 的 Queue config 一节参数校验逻辑在 queue_max_retries.sql。死信路由的判定条件是coalesce(ev_retry, 0) max_retries。以max_retries 2为例推演第几次 nack存储的 retry_count判定结果100 2 不成立重试计数变为 1211 2 不成立重试计数变为 2322 2 成立进入pgque.dead_letter也就是说最多重试 2 次意味着总共投递 3 次。整个死信表的建表与event_dead的幂等插入逻辑重复 nack 同一条终态消息只产生一行 DLQ见 dlq.sql。死信队列DLQ检查、回放与清理SQL 操作速查PgQ 原始版本只有重试队列死信队列是 PgQue 新增的能力。所有 DLQ 函数汇总如下签名与权限见 docs/reference.md函数作用所需角色dlq_inspect(queue, limit100)按时间倒序列出该队列的死信含dl_reason、原始 payloadpgque_readerdlq_replay(dl_id)回放单条重新入队并删除 DLQ 行返回新事件 idpgque_writerdlq_replay_all(queue)回放整个队列的死信逐条隔离失败返回(replayed, failed, first_error)pgque_writerdlq_purge(queue, older_than30 days)删除超过时限的死信返回删除条数pgque_admin日常运维四件套-- 1. 检查最近 20 条死信及失败原因 select dl_id, dl_reason, ev_type, ev_data from pgque.dlq_inspect(orders, 20); -- 2. 修复上游 bug 后单条回放带新 ev_id 重新入队 select pgque.dlq_replay(42); -- 3. 一键回放整队failed 0 时查看 first_error select replayed, failed, first_error from pgque.dlq_replay_all(orders); -- 4. 清理 7 天前的死信默认 30 天 select pgque.dlq_purge(orders, interval 7 days);注意dlq_replay_all返回的是 record 而非整数——读取时务必按列名取replayed / failed / first_error。回放属于生产动作所以授予pgque_writer纯消费角色只能inspect。客户端重试黄金模式Python / Go / TypeScript 官方库实战PgQue 提供 Python、Go、TypeScript 三个官方客户端clients/python、clients/go、clients/typescript都封装了同一个send / receive / ack / nack面。以 Python 客户端为例consumer.py 的常驻消费者默认行为就是重试黄金模式处理器抛出异常 → 自动nack默认retry_after60秒事件类型没有注册处理器 → 同样nack可用unknown_handler_policy改为ack丢弃重试耗尽后消息自动进入dead_letter客户端不感知、不会阻塞。import pgque with pgque.connect(postgresql://localhost/mydb) as client: client.handler(order.created) def handle(msg): call_downstream(msg.payload) # 抛异常 自动 nack 重试 client.listen(orders, processor) # 异常自动 nack(60s) → 5 次后进 DLQ三条落地建议用retry_count做指数退避——SQL 侧可写perform pgque.nack(bid, msg, (60 * power(2, coalesce(msg.retry_count,0)))::int * interval 1 second, reason)业务写库要与ack同一事务才能获得 exactly-once 效果模式见 docs/examples.md 的 Exactly-once processing 一节消费端幂等PgQue 默认 at-least-once重试必然带来重复投递的可能处理器应按msg_id去重。监控重试风暴与 DLQ 深度告警信号速查表重试与死信是最值得告警的信号。docs/monitoring.md 给出的阈值表中与本章直接相关的有两条信号来源告警条件含义DLQ 深度pgque.dead_letter计数 /dlq_inspect死信积压持续增长或预期为零却非零有下游在反复失败重试已耗尽重试速率pgque.error_rate(queue, period, bucket)重试分桶值异常抬升瞬时故障正在放大为重试风暴两条最常用的只读查询pgque_reader即可执行-- 各队列死信深度 select dl_queue_id, count(*) as dlq_depth, max(dl_time) as latest from pgque.dead_letter group by dl_queue_id order by dlq_depth desc; -- 按时间桶看重试与死信速率 select * from pgque.error_rate(orders, interval 1 hour, interval 5 minutes);经验法则DLQ 非空本身就是事件——它说明有消息连续失败超过max_retries次此时应先看dl_reason与ev_data定位下游故障修复后再回放而不是扩大重试上限。常见坑点与最佳实践清单nack后忘了ack消费者永远停在该 batch推荐用单个DO块receive → 逐条处理/nack → 批量 ack教程 Step 7 的原样模式⏱️send、ticker、receive必须各自独立事务ticker 的快照必须晚于send提交重试事件搬回后亦然snapshot rule见 docs/concepts.mddlq_replay返回的是新ev_id原事件 id 不复用依赖ev_id做幂等的系统要留意队列删除会级联清空死信dead_letter的外键是on delete cascade需要留档的审计数据请先dlq_purge前导出或复制⚙️调max_retries前先调retry_after上限是熔断间隔才是节流两者配合才能吸收长尾故障告警看趋势不看单点DLQ 深度与lag连续多个采样点增长再告警避免 tick 抖动误报。总结PgQue 把重试 死信做成了队列的内建能力nack一个函数同时承担退避重投与死信路由retry_queue/dead_letter两张表让失败流量与主事件流彻底隔离配合零膨胀的快照批量架构重试风暴也不会污染热路径。配合三个官方客户端的自动 nack 语义和error_rate监控你就获得了一套完整的可靠投递体系——不丢消息、不重试风暴、失败可审计、可回放、可清理。下一步建议阅读 docs/tutorial.md 亲手跑一遍 Step 7/8并在 tests/acceptance/us3_retry_dlq.sql 中查看该流程的完整集成测试实现。赞分享【免费下载链接】PgQuePgQue – Zero-bloat Postgres queue built on top of on battle-proven Skypes PgQ. One SQL file to install, pg_cron to tick https://pgque.dev项目地址https://gitcode.com/gh_mirrors/pg/PgQue点击查看免费下载相关推荐JEECG-Boot消息队列实战RabbitMQ可靠消息投递与死信队列处理完整指南JEECG Boot消息队列实战RabbitMQ可靠消息投递与死信队列处理完整指南 JEECG Boot作为一款优秀的企业级快速开发框架集成了强大的 Rab低代码后端前端AI 应用大模型RAG工作流自动化Orleans与消息队列可靠性消息重试与死信队列Orleans与消息队列可靠性消息重试与死信队列 在分布式系统中消息传递的可靠性直接影响系统稳定性。Orleans作为微软开发的分布式计算框架提供了完善的后端微服务node-interview消息可靠性消息重试与死信队列node interview消息可靠性消息重试与死信队列 你是否曾遇到过消息发送失败导致订单状态异常或者因网络波动造成关键通知丢失在分布式系统中消息传递文档教程创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考