📄 使用c#开发自己的web服务器 .txt
字号:
sBuffer = sBuffer + "Accept-Ranges: bytes\r\n";
sBuffer = sBuffer + "Content-Length: " + iTotBytes + "\r\n\r\n";
Byte[] bSendData = Encoding.ASCII.GetBytes(sBuffer);
SendToBrowser( bSendData, ref mySocket);
Console.WriteLine("Total Bytes : " + iTotBytes.ToString());
}
SendToBrowser函数向浏览器发送信息,这是一个工作量比较大的函数。
public void SendToBrowser(String sData, ref Socket mySocket)
{
SendToBrowser (Encoding.ASCII.GetBytes(sData), ref mySocket);
}
public void SendToBrowser(Byte[] bSendData, ref Socket mySocket)
{
int numBytes = 0;
try
{
if (mySocket.Connected)
{
if (( numBytes = mySocket.Send(bSendData, bSendData.Length,0)) == -1)
Console.WriteLine("Socket Error cannot Send Packet");
else
{
Console.WriteLine("No. of bytes send {0}" , numBytes);
}
}
else
Console.WriteLine("Connection Dropped....");
}
catch (Exception e)
{
Console.WriteLine("Error Occurred : {0} ", e );
}
}
我们已经有了编写一个互联网服务器应用程序的一些部件,下面我们将讨论互联网服务器应用程序中的关健函数。
public void StartListen()
{
int iStartPos = 0;
String sRequest;
String sDirName;
String sRequestedFile;
String sErrorMessage;
String sLocalDir;
String sMyWebServerRoot = "C:\\MyWebServerRoot\\";
String sPhysicalFilePath = "";
String sFormattedMessage = "";
String sResponse = "";
while(true)
{
//接受一个新的连接
Socket mySocket = myListener.AcceptSocket() ;
Console.WriteLine ("Socket Type " +mySocket.SocketType );
if(mySocket.Connected)
{
Console.WriteLine("\nClient Connected!!\n==================\n
CLient IP {0}\n", mySocket.RemoteEndPoint) ;
//生成一个字节数组,从客户端接收数据
Byte[] bReceive = new Byte[1024] ;
int i = mySocket.Receive(bReceive,bReceive.Length,0) ;
//将字节型数据转换为字符串
string sBuffer = Encoding.ASCII.GetString(bReceive);
//上前我们将只处理GET类型
if (sBuffer.Substring(0,3) != "GET" )
{
Console.WriteLine("Only Get Method is supported..");
mySocket.Close();
return;
}
// 查找HTTP请求
iStartPos = sBuffer.IndexOf("HTTP",1);
// 获取“HTTP”文本和版本号,例如,它会返回“HTTP/1.1”
string sHttpVersion = sBuffer.Substring(iStartPos,8);
//解析请求的类型和目录/文件
sRequest = sBuffer.Substring(0,iStartPos - 1);
//如果存在\符号,则使用/替换
sRequest.Replace("\\","/");
//如果提供的文件名中没有/,表明这是一个目录,我们解危需要查找缺省的文件名
if ((sRequest.IndexOf(".") <1) && (!sRequest.EndsWith("/")))
{
sRequest = sRequest + "/";
}
//解析请求的文件名
iStartPos = sRequest.LastIndexOf("/") + 1;
sRequestedFile = sRequest.Substring(iStartPos);
//解析目录名
sDirName = sRequest.Substring(sRequest.IndexOf("/"), sRequest.LastIndexOf("/")-3);
上面的代码无须多加解释,它接收用户的请求,将用户的请求由字节型数据转换为字符串型数据,然后查找请求的类型,解析HTTP的版本号、文件和目录信息。
// 确定物理目录
if ( sDirName == "/")
sLocalDir = sMyWebServerRoot;
else
{
//获得虚拟目录
sLocalDir = GetLocalPath(sMyWebServerRoot, sDirName);
}
Console.WriteLine("Directory Requested : " + sLocalDir);
//如果物理目录不存在,则显示出错信息
if (sLocalDir.Length == 0 )
{
sErrorMessage = "〈H2〉Error!! Requested Directory does not exists〈/H2〉〈Br〉";
//sErrorMessage = sErrorMessage + "Please check data\\Vdirs.Dat";
//对信息进行格式化
SendHeader(sHttpVersion, "", sErrorMessage.Length, " 404 Not Found", ref mySocket);
//向浏览器发送信息
SendToBrowser(sErrorMessage, ref mySocket);
mySocket.Close();
continue;
}
提示:微软的IE浏览器一般情况下总会显示一个比较“友好”一点的HTTP错误网页,如果要显示我们的Web服务器应用程序的错误信息,需要禁用IE中“显示友好HTTP错误信息”的功能,方法是依次点击“工具”->“互联网工具”,然后在其中的“高级”标签中即可以看到该选项。
如果用户没有提供目录名,Web服务器应用程序会使用GetLocalPath函数获取物理目录的信息,如果目录不存在(或者没有映射为Vdir.Dat中的条目),就会向浏览器发送错误信息。接下来Web服务器应用程序会确定文件名,如果用户没有提供文件名,Web服务器应用程序可以调用GetTheDefaultFileName函数获取文件名,如果有错误发生,则会将错误信息发送到浏览器。
//如果文件名不存在,则查找缺省文件列表
if (sRequestedFile.Length == 0 )
{
// 获取缺省的文件名
sRequestedFile = GetTheDefaultFileName(sLocalDir);
if (sRequestedFile == "")
{
sErrorMessage = "〈H2〉Error!! No Default File Name Specified〈/H2〉";
SendHeader(sHttpVersion, "", sErrorMessage.Length, " 404 Not Found",
ref mySocket);
SendToBrowser ( sErrorMessage, ref mySocket);
mySocket.Close();
return;
}
}
下面我们来识别Mime类型:
String sMimeType = GetMimeType(sRequestedFile);
//构建物理路径
sPhysicalFilePath = sLocalDir + sRequestedFile;
Console.WriteLine("File Requested : " + sPhysicalFilePath);
最后一个步骤是打开被请求的文件,并将它发送给浏览器。
if (File.Exists(sPhysicalFilePath) == false)
{
sErrorMessage = "〈H2〉404 Error! File Does Not Exists...〈/H2〉";
SendHeader(sHttpVersion, "", sErrorMessage.Length, " 404 Not Found", ref mySocket);
SendToBrowser( sErrorMessage, ref mySocket);
Console.WriteLine(sFormattedMessage);
}
else
{
int iTotBytes=0;
sResponse ="";
FileStream fs = new FileStream(sPhysicalFilePath, FileMode.Open,FileAccess.Read,
FileShare.Read);
// 创建一个能够从FileStream中读取字节数据的reader
BinaryReader reader = new BinaryReader(fs);
byte[] bytes = new byte[fs.Length];
int read;
while((read = reader.Read(bytes, 0, bytes.Length)) != 0)
{
// 从文件中读取数据,并将数据发送到网络上
sResponse = sResponse + Encoding.ASCII.GetString(bytes,0,read);
iTotBytes = iTotBytes + read;
}
reader.Close();
fs.Close();
SendHeader(sHttpVersion, sMimeType, iTotBytes, " 200 OK", ref mySocket);
SendToBrowser(bytes, ref mySocket);
//mySocket.Send(bytes, bytes.Length,0);
}
mySocket.Close();
}
}
}
}
}
编译和执行
可以使用下图所示的命令编译我们的Web服务器应用程序:
在我使用的.NET开发工具中,无须指定任何库的名字,在较老版本的.NET开发工具中,可能会需要使用/r参数添加对dll库文件的引用。
要运行该Web服务器应用程序,只要如下图那样输入程序的名字,并按回车键即可。
Now, let say user send the request, our web server will identify the default file name and sends to the browser.
现在,我们假设用户发送了请求,我们的Web服务器应用程序将会决定使用缺省的文件,并将它返回给浏览器。如下图所示:
当然了,用户也可以请求图像文件
可能的改进
WebServer仍然有许多地方可以加以改进。它不支持嵌入式图像和脚本,读者可以自己编写ISAPI过滤器,也可以使用IIS ISAPI过滤器。
结束语
本篇文章展示了开发Web服务器的基本原理,我们仍然可以对文章中的Web服务器应用程序进行许多改进,希望它能够起到抛砖引玉的作用,对读者有所启迪。
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -