首页 > 其他 > 详细

RocketMQ笔记4-顺序消费

时间:2019-11-03 10:46:54      阅读:105      评论:0      收藏:0      [点我收藏+]

简介

消息有序指的是可以按照消息的发送顺序来消费(FIFO)。RocketMQ可以严格的保证消息有序,可以分为分区有序或者全局有序。

  • 全局有序:发送和消费参与的queue只有一个,效率低,不推荐
  • 分区有序:有多个queue,但是每个queue中的消息的发送和消费都是有序的

要点

  • 消息顺序发送
    • 单线程同步发送
  • 消息顺序储存
    • 重写MessageQueueSelector接口中的select() 实现消息路由到一个queue
  • 消息顺序消费
    • 设置该监听器MessageListenerOrderly
    • 同一时刻一个消费者中的一个线程对一个队列中的消息进行消费
      • 消费者申请队列锁(只要一个消费者能消费该队列)
      • 拉取消息进行消费,此时通过synchronized上锁(只有一个线程能够消费)

推荐参考

RocketMQ中的顺序消费
rocketmq/docs/cn/RocketMQ_Example.md
聊一聊顺序消息

RocketMQ笔记4-顺序消费

原文:https://www.cnblogs.com/wuba/p/11785191.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!