Kafka SocketServer Reactor with MultiThread （Kafka高并发原理）

使用java nio的Selector（多路复用）技术 每个EndPoint对应一个Acceptor，Acceptor运行在一个Thread中，打开ServerSocketChannel，监听连接事件。 当有新的连接请求进入时，通过Selector可以获取到对应的SelectionKey_Accept。Acceptor把SelectionKey_Accept转交给Processor处理。 一个Ac

>>阅读原文<<