Jetty 服务器架构分析(中)

wuliws 发表于 2017-2-27 08:30:04

接上一篇，说到XmlConfiguration ,XmlConfiguration 利用自己实现的IOC组装Server的全过程如下图所示：
　　
　　这里可以看到3个关键的配置文件，jetty.xml、jetty-deploy.xml、以及contexts/xxx.xml
　　
l Jetty.xml文件中定义了入口类Server,以及其所需要的线程池、Connector、Handler。
l Jetty-deploy.xml中则定义了部署web应用用到部署工具，在其中指定了部署web应用的两种方式，类似于tomcat, 如果采用webappProvider，则表示将web应用放在webapp下即可生效，如果采用ContextProvider，则需要定义Contexts目录所在位置，只要在该目录下放置任何应用的context配置文件就可以生效。
l Xxx.xml 这是一个用户自定义文件，表示采用ContextProvider时，在其中定义一个WebAppContext的handler,它指定了我们应用所在的位置，便于加载。

XmlConfiguration解析装配完毕之后，就开始启动服务，Jetty的启动是从Server开始的，我们来看一下服务器真正的启动过程。
　　　　

从上图中我们能大概看出服务器启动过程，先是由用户设置好需要的核心组件，然后调用Server.start()开始启动服务，其中会首先启动handler处理器，之后启动用户自定义组件，这个自定义组件需要实现LifeCyle接口，最后才启动Connector接受请求。可以想到，关闭过程恰好是反过来，首先关闭接受请求的connector，然后再关闭用户自定义组件，最后关闭handler.
我们再来详细看一下Server源代码的核心实现过程，当调用start方法时，其实是调用其祖先类AbstractLifeCycle中方法，该方法在这里有一个模板实现，如下：
　　 public final void start() throws Exception{synchronized (_lock){try{if (_state == __STARTED || _state == __STARTING)return;setStarting();doStart();setStarted();}catch (Exception e){setFailed(e);throw e;}catch (Error e){setFailed(e);throw e;}}}
　　　　

　　

[*]Connector启动过程
　　　　
看下Connector的详细启动过程：(以NIO为例)

NIOConnector启动过程中，先创建了多个SelectSet对象，每个SelectSet负责一个NIO的Selector，专门用于监听read事件 (这里利用的多线程Reactor模式，http://gee.cs.oswego.edu/dl/cpjslides/nio.pdf) ，当然这里仅仅是创建了对象，并没有启动，后面会提到。
SelectorManager：

然后再调用open创建了一个blocking的阻塞channel，专门用于接受用户的新连接，我们看下：
public void open() throws IOException{synchronized(this){if (_acceptChannel == null){// Create a new server socket_acceptChannel = ServerSocketChannel.open();// Set to blocking mode_acceptChannel.configureBlocking(true);// Bind the server socket to the local host and port_acceptChannel.socket().setReuseAddress(getReuseAddress());InetSocketAddress addr = getHost()==null?new InetSocketAddress(getPort()):new InetSocketAddress(getHost(),getPort());_acceptChannel.socket().bind(addr,getAcceptQueueSize());_localPort=_acceptChannel.socket().getLocalPort();if (_localPort<=0)throw new IOException("Server channel not bound");}}}

随后从线程池中分配了N个(可以在配置文件中配置)线程用于启动SelectSet监听read事件。

　　synchronized (this){_acceptorThread = new Thread;for (int i = 0; i < _acceptorThread.length; i++)_threadPool.dispatch(new Acceptor(i));if (_threadPool.isLowOnThreads())Log.warn("insufficient threads configured for {}",this);}

最后再分配1个线程用于accept用户的新连接，新连接来之后，会将其设置为nonblocking模式，之后就将其Register给某个SelectSet去监听read事件，然后又返回来继续监听新连接：
_manager.dispatch(new Runnable(){public void run(){final ServerSocketChannel server=_acceptChannel;while (isRunning() && _acceptChannel==server && server.isOpen()){try{SocketChannel channel = server.accept();channel.configureBlocking(false);Socket socket = channel.socket();configure(socket);_manager.register(channel);}catch(IOException e){Log.ignore(e);}}}});

[*]Handler启动过程

　　Jetty将所有的真正处理请求的动作都抽象成了Handler，因此做事情的组件都是实现了这个接口的，包括上图所示的WebAppContext等等，需要做什么样的工作，那么就添加什么样的Handler，这里SessionHandler不是必须的，但是默认是创建好的。ServletHandler主要负责处理web应用的Servlet、Filter等工作，最后将请求直接交给Servlet、Filter都是在这里完成。
这里展示的Handler的启动过程其实是在准备web应用环境，例如解析web应用的web.xml等等工作，做好一切准备工作。

页: [1]

运维网's Archiver

Jetty 服务器架构分析(中)