Tomcat 7源码学习笔记

111

前一篇文章写到SocketProcessor的run方法，这次继续说明后续的处理流程。
1.在之前的Http11Protocol构造方法中，创建JIoEndpoint对象以后，接着指定了handler，就是Http11ConnectionHandler对象。
public Http11Protocol() {
endpoint = new JIoEndpoint();
cHandler = new Http11ConnectionHandler(this);
((JIoEndpoint) endpoint).setHandler(cHandler);
setSoLinger(Constants.DEFAULT_CONNECTION_LINGER);
setSoTimeout(Constants.DEFAULT_CONNECTION_TIMEOUT);
setTcpNoDelay(Constants.DEFAULT_TCP_NO_DELAY);
}

2.所以SocketProcessor的run方法中，直接调用了handler.process(socket,status)。这个process方法在Http11ConnectionHandler的父类AbstractConnectionHandler中定义。
3.接着，在process方法中回调Http11ConnectionHandler中的createProcessor()方法，createProcessor()方法会创建一个Http11Processor对象并返回。然后process方法中会继续调用Http11Processor对象的process(SocketWrapper<S> socketWrapper)方法。
4.process(SocketWrapper<S> socketWrapper)方法定义在Http11Processor的父类AbstractHttp11Processor中，从这个process方法开始，才正式进入了对request请求的处理。
5.process方法的大致处理如下
a.从socket中获得inputstream和outputstream,分别设置到Http11Processor类中的InternalInputBuffer和InternalOutputBuffer中
InternalInputBuffer类里面的inputStream成员变量保存从socket中获得的inputstream,父类AbstractInputBuffer中有request成员变量Request request
InternalOutputBuffer类里面的outputStream成员变量保存从socket中获得的outputstream，父类AbstractOutputBuffer中有response成员变量Response response

// Setting up the I/O
setSocketWrapper(socketWrapper);
getInputBuffer().init(socketWrapper, endpoint);
getOutputBuffer().init(socketWrapper, endpoint);

b.调用InternalInputBuffer类的parseRequestLine方法，该方法内部从inputStream里面读取http请求头header信息，进行分析后把header中的信息设置到request中，如：
method,requestURI,protocol。
c.调用prepareRequest方法，对该请求的filter进行设置。
在前面的3.中，构造Http11Processor对象的时候，会调用initializeFilters方法向
InternalInputBuffer和InternalOutputBuffer中添加标准的filter
    /**
* Initialize standard input and output filters.
*/
protected void initializeFilters(int maxTrailerSize) {
// Create and add the identity filters.
getInputBuffer().addFilter(new IdentityInputFilter());
getOutputBuffer().addFilter(new IdentityOutputFilter());
// Create and add the chunked filters.
getInputBuffer().addFilter(new ChunkedInputFilter(maxTrailerSize));
getOutputBuffer().addFilter(new ChunkedOutputFilter());
// Create and add the void filters.
getInputBuffer().addFilter(new VoidInputFilter());
getOutputBuffer().addFilter(new VoidOutputFilter());
// Create and add buffered input filter
getInputBuffer().addFilter(new BufferedInputFilter());
// Create and add the chunked filters.
//getInputBuffer().addFilter(new GzipInputFilter());
getOutputBuffer().addFilter(new GzipOutputFilter());
pluggableFilterIndex = getInputBuffer().getFilters().length;
}

d.prepareRequest方法中调用addInputFilter方法，根据请求header中的transfer-encoding的值来选择要添加的filter。
transfer-encoding：
    identity的时候，不添加filter
    chunked的时候，添加ChunkedInputFilter
    buffered的时候，添加BufferedInputFilter
    void的时候，添加VoidInputFilter
如果header中没有transfer-encoding，那么从header中取content-length,如果content-length >= 0,那么添加IdentityInputFilter。否则，添加VoidInputFilter。
e.调用CoyoteAdapter类中的service(request, response)方法来处理请求。
f.请求处理完以后，调用endRequest()方法结束请求，向客户端返回响应。
getInputBuffer().endRequest();
getOutputBuffer().endRequest();

6.请求处理完以后，当前的请求处理线程结束。2.中的SocketProcessor的run方法结束。
关于e.中的service(request, response)方法的处理细节，下回继续分解。