消息与事件驱动：共同模型先于产品配置

Freshness metadata

• last_verified: 2026-08-24
• version_scope: Kafka/RabbitMQ/RocketMQ concepts
• source_type: official-docs
• stability: version-sensitive

producer、consumer、partition/queue、ordering、delivery semantics、ack、retry、DLQ、idempotency、duplicate delivery、backpressure、schema 和 outbox 是共同模型。Kafka、RabbitMQ、RocketMQ 的日志/队列、路由、消费与运维设计不同，再按场景选择。

端到端语义

“Exactly once”必须说明边界：broker 内事务、producer、consumer state 和外部数据库不是自动同一事务。现实系统通常以 at-least-once delivery + idempotent consumer + outbox 获得可解释结果。

验收

模拟 duplicate、out-of-order、consumer crash before/after ack、broker unavailable、poison message 和 backlog。记录 event id、aggregate version、attempt、DLQ reason 与业务结果。