我们知道kafka是基于TCP连接的。其并没有像很多中间件使用netty作为TCP服务器。而是自己基于Java NIO写了一套。几个重要类先看下Kafka Client的网络层架构。本文主要分析的是Network层。Network层有两个重要的类:Selector和KafkaChannel。这两个类和Java NIO层的java.nio.channels.Selector和Channel有点类似。
注册时间:2019-04-23