腾讯二面：引入RabbitMQ后，你如何保证全链路数据100%不丢失？

阅读量：779 次

发布时间：2019-03-24

本文共 584 字，大约阅读时间需要 1 分钟。

RabbitMQ消息可靠性投递全解析

在消息系统中，消息从生产端到消费端的传输过程中可能会出现丢失，虽然这种情况概率极低，但不可忽视。我们需要通过多种机制来确保消息的可靠性传输。

生产端可靠性投递

生产端的可靠性投递主要依赖于RabbitMQ的confirm机制。通过设置confirmSelect模式，生产端可以接收到RabbitMQ的确认消息，从而判断消息是否成功投递。同时，通过设置确认监听，可以实现消息的重发策略，确保消息不会因为RabbitMQ内部错误而丢失。

消息持久化

消息持久化是RabbitMQ的一项重要机制。通过配置exchange、queue和message的持久化，可以保证RabbitMQ在重启时能够恢复消息。这种机制能够防止因RabbitMQ进程退出而导致的消息丢失。

消费端消息不丢失

消费端的消息不丢失主要依赖于手动确认机制。通过设置autoAck为false，可以让消费端对消息进行手动确认，从而避免RabbitMQ自动删除消息。这种机制能够防止因消费端连接丢失或处理异常而导致的消息丢失。

消息补偿机制

为了应对极端情况，生产端可以结合消息入库机制，通过将消息持久化到数据库，实现消息的补偿。这样可以确保消息在生产端和RabbitMQ之间的传输过程中不会丢失。

通过以上机制，可以有效地保证消息在生产端到消费端的传输过程中的可靠性。

转载地址：http://bsfuk.baihongyu.com/

你可能感兴趣的文章

Pinia入门（快速上手）

Pinia：$patch的使用场景

Pinia：$subscribe()的使用场景

Pinpoint对Kubernetes关键业务模块进行全链路监控

Pinterest 大规模缓存集群的架构剖析

pintos project (2) Project 1 Thread -Mission 1 Code

PinYin4j库的使用

pip install goose-extractor // SyntaxError: Missing parentheses in call to 'print'

pip install mysqlclient报错

pip install 出现报asciii码错误的解决

pip throws TypeError: parse() got an unexpected keyword argument ‘transport_encoding‘ 在尝试安装新软件包时

pip 升级报错AttributeError: ‘NoneType’ object has no attribute ‘bytes’

pip 安装opencv-python卡死

pip 安装出现异常

Pip 安装失败:需要 SSL

Pip 安装挂起

pip 或 pip3 为 Python 3 安装包?

pip 文件损坏导致 pip无法使用报错 ImportError: cannot import name 'main' from 'pip._int