消息积压治理与 MQ 架构设计:从生产事故到简化消息队列
系统分析消息延迟、过期、死信和百万级积压的处理流程,并从协议、存储、索引、副本、消费进度和扩容机制出发设计一个简化消息队列。
Tag
共 3 篇文章。
系统分析消息延迟、过期、死信和百万级积压的处理流程,并从协议、存储、索引、副本、消费进度和扩容机制出发设计一个简化消息队列。
从订单业务出发理解消息队列的解耦、异步和削峰价值,分析 MQ 引入的可用性、一致性与运维成本,并对比 Kafka、RocketMQ、RabbitMQ 和 ActiveMQ 的适用场景。
从生产者、Broker 和消费者三个故障边界分析消息可靠性,梳理确认、持久化、副本、重试、幂等、事务消息和局部顺序的工程实现。