1. 首页
  2. IT资讯

每日一题:如何保证消息的顺序性?

“u003Cpu003EJava后端,选择“”u003Cu002Fpu003Eu003Cpu003E优质文章,及时送达u003Cu002Fpu003Eu003Cimg src=”http:u002Fu002Fp1.pstatp.comu002Flargeu002Fpgc-imageu002FRcsUnd92eoboDR” img_width=”640″ img_height=”29″ alt=”每日一题:如何保证消息的顺序性?” inline=”0″u003Eu003Cpu003E原文来自 GitHub 开源社区 Doocs,欢迎 Star 此项目,如果你有独到的见解,同样可以参与贡献此项目。u003Cu002Fpu003Eu003Cpu003Eu003Cu002Fpu003Eu003Ch1 toutiao-origin=”h2″u003E面试题u003Cu002Fh1u003Eu003Cpu003E如何保证消息的顺序性?u003Cu002Fpu003Eu003Cpu003Eu003Cstrong toutiao-origin=”strong” class=”highlight-text”u003E面试官心理分析u003Cu002Fstrongu003Eu003Cu002Fpu003Eu003Cpu003E其实这个也是用 MQ 的时候必问的话题,第一看看你了不了解顺序这个事儿?第二看看你有没有办法保证消息是有顺序的?这是生产系统中常见的问题。u003Cu002Fpu003Eu003Cpu003Eu003Cstrong toutiao-origin=”strong” class=”highlight-text”u003E面试题剖析u003Cu002Fstrongu003Eu003Cu002Fpu003Eu003Cpu003E我举个例子,我们以前做过一个 mysql u003Ccodeu003Ebinlogu003Cu002Fcodeu003E同步的系统,压力还是非常大的,日同步数据要达到上亿,就是说数据从一个 mysql 库原封不动地同步到另一个 mysql 库里面去(mysql -> mysql)。常见的一点在于说比如大数据 team,就需要同步一个 mysql 库过来,对公司的业务系统的数据做各种复杂的操作。u003Cu002Fpu003Eu003Cpu003E你在 mysql 里增删改一条数据,对应出来了增删改 3 条 u003Ccodeu003Ebinlogu003Cu002Fcodeu003E日志,接着这三条u003Ccodeu003Ebinlogu003Cu002Fcodeu003E发送到 MQ 里面,再消费出来依次执行,起码得保证人家是按照顺序来的吧?不然本来是:增加、修改、删除;你楞是换了顺序给执行成删除、修改、增加,不全错了么。u003Cu002Fpu003Eu003Cpu003E本来这个数据同步过来,应该最后这个数据被删除了;结果你搞错了这个顺序,最后这个数据保留下来了,数据同步就出错了。u003Cu002Fpu003Eu003Cpu003E先看看顺序会错乱的俩场景:u003Cu002Fpu003Eu003Culu003Eu003Cliu003Eu003Cpu003ERabbitMQ:一个 queue,多个 consumer。比如,生产者向 RabbitMQ 里发送了三条数据,顺序依次是 data1u002Fdata2u002Fdata3,压入的是 RabbitMQ 的一个内存队列。有三个消费者分别从 MQ 中消费这三条数据中的一条,结果消费者2先执行完操作,把 data2 存入数据库,然后是 data1u002Fdata3。这不明显乱了。u003Cu002Fpu003Eu003Cu002Fliu003Eu003Cu002Fulu003Eu003Cimg src=”http:u002Fu002Fp3.pstatp.comu002Flargeu002Fpgc-imageu002FRdFqPDLDGFUWhu” img_width=”368″ img_height=”497″ alt=”每日一题:如何保证消息的顺序性?” inline=”0″u003Eu003Culu003Eu003Cliu003Eu003Cdivu003Eu003Cpu003EKafka:比如说我们建了一个 topic,有三个 partition。生产者在写的时候,其实可以指定一个 key,比如说我们指定了某个订单 id 作为 key,那么这个订单相关的数据,一定会被分发到同一个 partition 中去,而且这个 partition 中的数据一定是有顺序的。u003Cu002Fpu003Eu003Cpu003E消费者从 partition 中取出来数据的时候,也一定是有顺序的。到这里,顺序还是 ok 的,没有错乱。接着,我们在消费者里可能会搞多个线程来并发处理消息。因为如果消费者是u003Ci class=”chrome-extension-mutihighlight chrome-extension-mutihighlight-style-5″u003E单线u003Cu002Fiu003E程消费处理,而处理比较耗时的话,比如处理一条消息耗时几十 ms,那么 1 秒钟只能处理几十条消息,这吞吐量太低了。而多个线程并发跑的话,顺序可能就乱掉了。u003Cu002Fpu003Eu003Cu002Fdivu003Eu003Cu002Fliu003Eu003Cu002Fulu003Eu003Cimg src=”http:u002Fu002Fp3.pstatp.comu002Flargeu002Fpgc-imageu002FRdFqPDZIdvpL6k” img_width=”517″ img_height=”590″ alt=”每日一题:如何保证消息的顺序性?” inline=”0″u003Eu003Cpu003Eu003Cstrong toutiao-origin=”span”u003E解决方案u003Cu002Fstrongu003Eu003Cu002Fpu003Eu003Cpu003Eu003Cstrong toutiao-origin=”span”u003ERabbitMQu003Cu002Fstrongu003Eu003Cu002Fpu003Eu003Cpu003E拆分多个 queue,每个 queue 一个 consumer,就是多一些 queue 而已,确实是麻烦点;或者就一个 queue 但是对应一个 consumer,然后这个 consumer 内部用内存队列做排队,然后分发给底层不同的 worker 来处理。u003Cu002Fpu003Eu003Cimg src=”http:u002Fu002Fp1.pstatp.comu002Flargeu002Fpgc-imageu002FRdFqPDmCz3ZqA3″ img_width=”358″ img_height=”551″ alt=”每日一题:如何保证消息的顺序性?” inline=”0″u003Eu003Cpu003EKafkau003Cu002Fpu003Eu003Culu003Eu003Cliu003Eu003Cpu003E一个 topic,一个 partition,一个 consumer,内部u003Ci class=”chrome-extension-mutihighlight chrome-extension-mutihighlight-style-5″u003E单线u003Cu002Fiu003E程消费,u003Ci class=”chrome-extension-mutihighlight chrome-extension-mutihighlight-style-5″u003E单线u003Cu002Fiu003E程吞吐量太低,一般不会用这个。u003Cu002Fpu003Eu003Cu002Fliu003Eu003Cliu003Eu003Cpu003E写 N 个内存 queue,具有相同 key 的数据都到同一个内存 queue;然后对于 N 个线程,每个线程分别消费一个内存 queue 即可,这样就能保证顺序性。u003Cu002Fpu003Eu003Cu002Fliu003Eu003Cu002Fulu003Eu003Cimg src=”http:u002Fu002Fp1.pstatp.comu002Flargeu002Fpgc-imageu002FRdFqPDyG4fvjGo” img_width=”517″ img_height=”645″ alt=”每日一题:如何保证消息的顺序性?” inline=”0″u003Eu003Cpu003E-END-u003Cu002Fpu003Eu003Cpu003E如果看到这里,说明你喜欢这篇文章,帮忙u003Cstrong toutiao-origin=”span” class=”highlight-text”u003E转发u003Cu002Fstrongu003E一下吧,感谢。u003Ci class=”chrome-extension-mutihighlight chrome-extension-mutihighlight-style-4″u003E微信u003Cu002Fiu003Eu003Ci class=”chrome-extension-mutihighlight chrome-extension-mutihighlight-style-4″u003E搜索u003Cu002Fiu003E「web_resource」,u003Ci class=”chrome-extension-mutihighlight chrome-extension-mutihighlight-style-6″u003E关注u003Cu002Fiu003E后即可获取每日一题的推送。u003Cu002Fpu003E”

原文始发于:每日一题:如何保证消息的顺序性?

主题测试文章,只做测试使用。发布者:℅傍ㄖ免沦陷dε鬼,转转请注明出处:http://www.cxybcw.com/18030.html

联系我们

13687733322

在线咨询:点击这里给我发消息

邮件:1877088071@qq.com

工作时间:周一至周五,9:30-18:30,节假日休息

QR code