【消息队列】03 消息队列是如何确保消息不丢失的

消息可靠传递,我们要看消息都在出现在哪里? 生产阶段 通过收到broker 的确认响应,则表示发送成功。同步发送消息可以通过 try catch 捕获异常,进行重发,如果是异步发送消息,则需要写回调方法检查消息是否丢失。 存储阶段 将消息写入多个副本,或者通过配置刷盘和复制相关参数,不因Broker宕机导致消息丢失。 消费阶段 处理完所有的消费业务逻辑后,在发ACK。
相关文章
相关标签/搜索