首页 诗词 字典 板报 句子 名言 友答 励志 学校 网站地图
当前位置: 首页 > 教程频道 > 软件管理 > 软件架构设计 >

Tomcat 七源码学习笔记 - 1 (socket多线程)

2012-11-14 
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方法中,继续进行后续的处理。

预知后续处理如何,请见下回分解。

热点排行