如何保证消息的顺序性?

场景

以前做过一个MySQL binlog同步系统,压力还是非常大的,日同步数据要达到上亿。常见一点的在于 大数据项目中,就需要同步一个mysql库过来,然后对公司业务的系统做各种的复杂操作。

在mysql里增删改一条数据,对应出来的增删改3条binlog,接着这三条binlog发送到MQ里面,到消费出来依次执行,这个时候起码得保证能够顺序执行,不然本来是:增加、修改、删除,然后被换成了:删除、修改、增加,不全错了呢。

本来这个数据同步过来,应该是最后删除的,结果因为顺序搞错了,最后这个数据被保留了下来,数据同步就出错

  • RabbitMQ:一个queue,多个consumer,这不明显乱了
  • Kafka:一个topic,一个partition,一个consumer,内部多线程,就会乱套

在消息队列中,一个queue中的数据,一次只会被一个消费者消费掉

消息队列-如何保证消息的顺序性?

但因为不同消费者的执行速度不一致,在存入数据库后,造成顺序不一致的问题

消息队列-如何保证消息的顺序性?

RabbitMQ保证消息顺序性

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

下图为:一个consumer 对应 一个 queue,这样就保证了消息消费的顺序性。

消息队列-如何保证消息的顺序性?

Kafka保证消息消息顺序性

一个topic,一个partition,一个consumer,内部单线程消费,写N个内存,然后N个线程分别消费一个内存queu即可。注意,kafka中,写入一个partition中的数据,一定是有顺序的,

消息队列-如何保证消息的顺序性?

但是在一个消费者的内部,假设有多个线程并发的进行数据的消费,那么这个消息又会乱掉

消息队列-如何保证消息的顺序性?

这样时候,我们需要引入内存队列,然后我们通过消息的key,然后我们通过hash算法,进行hash分发,将相同订单key的散列到我们的同一个内存队列中,然后每一个线程从这个Queue中拉数据,同一个内存Queue也是有顺序的。

消息队列-如何保证消息的顺序性?

相关文章:

  • 2021-10-01
  • 2021-07-04
  • 2022-12-23
  • 2021-11-17
  • 2021-07-13
  • 2021-09-16
  • 2021-11-08
猜你喜欢
  • 2021-08-23
  • 2021-11-25
  • 2022-12-23
  • 2021-04-08
  • 2021-06-24
相关资源
相似解决方案