如何保證消息的順序性

1、面試官內心分析

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

2、面試題剖析

我舉個例子，咱們之前作過一個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便可