Skip to main content

implement-an-outbox-pattern

Implement an outbox pattern that atomically records domain change and event intent, then publishes with idempotency, ordering, observability, and reconciliation. Use when database state and messages must not diverge.

来源信息

仓库
protosphinx/sphinxstack
最近来源活动
2026年7月29日 13:55
检测到的 SKILL.md 语言
英语
星标
3
Forks
0

安装方式

默认使用会先检查来源的 Prompt;你也可以切换为直接命令,或下载本地副本。

检查来源文件

决定是否安装前,请先阅读 SKILL.md,以及 SkillsMP 当前展示的配套文件。

文件资源管理器
2 个文件

正在显示 SKILL.md

SKILL.md
来源说明 · 只读预览
name
implement-an-outbox-pattern
category
code
description
Implement an outbox pattern that atomically records domain change and event intent, then publishes with idempotency, ordering, observability, and reconciliation. Use when database state and messages must not diverge.
# implement-an-outbox-pattern Atomic intent plus replay-safe delivery replaces unreliable dual writes. ## When to use - Use when one transaction changes local state and must notify another system. - Do not claim exactly-once delivery; prove idempotent effect and reconciliation. ## Preconditions - Define transaction boundary, event contract, consumers, ordering, retention, throughput, and recovery. ## Procedure 1. Write domain change and outbox row in one local transaction. 2. Assign event ID, aggregate ID, sequence, schema version, occurred time, and safe payload. 3. Publish with claim or lease semantics that survive worker crashes. 4. Record attempts and acknowledgement without deleting the only evidence prematurely. 5. Require consumers to deduplicate event IDs and enforce aggregate ordering where needed. 6. Handle schema compatibility, poison events, retries, dead letters, and redrive. 7. Reconcile domain rows, outbox state, broker acknowledgements, and consumer outcomes. 8. Test every crash window plus backlog and recovery. ## Failure plan - Pause publishing when ordering or consumer compatibility is unsafe while retaining committed intent. ## Worked example An order and `OrderPlaced` event commit together; a crash after broker publish causes a retry that the consumer rejects by event ID. ## Done - An outbox implementation includes schema, transactional write, publisher, consumer contract, retention, reconciliation, and runbook - Rollback, duplicate, ordering, crash-window, backlog, poison, redrive, and end-to-end tests verify delivery
在 GitHub 查看