面試題
如何保證訊息的順序性？
面試官心理分析
其實這個也是用 mq 的時候必問的話題，第一看看你了不了解順序這個事兒？第二看看你有沒有辦法保證訊息是有順序的？這是生產系統中常見的問題。
面試題剖析
我舉個例子，我們以前做過乙個 mysql binlog 同步的系統，壓力還是非常大的，日同步資料要達到上億，就是說資料從乙個 mysql 庫原封不動地同步到另乙個 mysql 庫裡面去（mysql -> mysql）。常見的一點在於說比如大資料 team，就需要同步乙個 mysql 庫過來，對公司的業務系統的資料做各種複雜的操作。
你在 mysql 裡增刪改一條資料，對應出來了增刪改 3 條 binlog 日誌，接著這三條 binlog 傳送到 mq 裡面，再消費出來依次執行，起碼得保證人家是按照順序來的吧？不然本來是：增加、修改、刪除；你楞是換了順序給執行成刪除、修改、增加，不全錯了麼。
本來這個資料同步過來，應該最後這個資料被刪除了；結果你搞錯了這個順序，最後這個資料保留下來了，資料同步就出錯了。
先看看順序會錯亂的倆場景：
rabbitmq
乙個 queue，多個 consumer。比如，生產者向 rabbitmq 裡傳送了三條資料，順序依次是 data1/data2/data3，壓入的是 rabbitmq 的乙個記憶體佇列。有三個消費者分別從 mq 中消費這三條資料中的一條，結果消費者2先執行完操作，把 data2 存入資料庫，然後是 data1/data3。這不明顯亂了。
比如說我們建了乙個 topic，有三個 partition。生產者在寫的時候，其實可以指定乙個 key，比如說我們指定了某個訂單 id 作為 key，那麼這個訂單相關的資料，一定會被分發到同乙個 partition 中去，而且這個 partition 中的資料一定是有順序的。
消費者從 partition 中取出來資料的時候，也一定是有順序的。到這裡，順序還是 ok 的，沒有錯亂。接著，我們在消費者裡可能會搞多個執行緒來併發處理訊息。因為如果消費者是單執行緒消費處理，而處理比較耗時的話，比如處理一條訊息耗時幾十 ms，那麼 1 秒鐘只能處理幾十條訊息，這吞吐量太低了。而多個執行緒併發跑的話，順序可能就亂掉了。
解決方案
rabbitmq
拆分多個 queue，每個 queue 乙個 consumer，就是多一些 queue 而已，確實是麻煩點；或者就乙個 queue 但是對應乙個 consumer，然後這個 consumer 內部用記憶體佇列做排隊，然後分發給底層不同的 worker 來處理。
如何保證訊息的順序性？
我舉個例子，我們以前做過乙個 mysql binlog 同步的系統，壓力還是非常大的，日同步資料要達到上億，就是說資料從乙個 mysql 庫原封不動地同步到另乙個 mysql 庫裡面去 mysql mysql 常見的一點在於說比如大資料 team，就需要同步乙個 mysql 庫過來，對公司的業務系統...
如何保證訊息的順序性？
如何保證訊息的順序性？其實這個也是用 mq 的時候必問的話題，第一看看你了不了解順序這個事兒？第二看看你有沒有辦法保證訊息是有順序的？這是生產系統中常見的問題。我舉個例子，我們以前做過乙個 mysql binlog 同步的系統，壓力還是非常大的，日同步資料要達到上億，就是說資料從乙個 mysql 庫...
如何保證訊息佇列訊息的順序性
舉個例子 有乙個mysql binlog 同步系統，壓力是非常大的，日同步資料達到了上億級別，就是將資料從乙個 mysql 庫當中原封不動的同步到另乙個 mysql 庫當中去 比較常見的就是大資料組需要幹的事情 假設在 mysql 當中增刪改了一條資料，對應的生產了三條 增刪改的 binlog 日誌...