Damnatiox
知识文件夹

消息与事件驱动

现代 Java Backend Engineering 学习路线:消息与事件驱动

0 子目录5 文档

文档

5
高性能与消息队列推荐阅读高性能与消息队列推荐阅读 性能工程从测量和预算开始。消息中间件用于解耦、缓冲和事件流,但交付语义、顺序、积压与恢复必须显式设计。 官方资料优先顺序 Apache Kafka Documentation RabbitMQ Documentation Apache RocketMQ Concepts Elasticsearch Reference 阅读方法 1. 先阅读概念与快速开始,建立最小可运行闭环。 2. 再阅读 reference 消息与事件驱动:共同模型先于产品配置消息与事件驱动:共同模型先于产品配置 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、deliv消息队列基础:交付、顺序、幂等、积压与死信消息队列基础:交付、顺序、幂等、积压与死信 消息系统在生产者、broker 和消费者之间引入异步边界;可靠性来自协议、持久化、确认、幂等和运维共同作用。 1. 本文覆盖范围 消息模型与分区/队列 至少一次与幂等 顺序、重试和死信 积压、回压和模式演进 2. 核心知识详解 1. 投递链路与确认 生产确认表示 broker 已按配置接收,不代表消费者完成业务。消费者先处理后确认可减少丢失,但崩溃会重投。 生产端设置 id、key、schemApache Kafka:日志、分区、副本、消费组与事务Apache Kafka:日志、分区、副本、消费组与事务 Kafka 把 topic 表示为分区追加日志,消费者以 offset 追踪位置,适合事件流、日志集成和可重放处理。 1. 本文覆盖范围 Topic/partition/record 副本、leader 与 producer ack 消费组与 offset 幂等生产、事务与再均衡 2. 核心知识详解 1. 日志与分区 record 按 key 分配到 partition,分区内有RabbitMQ 与 RocketMQ:路由、队列、可靠性和选择RabbitMQ 与 RocketMQ:路由、队列、可靠性和选择 RabbitMQ 擅长灵活 AMQP 路由和工作队列;RocketMQ 面向大规模消息与事务/延时等业务能力。选择应基于语义和运维证据。 1. 本文覆盖范围 RabbitMQ exchange/binding/queue publisher confirms 与 consumer ack quorum queue 与死信 RocketMQ topic、consumer g