当前位置:首页 > 科技  > 软件

三分钟白话RocketMQ系列—— 如何保证消息顺序性

来源: 责编: 时间:2023-09-21 20:48:20 193观看
导读关键字摘要全局有序局部有序局部有序能一直有序吗顺序消息的限制Q1:什么是全局有序?如何实现全局有序?适用于性能要求不高,所有的消息严格按照先进先出(FIFO)的原则来发布和消费的场景。例如,在证券处理中,以人民币兑换美元为

kqy28资讯网——每日最新资讯28at.com

关键字摘要

  • 全局有序
  • 局部有序
  • 局部有序能一直有序吗
  • 顺序消息的限制

Q1:什么是全局有序?如何实现全局有序?

适用于性能要求不高,所有的消息严格按照先进先出(FIFO)的原则来发布和消费的场景。kqy28资讯网——每日最新资讯28at.com

例如,在证券处理中,以人民币兑换美元为Topic,在价格相同的情况下,先出价者优先处理,则可以按照FIFO的方式发布和消费全局顺序消息。kqy28资讯网——每日最新资讯28at.com

要实现全局有序,必须控制Topic只有一个队列queue,才能实现全局有序。kqy28资讯网——每日最新资讯28at.com

由于只有一个队列存在,这种方式虽然保证了全局有序,但是性能不高,无法扩展。kqy28资讯网——每日最新资讯28at.com

Q2:什么是局部有序?如何实现局部有序?

适用于性能要求高,以Sharding Key作为分区字段,在同一个队列queue中严格地按照FIFO原则进行消息发布和消费的场景。kqy28资讯网——每日最新资讯28at.com

例如,用户注册需要发送发验证码,以用户ID作为Sharding Key,那么同一个用户发送的消息都会按照发布的先后顺序来消费。kqy28资讯网——每日最新资讯28at.com

保证「消息生产」的顺序性,则必须满足以下条件:kqy28资讯网——每日最新资讯28at.com

  • 单一生产者:消息生产的顺序性仅支持单一生产者,不同生产者分布在不同的系统,即使设置相同的分区键,不同生产者之间产生的消息也无法判定其先后顺序。
  • 串行发送:生产者客户端支持多线程安全访问,但如果生产者使用多线程并行发送,则不同线程间产生的消息将无法判定其先后顺序。

满足以上条件的生产者,将 「顺序消息」 发送至服务端后,会保证设置了同一分区键的消息,按照发送顺序存储在同一队列中。kqy28资讯网——每日最新资讯28at.com

kqy28资讯网——每日最新资讯28at.com

局部有序(分区有序)kqy28资讯网——每日最新资讯28at.com

注意,在RocketMQ 5.x版本中,新增了「消息组」概念,顺序消息发送必须要设置消息组。kqy28资讯网——每日最新资讯28at.com

保证「消息消费」的顺序性,则必须满足以下条件:kqy28资讯网——每日最新资讯28at.com

  • 语义正确。业务方消费消息时需要严格按照 接收---处理---应答 的语义处理消息,避免因异步处理导致消息乱序。
  • 有限重试。顺序消息消费投递次数限定有限范围内,即一条消息如果超过最大重试次数后,将跳过这条消息消费,不会一直阻塞后续消息处理。

对于需要严格保证消费顺序的场景,请务必设置合理的重试次数,避免参数不合理导致消息乱序。kqy28资讯网——每日最新资讯28at.com

Q3:如果Broker掉线,局部有序还能保持有序吗?

如果一个Broker掉线,那么此时队列总数是否会发化?kqy28资讯网——每日最新资讯28at.com

如果发生变化,那么同一个 ShardingKey 的消息就会发送到不同的队列上,造成乱序。kqy28资讯网——每日最新资讯28at.com

如果不发生变化,那消息将会发送到掉线Broker的队列上,必然是失败的。kqy28资讯网——每日最新资讯28at.com

因此 Apache RocketMQ 提供了两种模式,如果要保证严格顺序而不是可用性,创建 Topic 是要指定 -o 参数(--order)为true,表示顺序消息:kqy28资讯网——每日最新资讯28at.com

$ sh bin/mqadmin updateTopic -c DefaultCluster -t TopicTest -o true -n 127.0.0.1:9876create topic to 127.0.0.1:10911 success.TopicConfig [topicName=TopicTest, readQueueNums=8, writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, order=true, attributes=null]

其次,要保证NameServer中的配置 orderMessageEnable 和 returnOrderTopicConfigToBroker 必须是 true。kqy28资讯网——每日最新资讯28at.com

如果上述任意一个条件不满足,则是保证可用性而不是严格顺序。kqy28资讯网——每日最新资讯28at.com

Q4: 顺序消息有哪些限制?

