who am i ... i'm back.
分类: C/C++
2010-07-05 21:31:25
class HttpProcessor {
private Socket s;
private BufferedStream bs;
private StreamReader sr;
private StreamWriter sw;
private
String method;
private String url;
private String protocol;
private Hashtable hashTable;
public
HttpProcessor(Socket s) {
this.s = s;
hashTable = new
Hashtable();
}
public void
process() {
NetworkStream ns = new NetworkStream(s,
FileAccess.ReadWrite);
bs = new BufferedStream(ns);
sr =
new StreamReader(bs);
sw = new StreamWriter(bs);
parseRequest();
readHeaders();
writeURL();
s.Shutdown(SocketShutdown.SdBoth);
ns.Close();
}
public void parseRequest() {
String request =
sr.ReadLine();
string[] tokens = request.Split(new char[]{' '});
method = tokens[0];
url = tokens[1];
protocol =
tokens[2];
}
public void
readHeaders() {
String line;
while((line = sr.ReadLine())
!= null && line != "") {
string[] tokens =
line.Split(new char[]{':'});
String name = tokens[0];
String value = "";
for(int i = 1; i < tokens.Length; i++) {
value += tokens[i];
if(i < tokens.Length - 1) tokens[i]
+= ":";
}
hashTable[name] = value;
}
}
public void writeURL() {
try {
FileStream fs = new FileStream(url.Substring(1), FileMode.Open,
FileAccess.Read);
writeSuccess();
BufferedStream bs2 =
new BufferedStream(fs);
byte[] bytes = new byte[4096];
int read;
while((read = bs2.Read(bytes, 0, bytes.Length)) !=
0) {
bs.Write(bytes, 0, read);
}
bs2.Close();
} catch(FileNotFoundException) {
writeFailure();
sw.WriteLine("File not found: " + url);
}
sw.Flush();
}
public void
writeSuccess() {
sw.WriteLine("HTTP/1.0 200 OK");
sw.WriteLine("Connection: close");
sw.WriteLine();
}
public void writeFailure() {
sw.WriteLine("HTTP/1.0 404 File not found");
sw.WriteLine("Connection: close");
sw.WriteLine();
}
}
public class HttpServer {
//
============================================================
//
Data
protected int port;
//
============================================================
//
Constructor
public HttpServer() :
this(80) {
}
public
HttpServer(int port) {
this.port = port;
}
//
============================================================
//
Listener
public void listen() {
Socket listener = new Socket(0, SocketType.SockStream,
ProtocolType.ProtTCP);
IPAddress ipaddress = new
IPAddress("127.0.0.1");
IPEndPoint endpoint = new
IPEndPoint(ipaddress, port);
listener.Bind(endpoint);
listener.Blocking = true;
listener.Listen(-1);
while(true)
{
Socket s = listener.Accept();
HttpProcessor
processor = new HttpProcessor(s);
Thread thread = new
Thread(new ThreadStart(processor.process));
thread.Start();
}
}
//
============================================================
//
Main
public static int Main(String[]
args) {
HttpServer httpServer;
if(args.GetLength(0) >
0) {
httpServer = new HttpServer(args[0].ToUInt16());
}
else {
httpServer = new HttpServer();
}
Thread
thread = new Thread(new ThreadStart(httpServer.listen));
thread.Start();
return 0;
}
}