關於MQ的幾件小事（七）若是讓你設計一個MQ，你怎麼設計

其實回答這類問題，說白了，起碼不求你看過那技術的源碼，起碼你大概知道那個技術的基本原理，核心組成部分，基本架構構成，而後參照一些開源的技術把一個系統設計出來的思路說一下就好

好比說這個消息隊列系統，咱們來從如下幾個角度來考慮一下

（1）首先這個mq得支持可伸縮性吧，就是須要的時候快速擴容，就能夠增長吞吐量和容量，那怎麼搞？設計個分佈式的系統唄，參照一下kafka的設計理念，broker -> topic -> partition，每一個partition放一個機器，就存一部分數據。若是如今資源不夠了，簡單啊，給topic增長partition，而後作數據遷移，增長機器，不就能夠存放更多數據，提供更高的吞吐量了？

（2）其次你得考慮一下這個mq的數據要不要落地磁盤吧？那確定要了，落磁盤，才能保證別進程掛了數據就丟了。那落磁盤的時候怎麼落啊？順序寫，這樣就沒有磁盤隨機讀寫的尋址開銷，磁盤順序讀寫的性能是很高的，這就是kafka的思路。

（3）其次你考慮一下你的mq的可用性啊？這個事兒，具體參考咱們以前可用性那個環節講解的kafka的高可用保障機制。多副本 -> leader & follower -> broker掛了從新選舉leader便可對外服務。

（4）能不能支持數據0丟失啊？能夠的，參考咱們以前說的那個kafka數據零丟失方案

其實一個mq確定是很複雜的，其實這是個開放題，就是看看你有沒有從架構角度總體構思和設計的思惟以及能力。

若是你還不清楚，請參考前面幾篇
《消息隊列的用途、優缺點、技術選型》
《如何保證消息隊列的高可用》
《如何保證消息不重複消費》
《如何防止數據隊列數據丟失》
《如何保證消息按順序執行》
《消息積壓在消息隊列裏怎麼辦》