Jafka源码分析——网络架构

在kafka中。每个broker都是一个server。依照一般理解，server就是一个SocketServer，其不断接收用户的请求并进行处理。在Java中进行网络连接有两种方式一种为堵塞模式一种为非堵塞模式。

Jafka採用非堵塞模式进行网络通讯。在Java的非堵塞模式中，建立socket?server的一般流程例如以下：

1.启动ServerSocketChannel并将其绑定到特定的port。

2.将ServerSocketChannel以及其感兴趣的操作注冊到Selector，在这里感兴趣的操作是Accept

3.不断轮询Selector是否有感兴趣的事件发生，假设有则accept远程连接并进行处理

以上基本上是全部网络编程的基本流程，jafka也不例外。在jafka中，类Acceptor具体负责server的实现。该实现比較简单，这里不再做具体的叙述。

须要注意的是，Acceptor接收client的请求后会把其交给Processor类进行处理。用户会在配置文件里配置Processor的个数，Acceptor会议、以round?robin的方式将client连接交给Processor进行处理。