这套 PG NOTIFY + 250ms 轮询 + 指数退避的三层方案，零额外中间件依赖，三个投影监听器共用同一份重试逻辑，出问题该恢复的自己恢复，该报警的留足日志。

你对投影重试是怎么处理的？是走消息队列Zuo死信重试，还是跟我在 DB 层搞定？欢迎在评论区聊聊你的方案。

提前声明：这是我个人的实践经验，不代表Zui佳实践，仅供参考。

但 NOTIFY 有个短板：它是无状态的推送，丢了就丢了。连接中断、进程重启、LISTEN 还没注册完这短短间隙里发的 NOTIFY——这些情况dou会丢消息。Ru果只靠 NOTIFY，丢了的消息要到下次有人写事件才Neng被"顺带"发现。

背景

项目的投影监听器跑了一段时间后我开始认真对待一个问题——投影挂了怎么办。

问题在于：这根管道总有堵塞的时候。

投影重试这件事，核心原则就一条：不同的故障原因，用不同的恢复策略。

把这三层放在一起kan，分工hen明确：

disintegrate-postgres 框架在事件表上自动建了数据库触发器，每次 INSERT 事件后发一条 NOTIFY。投影监听器在启动时通过 .with_notifier 注册了 LISTEN，收到通知后立即醒来处理。

CQRS三层容错方案失效了怎么办？

geng关键的是我不想为这件事引入额外的消息队列。技术栈Yi经够多了——Rust + Leptos + WASM + PostgreSQL + SeaORM + disintegrate，再加个 Kafka 或 RabbitMQ？一个人维护不起。

. 为什么第 次就封顶 秒？

attempts.min 让翻倍在第 次之后停止增长，退避封顶在 秒。Ru果不封顶，按照 * ^n 一直翻——第 次要等 秒，第 次要等 秒。等那么久不如直接放弃，让人介入排查。

CQRS三层容错方案中的指数退避机制

. 为什么是 200ms 起步？

瞬态故障通常几百毫秒内就Neng自愈。200ms 够快，但不会在 PG 挣扎的时候雪上加霜。

CQRS 三层容错方案详解

// orderprojection.rs.withretry})// scheduleprojection.rs.withretry})// servicerequestprojection.rs.withretry})

"为什么百度不收录我的文章？" , 有人问过这样的问题，说实话，这类问题通常和网站的内容质量、结构、外部链接等因素有关，要具体分析.

. 你Ke以这么理解：NOTIFY 是Zui快路径，但必须有人兜底，而这个兜底的就是轮询机制，两者互补.

CQRS 三层容错方案之轮询机制 . PgEventListenerConfig::poller),250ms 是一个"不浪费 CPU，但用户感觉不到延迟"的平衡点。

. 三个投影监听器共用同一个重试函数，通过闭包传入不同的 label 来区分日志：

RetryAction::Wait {duration: Duration::frommillis,}

. 说实话，Ru果一直失败，比如5次全失败，那咱就是说可Neng有系统性问题了——可Neng是 PG 宕机、表结构错乱、磁盘满了。. Abort 后打印一行醒目的错误日志，反而geng早暴露问题.

你怎么kan待CQRS模式下的容错?欢迎分享你的见解.

. 试想一下Ru果没有这个兜底，会咋样?

正常情况下的延迟非常理想——事件提交后几十毫秒内投影就消费完了前端刷新列表数据Yi经在用户完全无感.

. // backend/src/infrastructure/projections/crm/mod.rspub fn projectionlistenerretry<HE: Debug> -> RetryAction { let backoffms = as u32)).min; if attempts>= { eprintln!; return RetryAction::Abort; // 次全失败，放弃等人介入 } eprintln!: {:?}", label, attempts + , err); RetryAction::Wait { duration: Duration::frommillis, }}. 害，为啥非得是250ms呢?

其实是经过试验的.

. 之前试过100ms和500ms，各有各的问题.CQRS与事件溯源结合使用时的挑战

三个投影监听器，跑在独立的tokio任务里：

PgEventListener::builder.uninitialized.registerlistener).withnotifier.withretry}),).start.await;

. 背景先交代一下：项目用事件溯源 + CQRS，订单、排班、服务需求各有一个投影监听器。

它们在后台不停地消费事件流、geng新读模型表.

.

前端Neng SELECT * FROM orders 全仰仗它们.

.

. 为什么 次就 abort？ 投影监听器一直失败意味着有系统性问题.

.

CQRS 三层容错方案小结

.

// backend/src/infrastructure/projections/crm/mod.rspub async fn spawncrmlisteners -> Result&# x3C ;, String> {servicerequestprojection::spawnservicerequestlistener).await ?;orderprojection::spawnorderlistener).await ?;scheduleprojection::spawnschedulelistener.await ?;Ok)}. 每个 spawn*listener 内部Zuo的事dou一样.

. 为什么不用消息队列?, 说实话，一个人维护这么多技术栈Yi经hen吃力了.

. 开发期间我故意断过几次 PG 来验证这套机制.

"为什么我的网站百度不收录", 这类问题啊，其实hen多时候和网站内容质量有关，当然也有其他因素，比如外部链接啥的，你得具体情况具体分析才行.

.

---