ons 阿里云 rocketMQ

broker

ons 默认有两个brokerName组,分别有0-7共16个队列

还有两个死信队列 topic是 %RETRY%+tag

consumer15分钟消费超时,broker会重发消息

Producer

轮询发送到broker队列

如果发送失败会换个队列

defaultTopicQueueNums

自动创建topic时设置队列数量

ons不允许自动创建topic,也不允许修改队列数量

Consumer

AllocateMessageQueueAveragely

  • 默认 集群消费

平均分配可消费的 Broker 对应的消息队列 c1对应b1,b2,b3 c2对应d1,d2,d3

AllocateMessageQueueAveragelyByCircle

以环状轮流分Broker

广播消费

每个Consume都订阅每个Broker

注意点

  1. 刚启动时,broker分配还没有完成,会导致消息重复消费

  2. 但是可能会存在同样的消息有两个不同 msgId的情况(有多种原因),这种情况可能会使业务上重复消费,建议最好使用消息内容中的唯一标识字段去重

©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

相关阅读更多精彩内容

  • 每个人的想法不同 , RocketMQ 介绍的时候就说 是阿里从他们使用的上 解耦出来 近一步简化 便捷的 目...
    楼亭樵客阅读 462评论 0 0
  • RocketMQ是一款分布式、队列模型的消息中间件,具有以下特点: 能够保证严格的消息顺序 提供丰富的消息拉取模式...
    AI乔治阅读 2,202评论 2 5
  • 1 架构原理 1.1 应用场景 只支持发布订阅模式。 大数据量的消息堆积能力,最终数据是持久化到磁盘上,理论上无限...
    可笑可乐阅读 9,646评论 0 2
  • 一、 关键特性 1 消息发送和消费 1)消息发送者步骤分析: 创建消息生产者producer,并制定生产者组名 指...
    TiaNa_na阅读 2,302评论 0 2
  • 教育故事之三 纸巾的故事 前一段单位在公共卫生间装上了纸巾盒。由于人多,纸巾用的比较快,更换的不够及时。这时就会出...
    宋日红阅读 1,350评论 0 0

友情链接更多精彩内容