Kafka内部网络框架模型分析

Kafka基于高吞吐率和效率考虑,并没有使用第三方网络框架,而且自己基于java nio封装的,总体网络模型如下:   Broker的内部处理流水线化,分为多个阶段来进行(SEDA),以提高吞吐量和性能,尽量避免Thead盲等待,以下为过程说明。   Accept Thread负责与客户端建立连接链路,然后把Socket轮转交给Process Thread Process Thread负责接收请求
相关文章
相关标签/搜索