构建线程池
监听
添加到Map
PlaintextChannelBuilder
KafkaChannel
addToCompletedReceives
poll
pollSelectionKeys
kafkaServer
Acceptor
线程启动
方法
返回NetworkReceive
sendRequest
得到request之后调用handle
run
NetworkReceive
KafkaApis初始化
accept
readFrom
processCompletedReceives
初始化的时候需要创建
completedReceives
RequestChannel
runnablesKafkaRequestHandler
Processor
调用
属性
read
receive
readFromReadableChannel从通道中读取数据放入buffer
processNewResponses
KafkaRequestHandlerPool
buildChannel
handle
socketServer
selector
需要请求的加入列表
Selector
启动Processor
KafkaRequestHandler
requestQueue
newConnections
预加载
初始化
processor
会从channels中选取channel
判断是否为空，不为空，循环
channels
configureNewConnections
attachment返回channel
stagedReceives
调用，req加入列表，构建Request
addToStagedReceives
添加到列表中
循环列表的值
startup
Processor方法
register(key.attach(channel))
kafkaController
对新连接做处理OP_READ
启动线程
调用acceptor
KafkaApis
返回
