交易救助

事務性加速是一組體系結構技術，可在本地狀態變化（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。