|
package fvhttpserver;
import java.net.*;
import java.io.*;
public class ClientConnection extends Thread {
public boolean finish = false;
public ClientConnection (Socket s ) {
this.s = s;
}
@Override
public void run() {
try {
char tmp = ' ', tmpp = ' ';
while(true) {
tmp = (char) in.read();
if(tmp == '\r' && tmpp == '\n')
break;
tmpp = tmp;
query += tmp;
}
ProcessQuery.process(query, out, s.getInetAddress().getHostAddress(), this);
s.close();
System. out. println("[" + s. getInetAddress(). getHostAddress() + "]: " + ex );
}
finish = true;
}
}
|
|