06 如何保證訊息的順序性？

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即可。

以上，便是對於rabbitmq和kafka保證訊息順序性的簡單分析。

文集：