Kafka內部網絡框架模型分析

Kafka基於高吞吐率和效率考慮,並沒有使用第三方網絡框架,而且自己基於java nio封裝的,總體網絡模型如下:   Broker的內部處理流水線化,分爲多個階段來進行(SEDA),以提高吞吐量和性能,儘量避免Thead盲等待,以下爲過程說明。   Accept Thread負責與客戶端建立連接鏈路,然後把Socket輪轉交給Process Thread Process Thread負責接收請求
相關文章
相關標籤/搜索