Tomcat 七源码学习笔记 - 1 (socket多线程)
Tomcat 7源码学习笔记 - 1 (socket多线程)tomcat说白了就是一个socket服务线程,监听8080端口,一旦有连接过
Tomcat 7源码学习笔记 - 1 (socket多线程)
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[i], 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方法中,继续进行后续的处理。 预知后续处理如何,请见下回分解。