【消息隊列】如何保證消息的順序性

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便可