C#上位機之—WinForm實現Socket異步通訊示例

工作中常用到的一些知識點，總是用完就忘，第一次嘗試用博客記錄下來，以備后用；

Socket通訊，Socket（套接字）是基於TCP/IP通訊方式的封裝好的類，調用時需要添加下面的服務引用：

.......
using System.Net;
using System.Net.Sockets;

窗體頁面搭建，上面為服務器區，下面為客戶端區：

建立兩個類，一個表示服務器，一個表示客戶端，

首先建立服務器類：

1.聲明變量：IP地址，端口號，EndPoint，Socket類，數據Buffer等

        string ip;//IP地址
        string port;//端口號
        IPEndPoint endPoint;//網絡端點
        Socket socServer;//偵聽連接套接字
        Socket socClient;//通訊套接字
        byte[] dataReceived = new byte[50000];

        public delegate void delegateDisplayMsg(string type,string msg);
        public delegateDisplayMsg OnDisplay;

        public SocketServer()
        {
            socServer = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
        }

 

2.偵聽連接函數：

       public void StartListen(string ip,string port)
       {
            this.ip = ip;
            this.port = port;
            endPoint = new IPEndPoint(IPAddress.Parse(this.ip), int.Parse(port));
            socServer.Bind(endPoint);
            socServer.Listen(0);
            socServer.BeginAccept(new AsyncCallback(OnClientConnect), null);
            ShowMsg("Wait Connect");
        }

3.接受數據函數：

public void OnClientConnect(IAsyncResult asyn)
        {
            socClient = socServer.EndAccept(asyn);
            WaitForData();
            ShowMsg("Client Connected  " + socClient.RemoteEndPoint.ToString());
        }
        public void WaitForData()
        {
            if (socClient != null)
                socClient.BeginReceive(dataReceived, 0, dataReceived.Length, SocketFlags.None, new AsyncCallback(OnDataReceived), null);
        }
        public void OnDataReceived(IAsyncResult asyn)
        {
            int dataLength = socClient.EndReceive(asyn);
            byte[] chars = new byte[dataLength];
            Buffer.BlockCopy(dataReceived, 0, chars, 0, dataLength);
            string msg = Encoding.ASCII.GetString(chars);
            ShowMsg("<=" + msg);
            WaitForData();
        }

4.發送數據函數：

        public void SendMsg(string msg)
        {
            byte[] data = Encoding.Default.GetBytes(msg);
            socClient.Send(data);
            ShowMsg("=>" + msg);
        }

然后建立客戶端類：

1.聲明變量

        string ip;//IP地址
        string port;//端口號
        IPEndPoint endPoint;//網絡端點
        Socket socClient;//通訊套接字
        byte[] dataReceived = new byte[50000];//數據Buffer

        public delegate void delegateDisplayMsg(string type,string msg);
        public delegateDisplayMsg OnDisplay;

        public SocketClient()
        {
            socClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
        }

2.連接服務器函數：

        public void Connect(string ip, string port)
        {
            this.ip = ip;
            this.port = port;
            endPoint = new IPEndPoint(IPAddress.Parse(this.ip), int.Parse(port));
            socClient.BeginConnect(endPoint, new AsyncCallback(OnToConnected), null);
        }

3.接受數據函數：

        public void OnToConnected(IAsyncResult asyn)
        {
            socClient.EndConnect(asyn);
            WaitForData();
            ShowMsg("Connect Success");
        }
        public void WaitForData()
        {
            if (socClient != null)
                socClient.BeginReceive(dataReceived, 0, dataReceived.Length, SocketFlags.None, new AsyncCallback(OnDataReceived), null);
        }
        public void OnDataReceived(IAsyncResult asyn)
        {
            int dataLenth = socClient.EndReceive(asyn);
            byte[] chars = new byte[dataLenth];
            Buffer.BlockCopy(dataReceived, 0, chars, 0, dataLenth);
            string msg = Encoding.ASCII.GetString(chars);
            ShowMsg("<=" + msg);
            WaitForData();
        }

4.發送數據函數：

        public void SendMsg(string msg)
        {
            byte[] data = Encoding.Default.GetBytes(msg);
            socClient.Send(data);
            ShowMsg("=>" + msg);
        }

服務器類與客戶端類，已經建立完成，下面對兩個類進行實例化，並Link窗體控件的事件函數，如下：

1.實例化：

public void Init()
{
     Server = new SocketServer();
     Client = new SocketClient();
     Server.OnDisplay += ShowMsg;
     Client.OnDisplay += ShowMsg;
}

2.按鈕點擊事件：

        private void btn_StartListen_Click(object sender, EventArgs e)
        {
            Server.StartListen(txt_serverIP.Text.ToString(), txt_serverPort.Text.ToString());
            btn_StartListen.BackColor = Color.LimeGreen;
        }

        private void btn_Connect_Click(object sender, EventArgs e)
        {
            Client.Connect(txt_clientIP.Text.ToString(), txt_clientPort.Text.ToString());
        }

        private void btn_serverSend_Click(object sender, EventArgs e)
        {
            Button b = (Button)sender;
            bool isServer = b.Name.Contains("server");
            if (isServer)
                Server.SendMsg(txt_serverMsg.Text.ToString());
            else
                Client.SendMsg(txt_clientMsg.Text.ToString());
        }

現在啟動程序，測試發送接收功能是否正常

至此，一個簡單的Socket通訊模型已經完成，實際應用中還需考慮通訊異常，通訊協議，多個客戶端通訊等事項，第一次寫博，歡迎大家多多指正；