https://www.cnblogs.com/hzmark/p/orderly_message.html

Producer端确保消息顺序唯一要做的事情就是将消息路由到特定的分区,在RocketMQ中,通过MessageQueueSelector来实现分区的选择。

Consumer端

RocketMQ消费端有两种类型:MQPullConsumer和MQPushConsumer。

MQPullConsumer由用户控制线程,主动从服务端获取消息,每次获取到的是一个MessageQueue中的消息。PullResult中的List msgFoundList自然和存储顺序一致,用户需要再拿到这批消息后自己保证消费的顺序。

对于PushConsumer,由用户注册MessageListener来消费消息,在客户端中需要保证调用MessageListener时消息的顺序性。RocketMQ中的实现如下:

相关文章:

  • 2018-05-23
  • 2022-12-23
  • 2021-05-02
  • 2021-09-09
  • 2021-08-24
  • 2021-05-19
猜你喜欢
  • 2021-12-31
  • 2018-05-21
  • 2022-12-23
  • 2021-05-13
  • 2021-04-06
  • 2021-07-17
  • 2021-10-01
相关资源
相似解决方案