前言

公司实习分配给的任务是精简和优化 Jetty 框架，这里做简单的思路记录（比较乱），源码是 Jetty 7.x.x 。

大体流程

Connector 接口的实现类 SelectChannelConnector （后称连接器）会创建利用线程池调度Accpetor（接收器），每个线程对应一个接收器，接收器的 run() 方法会调用连接器的 accpet() 方法阻塞等待客户端连接。

注意： 一个连接器只创建一个 ServerSocketChannel ，因此只能监听一个端口。

当有客户端连接过来时，会在 SelectorManager （选择器管理者）中注册该 SocketChannel （socket通道）。

SocketChannel channel = server.accept(); // block and wait for client
channel.configureBlocking(false);
// ... ...
_manager.register(channel); // register the channel

SelectManager 的 register() 会将 socket 通道存储在 _selectSets 中， 层次结构如下的 _selectSets 是一个类似 HashMap 的存储结构。

SelectSet[] _selectSets;  // SelectSet._changes
ConcurrentLinkedQueue<Object> _changes;

SelectManager 的工作原理是为 _selectSets 的每个元素创建一个线程，并且循环调用 SelectSet 的 doSelect() 方法。

doSelect() 方法从 _changes 取出一个对象，判断不同的对象进行不同的操作其中包含了通道注册到选择器的操作，然后调用 Selector 的 Select 方法并获取 SelectionKey 集合，根据不同的附加来处理不同的SelectChannelEndPoint 的 schedule()。

版权声明：本文为linzhehuang原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
本文链接：https://www.cnblogs.com/linzhehuang/p/11190290.html