谈谈jetty8 的io模型

几个重要的概念

• Connector: jetty网络接口的封装，用于监听网络连接
• SelectorManager：底层selector封装，管理网络事件，主要是向底层selector注册感兴趣的网络事件，并从selector中轮询出准备好的事件
• EndPoint：socket的封装，用于底层网络的读写,一旦网络读写准备好，会调用相应的connection的handle方法
• Connection:请求的抽象，比如解析请求的http协议，并调用servlet 容器，依赖EndPoint
  

见图

几个重要的线程

1) Acceptor线程

• task：org.eclipse.jetty.server.AbstractConnector.Acceptor
• 数量设定：setAcceptors(Math.max(1,(Runtime.getRuntime().availableProcessors()+3)/4));见SelectChannelConnector构造函数
• 触发时机：见SelectChannelConnector(AbstractConnector).doStart()
• 执行线程：QueuedThreadPool中的线程
• 执行逻辑
• 轮询SelectChannelConnector.accept(int acceptorID)
• 以阻塞的方式获取连接请求
• 一旦获得连接，调用ConnectorSelectorManager.register(SocketChannel channel)
• 向SelectorManager$SelectSet 内部的_changes队列中添加该事件（有新的连接）
• 唤醒selector

2）Selector 线程

• task：匿名内部类(newRunnable(){......})
• 数量设定：在jetty.xml中配置
  
• 触发时机：见SelectChannelConnector$ConnectorSelectorManager(SelectorManager).doStart()
  
• 执行线程：QueuedThreadPool中的线程
• 执行逻辑
• 轮询SelectorManager$SelectSet.doSelect()
• 从_changes队列获取感兴趣的事件
• 如果是EndPoint类型（读写事件）
• 如果已在selector中注册过，则更新selection key, 否则向selector注册
• 如果是ChannelAndAttachment类型
• 如果关联的SocketChannel已连接，则向selector注册读事件
• 否则注册连接事件
• 如果是SocketChannel类型(连接事件)
• 则向selector注册读事件//key = channel.register(selector,SelectionKey.OP_READ,null);
• 实例化SelectChannelEndPoint //createEndPoint(channel,key);
  
• 调用SelectChannelEndPoint.schedule()
• 调用SelectChannelConnector$ConnectorSelectorManager.dispatch(Runnable task)将请求扔给QueuedThreadPool(存放在内部jobs队列)
• 如果是ChangeTask类型
• 直接执行
• 如果是Runnable
• 直接丢给QueuedThreadPool
• 运行selector.select获取准备好的SelectionKey，遍历SelectionKey
• 如果key无效则去更新
• 如果有事件发生则调用SelectChannelEndPoint.schedule()
• 调用selector.selectedKeys().clear()

3)Worker线程

• task:匿名内部类(newRunnable(){......})
• 数量设定：在jetty.xml中配置
  
• 触发时机:QueuedThreadPool.startThread
  
• 执行线程：QueuedThreadPool中的线程
  
• 执行逻辑:
  
• 轮询从jobs队列取job（通常是SelectChannelEndPoint的匿名内部类(newRunnable(){......})）
• 然后执行job.run(通常是SelectChannelEndPoint.handle())
• 调用SelectChannelConnector$SelectChannelHttpConnection(AsyncHttpConnection).handle()
• HttpParser.parseAvailable()(不断调用parseNext读取请求的内容)处理请求
• flush内容
• 如果过程中存在写阻塞，会调用SelectChannelEndPoint.scheduleWrite()或者直接调用updateKey()往_changes队列中添加写事件

线程关系见图

小结(请求处理流程)

• Acceptor线程负责监听连接，一但有连接过来，写入changes队列
• Selector轮询changes队列，将队列中的感兴趣事件往selector中注册，并从selector中查出准备好的网络事件，一旦有准备好的网络事件，通过调用endpoint.schedule()将task丢入线程池的jobs队列
• Work线程会从jobs队列取出任务，然后执行
• 上面的3组线程全来自QueuedThreadPool中的线程