Kafka——SocketServer分析

上文講到Sender 線程把消息封裝成 ClientRequest 之後放入 selector 的 send 字段在由其 poll 方法進行發送消息。那麼在 KafkaServer 中則是通過 SocketServer 接受消息並且進行處理。並採用了 Reactor 模式 現在我們來看一下 SocketServer 它的模型是一個 endpoint 綁定一個 Acceptor 對應多個 Proce

>>阅读原文<<