C# Socket 模擬http服務器幫助類

0x01 寫在前面

0x02 Http協議

0x03 TCP/IP

0x04 看代碼

0x05 總結

0x01 寫在前面

　　由於工作中，經常需要在服務器之間，或者進程之間進行通信，分配任務等。用Socket操作，太麻煩了，需要建立連接，處理消息。所以

准備創建一個Socket模擬Http服務器的幫助類，來直接通過WebClient進行調用。

0x02 Http協議

我的理解：http協議，其實就是依托於tcp/ip的一個協議，也是可以通過socket發送消息，只是說。發送的內容格式滿足http的條件，就可以被理解成http協議。

常用Http頭。 Http版本也是可以寫成1.1的。

HTTP/1.0 200 OK
Content-Type: text/html
Connection: keep-alive
Content-Encoding: utf-8

0x03 TCP/IP

我的理解：TCP/IP協議其實是某一類協議的大分類了，很多協議都是基於這個協議來傳遞消息的。更詳細的信息，自己搜索一下。

0x04 看代碼

SocketHttpHelper.cs  socket模擬http幫助類

public class SocketHttpHelper
{
    private string ip = "127.0.0.1";
    private int port = 8123;
    private int count = 0;
    private Socket server = null;

    public string DefaultReturn = string.Empty;

    public event Func<string, string, string> Handler = null;

    public SocketHttpHelper()
    {
    }

    public SocketHttpHelper(string ip, int port)
    {
        this.ip = ip;
        this.port = port;
    }

    public void StartListen(int count = 10)
    {
        this.count = count;
        Thread t = new Thread(new ThreadStart(ProcessThread));
        t.IsBackground = true;
        t.Start();
    }

    public void CloseSocket()
    {
        try
        {
            server.Close();
        }
        catch { }
    }

    private void ProcessThread()
    {
        server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
        server.Bind(new System.Net.IPEndPoint(System.Net.IPAddress.Parse(ip), port));
        server.Listen(count);
        while (true)
        {
            try
            {
                Socket client = server.Accept();
                ThreadPool.QueueUserWorkItem(new WaitCallback(ListenExecute), client);
            }
            catch { }
            finally
            {
            }
        }
    }

    private void ListenExecute(object obj)
    {
        Socket client = obj as Socket;
        try
        {
            string ip = (client.RemoteEndPoint as System.Net.IPEndPoint).Address.ToString();
            byte[] buffer = new byte[1024];
            int count = client.Receive(buffer);
            if (count > 0)
            {
                string content = Encoding.UTF8.GetString(buffer, 0, count);

                // 解析 content
                Regex actionRegex = new Regex(@"GET\s+/(?<action>\w+)\?(?<args>[^\s]{0,})");
                string action = actionRegex.Match(content).Groups["action"].Value;
                string args = actionRegex.Match(content).Groups["args"].Value;
                string headStr = @"HTTP/1.0 200 OK
Content-Type: text/html
Connection: keep-alive
Content-Encoding: utf-8

";
                if (Handler != null)
                {
                    try
                    {
                        string result = Handler(action, args);
                        string data = string.Format(headStr + result);
                        client.Send(Encoding.UTF8.GetBytes(data));
                    }
                    catch { }
                    finally
                    {
                    }
                }
                else
                {
                    string data = string.Format(headStr + DefaultReturn);
                    client.Send(Encoding.UTF8.GetBytes(data));
                }
            }
        }
        catch { }
        finally
        {
            try
            {
                client.Shutdown(SocketShutdown.Both);
                client.Close();
                client.Dispose();
            }
            catch { }
        }
    }
}

0x05 總結

由於，每次都要從Socket開始寫，寫多了才發現，原來需要寫一個公用類，點都不費時間。