Tomcat 7源码学习笔记

xiaowei8782088

tomcat说白了就是一个socket服务线程，监听8080端口，一旦有连接过来就生成一个socket来对应，然后把socket扔给后端的Executor线程池，由线程池中的一个线程负责进行后续的处理，而ServerSocket线程继续监听等待下一个连接的到来。
0.由Http11Protocol类的构造函数Http11Protocol()构造出JIoEndpoint对象
endpoint = new JIoEndpoint();

1.调用JIoEndpoint的bind()方法，创建一个ServerSocket对象
serverSocket = serverSocketFactory.createSocket(getPort(),
getBacklog());

2.调用JIoEndpoint类的startInternal()方法，startInternal()中调用父类AbstractEndpoint中的startAcceptorThreads()方法
3.startAcceptorThreads()方法中，回调JIoEndpoint类中的createAcceptor()方法，来取得一个Acceptor对象(Acceptor类实现了Runnable接口，并实现了run方法),然后创建一个线程，并启动。
Thread t = new Thread(acceptors, getName() + "-Acceptor-" + i);
t.start();

4.线程启动后回自动调用Acceptor中实现的run方法，run方法中调用serverSocket的accept方法，等待接入客户端发起的连接,有连接接入后，调用processSocket(socket)来处理请求。processSocket方法里面会把socket扔给Executor线程池里面的一个线程，所以processSocket(socket)会很快返回，接着进行下一次while循环，继续等待下一个连接的接入。
public void run() {
while (running) {
socket = serverSocketFactory.acceptSocket(serverSocket);
if (!processSocket(socket)) {
countDownConnection();
// Close socket right away
closeSocket(socket);
}
}
}

5.processSocket方法里面会用传入的socket创建一个SocketWrapper对象，然后再用SocketWrapper对象创建一个SocketProcessor对象，SocketProcessor类实现了Runnable接口并且实现了run方法。接着调用StandardThreadExecutor类的execute方法。
protected boolean processSocket(Socket socket) {
SocketWrapper wrapper = new SocketWrapper(socket);
getExecutor().execute(new SocketProcessor(wrapper));
return true;
}

6.StandardThreadExecutor类里面维护了一个ThreadPoolExecutor线程池，execute方法里面会把SocketProcessor线程对象传给线程池中的一个线程Thread，并启动该线程，start以后会自动回调SocketProcessor中的run方法。
7.SocketProcessor的run方法中，继续进行后续的处理。
预知后续处理如何，请见下回分解。