目錄

1、面試題

2、面試官心裡分析

3、面試題剖析

1、面試題

如何保證訊息的順序性？

2、面試官心裡分析

其實這個也是用MQ的時候必問的話題，第一看看你瞭解不瞭解順序這個事兒？第二看看你有沒有辦法保證訊息是有順序的？這個生產系統中常見的問題。

3、面試題剖析

我舉個例子，我們以前做過一個mysql binlog+同步的系統，壓力還是非常大的，日同步資料要達到上億。mysql -> mysql，常見的一點在於說大資料team，就需要同步一個mysql庫過來，對公司的業務系統的資料做各種複雜的操作。

你在mysql裡增刪改一條資料，對應出來了增刪改3條binlog，接著這三條binlog傳送到MQ裡面，到消費出來依次執行，起碼得保證人家是按照順序來的吧？不然本來是：增加、修改、刪除；你楞是換了順序給執行成刪除、修改、增加，不全錯了麼。

本來這個資料同步過來，應該最後這個資料被刪除了；結果你搞錯了這個順序，最後這個資料保留下來了，資料同步就出錯了。

先看看順序會錯亂的倆場景

（1）rabbitmq：一個queue，多個consumer，這不明顯亂了

（2）kafka：一個topic，一個partition，一個consumer，內部多執行緒，這不也明顯亂了

那如何保證訊息的順序性呢？簡單簡單

（1）rabbitmq：拆分多個queue，每個queue一個consumer，就是多一些queue而已，確實是麻煩點；或者就一個queue但是對應一個consumer，然後這個consumer內部用記憶體佇列做排隊，然後分發給底層不同的worker來處理

（2）kafka：一個topic，一個partition，一個consumer，內部單執行緒消費，寫N個記憶體queue，然後N個執行緒分別消費一個記憶體queue即可