原文出處:https://github.com/doocs/advanced-java/blob/master/docs/high-concurrency/mq-design.md
歡迎 star 關(guān)注 GitHub 項目最新動態(tài)阳液!
面試題
如果讓你寫一個消息隊列怕敬,該如何進行架構(gòu)設(shè)計?說一下你的思路帘皿。
面試官心理分析
其實聊到這個問題东跪,一般面試官要考察兩塊:
- 你有沒有對某一個消息隊列做過較為深入的原理的了解,或者從整體了解把握住一個消息隊列的架構(gòu)原理鹰溜。
- 看看你的設(shè)計能力虽填,給你一個常見的系統(tǒng),就是消息隊列系統(tǒng)曹动,看看你能不能從全局把握一下整體架構(gòu)設(shè)計斋日,給出一些關(guān)鍵點出來。
說實話墓陈,問類似問題的時候恶守,大部分人基本都會蒙第献,因為平時從來沒有思考過類似的問題,大多數(shù)人就是平時埋頭用兔港,從來不去思考背后的一些東西庸毫。類似的問題,比如衫樊,如果讓你來設(shè)計一個 Spring 框架你會怎么做飒赃?如果讓你來設(shè)計一個 Dubbo 框架你會怎么做?如果讓你來設(shè)計一個 MyBatis 框架你會怎么做科侈?
面試題剖析
其實回答這類問題资厉,說白了闭翩,不求你看過那技術(shù)的源碼颗管,起碼你要大概知道那個技術(shù)的基本原理玫锋、核心組成部分、基本架構(gòu)構(gòu)成挂脑,然后參照一些開源的技術(shù)把一個系統(tǒng)設(shè)計出來的思路說一下就好藕漱。
比如說這個消息隊列系統(tǒng),我們從以下幾個角度來考慮一下:
首先這個 mq 得支持可伸縮性吧崭闲,就是需要的時候快速擴容肋联,就可以增加吞吐量和容量,那怎么搞刁俭?設(shè)計個分布式的系統(tǒng)唄橄仍,參照一下 kafka 的設(shè)計理念,broker -> topic -> partition牍戚,每個 partition 放一個機器侮繁,就存一部分數(shù)據(jù)。如果現(xiàn)在資源不夠了如孝,簡單啊宪哩,給 topic 增加 partition,然后做數(shù)據(jù)遷移第晰,增加機器锁孟,不就可以存放更多數(shù)據(jù),提供更高的吞吐量了茁瘦?
其次你得考慮一下這個 mq 的數(shù)據(jù)要不要落地磁盤吧品抽?那肯定要了,落磁盤才能保證別進程掛了數(shù)據(jù)就丟了甜熔。那落磁盤的時候怎么落霸残簟?順序?qū)懬幌。@樣就沒有磁盤隨機讀寫的尋址開銷盆昙,磁盤順序讀寫的性能是很高的羽历,這就是 kafka 的思路。
其次你考慮一下你的 mq 的可用性暗病窄陡?這個事兒,具體參考之前可用性那個環(huán)節(jié)講解的 kafka 的高可用保障機制拆火。多副本 -> leader & follower -> broker 掛了重新選舉 leader 即可對外服務(wù)。
能不能支持數(shù)據(jù) 0 丟失巴吭病们镜?可以的,參考我們之前說的那個 kafka 數(shù)據(jù)零丟失方案润歉。
mq 肯定是很復(fù)雜的模狭,面試官問你這個問題,其實是個開放題踩衩,他就是看看你有沒有從架構(gòu)角度整體構(gòu)思和設(shè)計的思維以及能力嚼鹉。確實這個問題可以刷掉一大批人,因為大部分人平時不思考這些東西驱富。