Kafka网络模型是一个用于处理大规模流数据的分布式系统
发布时间
阅读量：
阅读量
Kafka采用了基于NIO的Reactor多线程架构来进行网络通信模型的设计。该系统的主要组件包括一个Accepter核心线程、多个Processor处理节点以及M个业务处理单元。
| 线程数 | 线程名 | 线程具体说明 |
|---|---|---|
| 1 | kafka-socket-acceptor | Acceptor线程，负责监听Client端发起的请求 |
| N | kafka-network-thread | Processor线程，负责对Socket进行读写 |
| M | kafka-request-handler | Worker线程，处理具体的业务逻辑并生成Response返回 |
Kafka网络通信层的完整框架图如下图所示：
Kafka网络通信模型中的几个重要概念：
Accept Thread主要处理与客户端之间的通信并建立相应的网络连接，并将所有的Socket资源按照一定的周期性切换给相应的Process Thread来继续处理
Process Thread：负责处理客户端的请求与响应信息；每当Selector事件触发时；Process Thread会首先从Response
全部评论 (0)
还没有任何评论哟~