分布式系统

Transactional Outbox:数据库成功后事件也不能丢

把业务更新与待发送事件放进同一事务,再通过可重入发布器投递,解决数据库提交和消息发送之间无法原子化的双写问题。

这类问题看似集中在一个 API 或参数上,真正决定可用性的却是状态归属、资源上限和失败后的恢复方式。 先发消息再提交可能发布不存在的状态,先提交再发消息可能在崩溃窗口丢事件。outbox 行与业务行同事务提交,发布成功后单独标记。

分布式正确性来自幂等键、租约、单调版本和可对账事实,而不是假设请求只到一次。超时代表结果未知,调用方不能未经确认就把它解释成失败。

先把实现决策说清楚

落地时要把关键选择变成稳定契约:输入如何校验、状态由谁推进、资源何时释放、旧版本如何降级。只有这样,后续优化才不会改变原有语义。

  • 事件包含 eventId、aggregateId、aggregateVersion 和最小载荷;多个发布器用跳过锁定或租约抢占,消费者仍按 eventId 幂等。
  • 把协议事实、用户意图和自动恢复分层;自动化只能恢复事实,不能推翻用户明确选择。
  • 重试必须带幂等键、退避和截止时间;超过截止时间后建立新任务,而不是继续复活旧回调。

“Transactional Outbox:数据库成功后事件也不能丢”的交付标准是正常路径可用、异常路径收敛、资源有界,并且用户能理解系统为何采用当前状态。 这样得到的不是演示代码,而是能解释、能降级、能回滚的生产能力。

最容易漏掉的失败路径

边界条件会把隐藏假设变成真实事故。弱网、刷新、并发和容量上限必须组合测试,因为单独出现时它们往往都能被重试掩盖。

  • 发布后标记前崩溃会重复事件,因此 outbox 提供至少一次而非恰好一次;无限保留已发记录又会拖慢扫描和备份。
  • 只修正界面状态而没有清理底层资源,下一次操作继承队列、锁或过期凭据并再次失败。
  • 降级路径从未压测,主路径故障时所有流量同时进入更慢、更昂贵的后备方案。

上线前怎样验证

验证时同时观察两端状态、持久化记录和可观测指标。单看某个按钮或一次接口响应,无法证明整个闭环成立。

  1. 在提交、领取、发布和标记四个边界分别杀进程,确认不丢事件、重复可去重且按 aggregateVersion 不会倒序覆盖。
  2. 在操作中途断网、切换网络并恢复,核对两端状态、持久化记录和资源计数最终一致。
  3. 分别覆盖直连、中转、弱网、后台标签页和移动端,报告不能只给平均值或一次成功截图。

最终结果应同时满足正确性、可恢复性和可解释性。任何一项只能依赖刷新页面或工程师猜测,都说明协议闭环仍不完整。

把方法变成一次真实连接

打开 uCopy,让两台设备在浏览器里安全连接并开始传输。

开始免费使用