如何保证RocketMQ消息不丢失

news/2024/11/27 17:22:47/文章来源:https://www.cnblogs.com/likeguang/p/18572722

如何保证RocketMQ消息不丢失

如何保证RocketMQ消息不丢失
- 背景
- 什么情况下RokectMQ消息会丢失
- 解决RocketMQ消息丢失问题
  - 消息生产防止消息丢失
  - Broker端消息丢失
  - 消费端处理消息
- 总结

背景

在金融系统中MQ消息的消息丢失是不允许的，消息的丢失会导致支付状态订单状态出现混乱。接下来聊一下如何保证MQ消息不丢失,以笔者公司使用的RocketMQ为例。

什么情况下RokectMQ消息会丢失

MQ的消息生成到消费主要经历三个阶段：生产者发送消息、Broker存储消息、消费者消息对应的消息。如下图：

从上图可以知道消息丢失主要会发生在下面几个地方：

消息生产者将消息发送到RocketMQ Broker的这个过程可能出现消息丢失。
RocketMQ Broker接收到生产者发送的消息存储的过程消息可能丢失。
消费者处理失败，但是将错误进行捕捉，导致消息出现虚假的消费成功。实际上没有消费成功，但是在MQ看来消费完成了消费。

解决RocketMQ消息丢失问题

下面会针对于上述过程中可能丢失的问题给与解决。

消息生产防止消息丢失

RocketMQ消息生产方式有三种：同步发送消息、异步发送消息、One-Way发送消息。不同的发送方式试用不同的场景：

同步发送消息：重要的通知(订单状态的更新)、短信系统。

异步发送消息：通常用于响应时间敏感的业务场景。

One-way：主要用于对可靠性要求不高的场景，在金融的场景下不适用。一般是用于日志收集。

1、所以如果你的系统对消息丢失零容忍不能使用 one-way 的方式发送，因为one-way 的消息发送模式本身就是不对消息的不丢失无法保证；

2、同步发送消息和异步发送消息都可以判断消息的发送状态判断消息是否已经发送到Broker。这里是选择同步发送还是异步发送消息看业务的需要，同步发送比较关心发送后返回的结果，对时间的要求不是那么敏感。异步发送对消息返回时间敏感。

下面找了一个图来进行描述：

下面来对SendResult着重进行说明(来自RocketMQ官方)：

SEND_OK
消息发送成功。要注意的是消息发送成功也不意味着它是可靠的。要确保不会丢失任何消息，还应启用同步Master服务器或同步刷盘，即SYNC_MASTER或SYNC_FLUSH。
FLUSH_DISK_TIMEOUT
消息发送成功但是服务器刷盘超时。此时消息已经进入服务器队列（内存），只有服务器宕机，消息才会丢失。消息存储配置参数中可以设置刷盘方式和同步刷盘时间长度，如果Broker服务器设置了刷盘方式为同步刷盘，即FlushDiskType=SYNC_FLUSH（默认为异步刷盘方式），当Broker服务器未在同步刷盘时间内（默认为5s）完成刷盘，则将返回该状态——刷盘超时。
FLUSH_SLAVE_TIMEOUT
消息发送成功，但是服务器同步到Slave时超时。此时消息已经进入服务器队列，只有服务器宕机，消息才会丢失。如果Broker服务器的角色是同步Master，即SYNC_MASTER（默认是异步Master即ASYNC_MASTER），并且从Broker服务器未在同步刷盘时间（默认为5秒）内完成与主服务器的同步，则将返回该状态——数据同步到Slave服务器超时。
SLAVE_NOT_AVAILABLE
消息发送成功，但是此时Slave不可用。如果Broker服务器的角色是同步Master，即SYNC_MASTER（默认是异步Master服务器即ASYNC_MASTER），但没有配置slave Broker服务器，则将返回该状态——无Slave服务器可用。

Broker端消息丢失

首先了解一下Broker集群部署模式(官方方案)。

单Master模式

这种方式风险较大，一旦Broker重启或者宕机时，会导致整个服务不可用。不建议线上环境使用,可以用于本地测试。

多Master模式

一个集群无Slave，全是Master，例如2个Master或者3个Master，这种模式的优缺点如下：

优点：配置简单，单个Master宕机或重启维护对应用无影响，在磁盘配置为RAID10时，即使机器宕机不可恢复情况下，由于RAID10磁盘非常可靠，消息也不会丢（异步刷盘丢失少量消息，同步刷盘一条不丢），性能最高；
缺点：单台机器宕机期间，这台机器上未被消费的消息在机器恢复之前不可订阅，消息实时性会受到影响。
多Master多Slave模式-异步复制

每个Master配置一个Slave，有多对Master-Slave，HA采用异步复制方式，主备有短暂消息延迟（毫秒级），这种模式的优缺点如下

优点：即使磁盘损坏，消息丢失的非常少，且消息实时性不会受影响，同时Master宕机后，消费者仍然可以从Slave消费，而且此过程对应用透明，不需要人工干预，性能同多Master模式几乎一样；
缺点：Master宕机，磁盘损坏情况下会丢失少量消息(非同步刷盘的情况下)
多Master多Slave模式-同步双写

每个Master配置一个Slave，有多对Master-Slave，HA采用同步双写方式，即只有主备都写成功，才向应用返回成功，这种模式的优缺点如下：

优点：数据与服务都无单点故障，Master宕机情况下，消息无延迟，服务可用性与数据可用性都非常高；
缺点：性能比异步复制模式略低（大约低10%左右），发送单个消息的RT会略高，且目前版本在主节点宕机后，备机不能自动切换为主机

如果是想不存在消息丢失的情况，那么在多Master的情况下要配置消息同步刷盘，而在多Master多Slave模式-同步双写的情况下配置同步刷盘。

消费端处理消息

在处理消息的时候，如果消息处理失败返回的状态不应该是ConsumeConcurrentlyStatus.CONSUME_SUCCESS 。如果消息处理失败返回的是ConsumeConcurrentlyStatus.CONSUME_SUCCESS 消息就不能再次被消息。在Broker看来就是已经消费完成。

所以要针对消息处理一定要严谨。