學(xué)習(xí)C#時(shí)，經(jīng)常會(huì)遇到Web服務(wù)器功能的程序設(shè)計(jì)問題，這里將介紹C#實(shí)現(xiàn)Web服務(wù)器功能的程序設(shè)計(jì)問題的解決方法。

C#實(shí)現(xiàn)Web服務(wù)器功能的程序設(shè)計(jì)

根據(jù)HTTP協(xié)議的作用原理，實(shí)現(xiàn)GET請(qǐng)求的Web服務(wù)器程序的方法如下：

創(chuàng)建TcpListener類對(duì)象，監(jiān)聽某端口（任意輸入閑置端口 如：8080 ）。等待、接受客戶機(jī)連接到該端口，得到與客戶機(jī)連接的socket;從與socket關(guān)聯(lián)的輸入流中讀取一行客戶機(jī)提交的請(qǐng)求信息，請(qǐng)求信息的格式 為：GET 路徑/文件名 HTTP/1.0。從請(qǐng)求信息中獲取請(qǐng)求類型。如果請(qǐng)求類型是GET，則從請(qǐng)求信息中獲取所訪問的HTML文件名。沒有HTML文件名時(shí)，則以 index.html作為文件名；

如果HTML文件存在，則打開HTML文件，把HTTP頭信息和HTML文件內(nèi)容通過socket傳回給Web瀏覽器，然后關(guān)閉文件。否則發(fā)送錯(cuò)誤信息給Web瀏覽器；關(guān)閉與相應(yīng)Web瀏覽器連接的socket字。

