【消息队列】如何保证消息的顺序性

1、顺序错乱的场景

1）rabbitmq：一个queue，多个consumer

 

2）kafka：一个topic，一个partition，一个consumer，内部多线程

 

 

 

2、那如何保证消息的顺序性

1）rabbitmq：拆分多个queue，每一个queue一个consumer，就是多一些queue而已，确实是麻烦点；或者就一个queue可是对应一个consumer，而后这个consumer内部用内存队列作排队，而后分发给底层不一样的worker来处理

 

2）kafka：一个topic，一个partition，一个consumer，内部单线程消费，写N个内存queue，而后N个线程分别消费一个内存queue便可