面试官：RocketMQ 如何保证消息不丢失，如何保证消息不被重复消费？

Love The Way You Lie 2023-09-28 19:02 166阅读 0赞

1、消息整体处理过程

5befe477f897064066e42dc740a93ab8.png

这里我们将消息的整体处理阶段分为3个阶段进行分析：

  • Producer发送消息阶段。
  • Broker处理消息阶段。
  • Consumer消费消息阶段。

Producer发送消息阶段

发送消息阶段涉及到Producer到broker的网络通信，因此丢失消息的几率一定会有，那RocketMQ在此阶段用了哪些手段保证消息不丢失了（或者说降低丢失的可能性）。

手段一：提供SYNC的发送消息方式，等待broker处理结果。

RocketMQ提供了3种发送消息方式，分别是：

  • 同步发送：Producer 向 broker 发送消息，阻塞当前线程等待 broker 响应 发送结果。
  • 异步发送：Producer 首先构建一个向 broker 发送消息的任务，把该任务提交给线程池，等执行完该任务时，回调用户自定义的回调函数，执行处理结果。
  • Oneway发送：Oneway 方式只负责发送请求，不等待应答，Producer只负责把请求发出去，而不处理响应结果。

我们在调用producer.send方法时，不指定回调方法，则默认采用同步发送消息的方式&#

发表评论

表情：
评论列表 （有 0 条评论，166人围观）

还没有评论，来说两句吧...

相关阅读

    相关 如何保证消息不被重复消费?

    消息被重复消费，就是消费方多次接受到了同一条消息。根本原因就是，第一次消费完之后，消费方给 MQ 确认已消费的反馈，MQ 没有成功接受。比如网络原因、MQ 重启等。 所以 M

    Bertha 。Bertha 。/ 0 赞/ 150 阅读