C#實(shí)現(xiàn)Web服務(wù)器功能的代碼如下：

    using System;  
    using System.IO;  
    using System.Net;  
    using System.Net.Sockets;  
    using System.Text;  
    using System.Threading ;  
     
    class MyWebServer  
    {  
     
    private TcpListener myListener ;  
    private int port = 8080 ; // 選者任何閑置端口  
     
    //開始兼聽端口  
    //同時(shí)啟動(dòng)一個(gè)兼聽進(jìn)程  
    public MyWebServer()  
    {  
    try  
    {  
    //開始兼聽端口  
    myListener = new TcpListener(port) ;  
    myListener.Start();  
    Console.WriteLine("Web Server Running... Press ^C to Stop...");  
    //同時(shí)啟動(dòng)一個(gè)兼聽進(jìn)程 ''StartListen''  
    Thread th = new Thread(new ThreadStart(StartListen));  
    th.Start() ;  
     
    }  
    catch(Exception e)  
    {  
    Console.WriteLine("兼聽端口時(shí)發(fā)生錯(cuò)誤 :" +e.ToString());  
    }  
    }  
    public void SendHeader(string sHttpVersion, string sMIMEHeader, 
    int iTotBytes, string sStatusCode, ref Socket mySocket)  
    {  
     
    String sBuffer = "";  
     
    if (sMIMEHeader.Length == 0 )  
    {  
    sMIMEHeader = "text/html"; // 默認(rèn) text/html  
    }  
     
    sBuffersBuffer = sBuffer + sHttpVersion + sStatusCode + "\r\n";  
    sBuffersBuffer = sBuffer + "Server: cx1193719-b\r\n";  
    sBuffersBuffer = sBuffer + "Content-Type: " + sMIMEHeader + "\r\n";  
    sBuffersBuffer = sBuffer + "Accept-Ranges: bytes\r\n";  
    sBuffersBuffer = sBuffer + "Content-Length: " + iTotBytes + "\r\n\r\n";  
     
    Byte[] bSendData = Encoding.ASCII.GetBytes(sBuffer);  
     
    SendToBrowser( bSendData, ref mySocket);  
     
    Console.WriteLine("Total Bytes : " + iTotBytes.ToString());  
     
    }  
     
    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("連接失敗....");  
    }  
    catch (Exception e)  
    {  
    Console.WriteLine("發(fā)生錯(cuò)誤 : {0} ", e );  
     
    }  
    }  
    public static void Main()  
    {  
    MyWebServer MWS = new MyWebServer();  
    }  
    public void StartListen()  
    {  
     
    int iStartPos = 0;  
    String sRequest;  
    String sDirName;  
    String sRequestedFile;  
    String sErrorMessage;  
    String sLocalDir;  
     
    String sMyWebServerRoot = "E:\\MyWebServerRoot\\"; //設(shè)置你的虛擬目錄  
     
    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=\nCLient IP {0}\n",mySocket.RemoteEndPoint) ;  
     
    Byte[] bReceive = new Byte[1024] ;  
    int i = mySocket.Receive(bReceive,bReceive.Length,0) ;  
     
    //轉(zhuǎn)換成字符串類型  
    string sBuffer = Encoding.ASCII.GetString(bReceive);  
     
     
    //只處理"get"請(qǐng)求類型  
    if (sBuffer.Substring(0,3) != "GET" )  
    {  
    Console.WriteLine("只處理get請(qǐng)求類型..");  
    mySocket.Close();  
    return;  
    }  
     
    // 查找 "HTTP" 的位置  
    iStartPos = sBuffer.IndexOf("HTTP",1);  
     
    string sHttpVersion = sBuffer.Substring(iStartPos,8);  
     
    // 得到請(qǐng)求類型和文件目錄文件名  
    sRequest = sBuffer.Substring(0,iStartPos - 1);  
     
    sRequest.Replace("\\","/");  
     
    //如果結(jié)尾不是文件名也不是以"/"結(jié)尾則加"/"  
    if ((sRequest.IndexOf(".") <1) && (!sRequest.EndsWith("/")))  
    {  
    sRequestsRequest = sRequest + "/";  
    }  
     
    //得帶請(qǐng)求文件名  
    iStartPos = sRequest.LastIndexOf("/") + 1;  
    sRequestsRequestedFile = sRequest.Substring(iStartPos);  
     
    //得到請(qǐng)求文件目錄  
    sDirName = sRequest.Substring(sRequest.IndexOf("/"), sRequest.LastIndexOf("/")-3);  
     
    //獲取虛擬目錄物理路徑  
    sLocalDir = sMyWebServerRoot;  
     
    Console.WriteLine("請(qǐng)求文件目錄 : " + sLocalDir);  
     
    if (sLocalDir.Length == 0 )  
    {  
    sErrorMessage = "<H2>Error!! Requested Directory does not exists</H2><Br>";  
    SendHeader(sHttpVersion, "", sErrorMessage.Length, " 404 Not Found", ref mySocket);  
    SendToBrowser(sErrorMessage, ref mySocket);  
    mySocket.Close();  
    continue;  
    }  
     
    if (sRequestedFile.Length == 0 )  
    {  
    // 取得請(qǐng)求文件名  
    sRequestedFile = "index.html";  
    }  
     
     
    String sMimeType = "text/html";  
     
    sPhysicalFilePath = sLocalDir + sRequestedFile;  
    Console.WriteLine("請(qǐng)求文件: " + 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);  
     
    BinaryReader reader = new BinaryReader(fs);  
    byte[] bytes = new byte[fs.Length];  
    int read;  
    while((read = reader.Read(bytes, 0, bytes.Length)) != 0)  
    {  
    sResponsesResponse = sResponse + Encoding.ASCII.GetString(bytes,0,read);  
     
    iTotBytesiTotBytes = 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();  
    }  
    }  
    }  
    }  
    } 

標(biāo)簽： web服務(wù)器 代碼 服務(wù)器 服務(wù)器功能

版權(quán)申明：本站文章部分自網(wǎng)絡(luò)，如有侵權(quán)，請(qǐng)聯(lián)系：west999com@outlook.com
特別注意：本站所有轉(zhuǎn)載文章言論不代表本站觀點(diǎn)！
本站所提供的圖片等素材，版權(quán)歸原作者所有，如需使用，請(qǐng)與原作者聯(lián)系。