交易救助

事务性加速是一组体系结构技术，可在本地状态变化（DB/缓存）和经纪人/总线消息之间保持一致。目标："在故障↔撤回，缩放和多重影子的情况下，状态不会丢失或复制消息"。

1）交付语义

最多：快速，便宜，可能的损失，没有。
On-Least-once：不会丢失消息,双打是可能的→需要等效性。
（有效的）Exactly once：没有损失，也没有商业效果的可见倍数，是通过结合技术（outbox/inbox，执行者/消费者交易，dedup）来实现的。

2）为什么"twoppismo"是危险的

天真的逻辑"首先写入DB，然后发送到总线"（反之亦然）在步骤之间下降时撕裂：数据被固定，事件丢失。或者事件消失了，没有数据。事务性救助消除了这一差距。

3）基本模式

3.1 Outbox（制造商）

在一个本地事务中，我们将业务更改和行写入"outbox"表格；一个单独的公关人员阅读outbox，并张贴到带有后台和后台的经纪人中。不包括损失；gasim是消费者的偶然性。

3.2 Inbox/Idempotent Consumer（消费者）

在执行效果之前，用户将"INSERT"作为"inbox（consumer，event_id）"中的主键。密钥冲突=事件已处理→跳过。这就是实现"有效的exactly-once"的方式。

3.3 Read-Process-Write with offset交易

面向日志的轮胎模板：用户读取战斗,在同一交易中捕获业务变化和"越过"。Commite之后，经纪人将消息视为消耗。这消除了"阅读→掉落→重复"而没有效果。

3.用于服务间效果的4个TSS/Sagi

当需要一致的多指令过程时，使用TCC或传奇；消息是命令/事件传输，交易是在步骤和补偿级别。

4）异位生产商和消费者

Produser：稳定的"message_id"/"idempotency_key"，使用相同密钥的重新发送不会在订户中产生新的效果；按键保持序列（序列）。
消费者："inbox"+业务水平（upsert/merge，最新版本/修订验证）。

5）顺序和因果关系

通过业务键（例如"aggregate_id"，"tenant_id"）参与以使单个对象的事件按顺序进行。
在批次内保留连续的编号/时间标记；在DLQ的重做中，遵循"按键顺序"。
如果全局顺序不重要，则按键提供局部顺序并固定域不变量。

6）Offset和效果固定

备选桉文A： "OBD中的Offset"

将"最后处理的offset （partition, offset）"写入您更改域数据的同一事务中。重启时，从下一个离场继续进行，避免重复效果。

备选桉文B： "经纪人交易"

一些经纪人在单个执行者/消费者交易中维护消息和离线的原子记录。如果可用，请使用，但始终以消费者的偶数补充。

7） Retrai, backoff, DLQ

仅使用指数后退和抖动重复后退错误（taymouts, 5xx）。
非retraible（计划/验证）-立即在DLQ中使用元数据（tenant，key，offset，原因）。
从DLQ中重新分配（batch, rate limit）,在重播前检查电路,观察按键顺序。

8）多重性与区域

在消息元数据和分期密钥中启用"tenant_id"、"plan"、"region"。
Per-tenant fairness：限制发布/处理,以便"嘈杂"的客户不会从其他人那里获得预算。
驻留：将消息和outbox存储在与域数据相同的区域；区域间复制-异步聚合。

9）可观察性和审计

培训："event_id"/"aggregate_id"/"saga_id"的相关性，并带有"read process write/commit"。
度量：发布/处理差（p95/p99），成功率，DLQ-rate，红土成功，"重复抑制"。
Logi：简而言之；详细说明错误（原因、尝试、关键、错误）。
审计：谁是稀有的/回滚的，比目鱼是什么，结果是什么。

10）安全性和合规性

将付费中的PII降至最低；在DLQ/Logs中传输时伪装。
订阅/加密外部总线的消息；在服务之间使用mTLS。
管理per tenant/region的保质期和"遗忘权"。

11）示范集成方案

1.服务来源（write-side）

本地事务：域记录+outbox。
Publisher： batchi, "SKIP LOCKED", backoff, per tenant限制。
监测laga'now − occurred_at'。

2.消费者服务（阅读面）

读取butch →尝试"INSERT inbox （consumer, event_id）"→成功时,我们执行效果。
在同一交易中，我们记录了"已通过的offset"（选项A）或依赖于经纪人交易（选项B）。
在错误：retray或DLQ的策略。

3.投影/物化视图

仅偶数升级（upsert）、紧凑型重复数据消除密钥、定期校验和对账。

12）配置模板（示例）

yaml producer:
idempotency_key: event_id partition_key: "{tenant_id}:{aggregate_id}"
retry:
max_attempts: 8 initial_ms: 200 max_ms: 8000 strategy: exponential_full_jitter

consumer:
batch: 500 offset_commit: "with_domain_tx"  # или "broker_tx"
inbox_enabled: true concurrency_per_partition: 4 dlq:
enabled: true batch_redrive: 200 rate_limit_per_sec: 50 order_by_key: true

observability:
metrics:
- processing_lag_ms
- publish_success_ratio
- dlq_rate
- redrive_success_ratio tracing_tags: [event_id, tenant_id, aggregate_id, partition, offset]

13）售前支票清单

• 消除了"twoppismo"：在审阅器上装出盒子，或者在审阅者的一笔交易中提交离场和效果。
• Idempotent consumer： "inbox"/dedup magazine, business idementity运营。
• 通过业务密钥参与,遵守当地秩序。
• 带有backoff+jitter的retrai，错误分类，带有丰富元数据的DLQ。
• Redrive剂量，安全；有花花公子。
• 多重限额和优先事项；"tenant_id/plan/region"标签。
• 遥测：泻湖，成功率，"重复抑制"，p95/p99。
• 符合PII/还原/加密政策。
• 测试：在步骤之间下降,重复,按键顺序,质量重复。

14）典型错误

通过单独的步骤发送到总线并写入DB，而没有outbox/offset事务。
不具有相容性的消费者→复制副作用。
"不惜一切代价"的全球秩序是昂贵的，很少有正当理由；按键顺序足够。
无限制的大规模红土→次要事件。
缺少tracing/lag指标→"隐藏降级"。
DLQ/Logs中的PII混合。

15）快速食谱

SaaS事件：Outbox+等效消费者（inbox），通过"tenant_id： aggregate_id"分期付款。
ETL/投影：读取过程写入，在单个事务中提交离线，batchi 500-1000，upsert。
高负荷：乱七八糟，"SKIP LOCKED"，WFQ per tenant，滞后控制。
严格的合规区域：区域外包、加密payload、重整和红土审核。

结论

事务性寻呼是数据和消息连接的学科。通过将outbox/inbox、等效性、离线固定以及效果和受控的转发与DLQ结合起来，您可以获得实际的exactly-once行为，而无需全球锁定，即使发生故障、尖峰和复杂的多阴影操作，也可以保留SLO。