Tomcat的HttpConnector/HttpProcesser（tomcat源码学习）

alibabamama

先启动进程HttpProcesser，等请求到达后加入socket对象并执行process().tomcat5.5以及后续版本已经没有看到HttpProcesser对象了
package com.xly;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
public class HttpConnecter {
public static void main(String... args){
try {
Socket sk=null;
HttpConnecter hc=new HttpConnecter();
HttpProcesser hp=new HttpProcesser(hc,sk);
hp.start();
ServerSocket socketserver=new ServerSocket(8888,60000);
sk=socketserver.accept();
hp.assign(sk);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}

package com.xly;
import java.net.Socket;
public class HttpProcesser extends Thread{
public boolean available = false;
public boolean stopped = false;
public Socket socket;
public HttpConnecter httpconnecter;
public HttpProcesser(HttpConnecter httpconnecter,Socket socket) {
this.available = false;
this.socket=socket;
this.httpconnecter=httpconnecter;
}
public void setAvailable(boolean available){
this.available=available;
}
private synchronized Socket await() {
// Wait for the Connector to provide a new Socket
while (!available) {
try {
wait();
} catch (InterruptedException e) {
}
}
// Notify the Connector that we have received this Socket
Socket socket = this.socket;
available = false;
notifyAll();
if ((socket != null))
System.out.println("The incoming request has been awaited");
return (socket);
}
synchronized void assign(Socket socket) {
// Wait for the Processor to get the previous Socket
while (available) {
try {
wait();
} catch (InterruptedException e) {
}
}
// Store the newly available Socket and notify our thread
this.socket = socket;
available = true;
notifyAll();
if ((socket != null))
System.out.println("An incoming request is being assigned");
}
public void process(Socket sockets)
{
System.out.println("process.run");
}
public void run() {
// Process requests until we receive a shutdown signal
while (!stopped) {
System.out.println("Thread Run");
// Wait for the next socket to be assigned
Socket socket = await();
if (socket == null)
continue;
// Process the request from this socket
try {
process(socket);
} catch (Throwable t) {
System.out.print("process.invoke");
}
// Finish up this request
//connector.recycle(this);
}
// Tell threadStop() we have shut ourselves down successfully
}

}