后端开发
消息存储 标签描述

回顾上一篇核心概念,我们知道RocketMQ的消息模型分为生产、存储(消息堆积)、消费三大部分。 消息模型三大部分 因此,如何保证消息不丢失,也是从这三个环节来考虑。 关键字摘要 生产、存储(消息堆积)、消费三个环节保证消息不丢失 生产环节:消息类型,消息确认机制、失败重试机制 存储环节:同步/异步刷盘、同步/异步复制slave 消费环节:消息确认机制(至少消费成功一次)、失败重试机制、死信队列机制 Q1:如何保证「消息生产」不丢失? 先想想什么情况下,消息生产会丢失消息呢? 生产者将发送消息时,如果出现了网络抖动或者通信异常等问题,消息就有可能会丢失。 那怎么解决...