栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

突破Java面试(9)-如何保证消息队列的顺序性

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

突破Java面试(9)-如何保证消息队列的顺序性

0 Github 1 面试题

如何保证消息的顺序性?

2 考点分析

MQ必问话题

  • 考察你是否了解顺序性
  • 考察你是否有办法保证消息的顺序性,因为这是生产系统中常见的一个问题.
3 详解 3.0 案例

一个MySQL binlog同步系统,日同步数据达到上亿.

  • 在MySQL里增删改一条数据
  • 即对应出增删改3条binlog
  • 接着这三条binlog发送到MQ里面
  • 消费出来依次执行

应该得保证消息按照顺序执行的吧!
不然本来是:增加->修改->删除
你楞是换了顺序给执行成:删除->修改->增加
全错!!!

该数据同步过来,最后本该被删除,结果你搞错顺序,最后它却被保留下来了,数据同步出错!

3.1 顺序错乱的场景 3.1.1 rabbitmq

一个queue,多个consumer,这不明显乱了

3.1.2 kafka

一个topic,一个partition,一个consumer,内部多线程,这也明显乱了

3.2 保证消息的顺序性 3.2.1 rabbitmq

拆分多个queue,每个queue一个consumer
就是多一些queue而已,确实麻烦点
或者就一个queue但是对应一个consumer,然后这个consumer内部用内存队列做排队,然后分发给底层不同的worker来处理

3.2.2 kafka

一个topic,一个partition,一个consumer,内部单线程消费,写N个内存queue,然后N个线程分别消费一个内存queue即可

参考

《Java工程师面试突击第1季-中华石杉老师》

更多干货请关注JavaEdge公众号

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/239383.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号