Kafka SocketServer Reactor with MultiThread （Kafka高併發原理）

使用java nio的Selector（多路複用）技術 每個EndPoint對應一個Acceptor，Acceptor運行在一個Thread中，打開ServerSocketChannel，監聽連接事件。 當有新的連接請求進入時，通過Selector可以獲取到對應的SelectionKey_Accept。Acceptor把SelectionKey_Accept轉交給Processor處理。 一個Ac

>>阅读原文<<