同一条消息是否可以既是顺序消息,又是定时消息和事务消息?kqy28资讯网——每日最新资讯28at.com

不可以。顺序消息、定时消息、事务消息是不同的消息类型,三者是互斥关系,不能叠加在一起使用。kqy28资讯网——每日最新资讯28at.com

为什么全局顺序消息性能一般?kqy28资讯网——每日最新资讯28at.com

全局顺序消息是严格按照FIFO的消息阻塞原则,即上一条消息没有被成功消费,那么下一条消息会一直被存储到Topic队列中。kqy28资讯网——每日最新资讯28at.com

关键字总结

  • 全局有序:必须控制Topic只有一个队列queue,才能实现全局有序,性能一般。
  • 局部有序:性能较好,需要确保「生产有序」和「消费有序」,同时注意Broker掉线时的 可用性 与 有序性 权衡。

本文链接://www.dmpip.com//www.dmpip.com/showinfo-26-10904-0.html三分钟白话RocketMQ系列—— 如何保证消息顺序性

声明:本网页内容旨在传播知识,若有侵权等问题请及时与本网联系,我们将在第一时间删除处理。邮件:2376512515@qq.com

上一篇: 实用!Python数据去重与唯一值提取:高效整理数据

下一篇: 什么是 Merge Queue,为什么要使用它?

标签:
  • 热门焦点
  • 小米降噪蓝牙耳机Necklace分享:听一首歌 读懂一个故事

    小米降噪蓝牙耳机Necklace分享:听一首歌 读懂一个故事

    在今天下午的小米Civi 2新品发布会上,小米还带来了一款新的降噪蓝牙耳机Necklace,我们也在发布结束的第一时间给大家带来这款耳机的简单分享。现在大家能见到最多的蓝牙耳机
  • 5月iOS设备性能榜:M1 M2依旧是榜单前五

    5月iOS设备性能榜:M1 M2依旧是榜单前五

    和上个月一样,没有新品发布的iOS设备性能榜的上榜设备并没有什么更替,仅仅只有跑分变化而产生的排名变动,刚刚开始的苹果WWDC2023,推出的产品也依旧是新款Mac Pro、新款Mac Stu
  • 谷歌KDD'23工作:如何提升推荐系统Ranking模型训练稳定性

    谷歌KDD'23工作:如何提升推荐系统Ranking模型训练稳定性

    谷歌在KDD 2023发表了一篇工作,探索了推荐系统ranking模型的训练稳定性问题,分析了造成训练稳定性存在问题的潜在原因,以及现有的一些提升模型稳定性方法的不足,并提出了一种新
  • JVM优化:实战OutOfMemoryError异常

    JVM优化:实战OutOfMemoryError异常

    一、Java堆溢出堆内存中主要存放对象、数组等,只要不断地创建这些对象,并且保证 GC Roots 到对象之间有可达路径来避免垃 圾收集回收机制清除这些对象,当这些对象所占空间超过
  • 每天一道面试题-CPU伪共享

    每天一道面试题-CPU伪共享

    前言:了不起:又到了每天一到面试题的时候了!学弟,最近学习的怎么样啊 了不起学弟:最近学习的还不错,每天都在学习,每天都在进步! 了不起:那你最近学习的什么呢? 了不起学弟:最近在学习C
  • 自律,给不了Keep自由!

    自律,给不了Keep自由!

    来源 | 互联网品牌官作者 | 李大为编排 | 又耳 审核 | 谷晓辉自律能不能给用户自由暂时不好说,但大概率不能给Keep自由。近日,全球最大的在线健身平台Keep正式登陆港交所,努力
  • 联想的ThinkBook Plus下一版曝光,键盘旁边塞个平板

    联想的ThinkBook Plus下一版曝光,键盘旁边塞个平板

    ThinkBook Plus 是联想的一个特殊笔记本类别,它在封面放入了一块墨水屏,也给人留下了较为深刻的印象。据有人爆料,联想的下一款 ThinkBook Plus 可能更特殊,它
  • onebot M24巧系列一体机采用轻薄机身设计,现已在各平台开售

    onebot M24巧系列一体机采用轻薄机身设计,现已在各平台开售

    onebot M24 巧系列一体机目前已在线上线下各平台同步开售。onebot M24 巧系列采用一体化轻薄机身设计,最薄处为 10.15mm,拥有宝石红、午夜蓝、石墨绿、雅致
  • AI艺术欣赏体验会在上海梅赛德斯奔驰中心音乐俱乐部上演

    AI艺术欣赏体验会在上海梅赛德斯奔驰中心音乐俱乐部上演

    光影交错的镜像世界,虚实幻化的视觉奇观,虚拟偶像与真人共同主持,这些场景都出现在2019世界人工智能大会的舞台上。8月29日至31日,“AI艺术欣赏体验会”在上海
Top
Baidu
map