G
Guest
using System;
using System.Collections;
using System.IO;
using System.Net;
using System.Net.Sockets;
using System.Threading;
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, false);
bs = new BufferedStream(ns);
sr = new StreamReader(bs);
sw = new StreamWriter(bs);
sr.Peek (); <--------------- stuck, or sr.Read (...) stuck too
parseRequest();
readHeaders();
writeURL();
s.Shutdown (SocketShutdown.Both);
s.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;
if(i < tokens.Length - 1) tokens += ":";
}
hashTable[name] = value;
}
}
public void writeURL()
{
try
{
FileStream fs = new FileStream(url.Length <= 1 ? "index.html" :
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);
}
bs.Flush ();
bs2.Close();
}
catch(FileNotFoundException)
{
writeFailure();
sw.WriteLine("File not found: " + url);
}
}
public void writeSuccess()
{
sw.WriteLine("HTTP/1.0 200 OK");
sw.WriteLine("Connection: close");
sw.WriteLine();
sw.Flush();
}
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.Stream, ProtocolType.Tcp);
listener.Bind (new IPEndPoint(IPAddress.Any, port));
listener.Blocking = true;
listener.Listen((int) SocketOptionName.MaxConnections);
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 (Int32.Parse (args[0]));
else
httpServer = new HttpServer();
Thread thread = new Thread(new ThreadStart(httpServer.listen));
thread.Start();
return 0;
}
}
-----------
NetworkStream ns = new NetworkStream(s, FileAccess.ReadWrite, false);
bs = new BufferedStream(ns);
sr = new StreamReader(bs);
sw = new StreamWriter(bs);
sr.Read (...) call gets blocked?! so does sr.Peek () ?!!!!!!
sw.Write (...) is okay
----
NetworkStream ns = new NetworkStream(s, FileAccess.ReadWrite, false);
bs = new BufferedStream(ns);
sr = new StreamReader(ns); <---- notice: ns not bs
sw = new StreamWriter(bs);
sr.Peek and Read now okay
using System.Collections;
using System.IO;
using System.Net;
using System.Net.Sockets;
using System.Threading;
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, false);
bs = new BufferedStream(ns);
sr = new StreamReader(bs);
sw = new StreamWriter(bs);
sr.Peek (); <--------------- stuck, or sr.Read (...) stuck too
parseRequest();
readHeaders();
writeURL();
s.Shutdown (SocketShutdown.Both);
s.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;
if(i < tokens.Length - 1) tokens += ":";
}
hashTable[name] = value;
}
}
public void writeURL()
{
try
{
FileStream fs = new FileStream(url.Length <= 1 ? "index.html" :
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);
}
bs.Flush ();
bs2.Close();
}
catch(FileNotFoundException)
{
writeFailure();
sw.WriteLine("File not found: " + url);
}
}
public void writeSuccess()
{
sw.WriteLine("HTTP/1.0 200 OK");
sw.WriteLine("Connection: close");
sw.WriteLine();
sw.Flush();
}
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.Stream, ProtocolType.Tcp);
listener.Bind (new IPEndPoint(IPAddress.Any, port));
listener.Blocking = true;
listener.Listen((int) SocketOptionName.MaxConnections);
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 (Int32.Parse (args[0]));
else
httpServer = new HttpServer();
Thread thread = new Thread(new ThreadStart(httpServer.listen));
thread.Start();
return 0;
}
}
-----------
NetworkStream ns = new NetworkStream(s, FileAccess.ReadWrite, false);
bs = new BufferedStream(ns);
sr = new StreamReader(bs);
sw = new StreamWriter(bs);
sr.Read (...) call gets blocked?! so does sr.Peek () ?!!!!!!
sw.Write (...) is okay
----
NetworkStream ns = new NetworkStream(s, FileAccess.ReadWrite, false);
bs = new BufferedStream(ns);
sr = new StreamReader(ns); <---- notice: ns not bs
sw = new StreamWriter(bs);
sr.Peek and Read now okay