C#網路編程入門之UDP

2020 年 5 月 27 日
筆記
C#網路編程, http, TCP, UDP

一、概述

UDP和TCP是網路通訊常用的兩個傳輸協議，C#一般可以通過Socket來實現UDP和TCP通訊，由於.NET框架通過UdpClient、TcpListener 、TcpClient這幾個類對Socket進行了封裝，使其使用更加方便，本文就通過這幾個封裝過的類講解一下相關應用。

二、UDP基本應用

與TCP通訊不同，UDP通訊是不分服務端和客戶端的，通訊雙方是對等的。為了描述方便，我們把通訊雙方稱為發送方和接收方。

發送方：

首先創建一個UDP對象：

            string locateIP = "127.0.0.1";    //本機IP

            int locatePort = 9001;            //發送埠

            IPAddress locateIpAddr = IPAddress.Parse(locateIP);

            IPEndPoint locatePoint = new IPEndPoint(locateIpAddr, locatePort);

            UdpClient  udpClient = new UdpClient(locatePoint);

發送數據：

            string remoteIP = "127.0.0.1";             //目標機器IP

            int remotePort = 9002;                     //接收埠          

            IPAddress remoteIpAddr = IPAddress.Parse(remoteIP);

            IPEndPoint remotePoint = new IPEndPoint(remoteIpAddr, remotePort);

            byte[] buffer = Encoding.UTF8.GetBytes(「hello」);

            udpClient.Send(buffer, buffer.Length, remotePoint);

以上就完成了一個發送任務，一個較完整的發送程式碼如下：

    public partial class FormServer : Form
    {
        private UdpClient udpClient = null;

        private void btnConnect_Click(object sender, EventArgs e)
        {
            string locateIP = "127.0.0.1";
            int locatePort = 9001;
            IPAddress locateIpAddr = IPAddress.Parse(locateIP);
            IPEndPoint locatePoint = new IPEndPoint(locateIpAddr, locatePort);
            udpClient = new UdpClient(locatePoint);

            this.groupWork.Enabled = true;
        }

        private void Send_Click(object sender, EventArgs e)
        {
            string text = this.txtSend.Text.Trim();
            string remoteIP = "127.0.0.1";
            int remotePort = 9002;
            byte[] buffer = Encoding.UTF8.GetBytes(text);

            if (udpClient != null)
            {
                IPAddress remoteIp = IPAddress.Parse(remoteIP);
                IPEndPoint remotePoint = new IPEndPoint(remoteIp, remotePort);
                udpClient.Send(buffer, buffer.Length, remotePoint);
            }

            Debug.WriteLine("Send OK");
        }
    }

View Code

接收端：

首先創建一個UDP對象：

            string locateIP = "127.0.0.1";

            int locatePort = 9002;

            IPAddress locateIpAddr = IPAddress.Parse(locateIP);

            IPEndPoint locatePoint = new IPEndPoint(locateIpAddr, locatePort);

            UdpClient  udpClient = new UdpClient(locatePoint);

接收數據：

    IPEndPoint remotePoint = new IPEndPoint(IPAddress.Parse("1.1.1.1"), 1);

     var received = udpClient.Receive(ref remotePoint);

     string info = Encoding.UTF8.GetString(received);

     string from=$」 {remotePoint.Address}:{remotePoint.Port}」;

注意兩點：

1、remotePoint是獲得發送方的IP資訊，定義時可以輸入任何合法的IP和埠資訊；

2、Receive方法是阻塞方法，所以需要在新的執行緒內運行，程式會一直等待接收數據，當接收到一包數據時程式就返回，要持續接收數據需要重複調用Receive方法。

一個較完整的接收端程式碼如下：

   public partial class FormClent : Form
   {
        private UdpClient udpClient = null; 

        private void btnConnect_Click(object sender, EventArgs e)
        {
            string locateIP = "127.0.0.1";
            int locatePort = 9002;
            IPAddress locateIpAddr = IPAddress.Parse(locateIP);
            IPEndPoint locatePoint = new IPEndPoint(locateIpAddr, locatePort);
            udpClient = new UdpClient(locatePoint);
            IPEndPoint remotePoint = new IPEndPoint(IPAddress.Parse("1.1.1.1"), 1);

            Task.Run(() =>
            {
                while (true)
                {
                    if (udpClient != null)
                    {
                        var received = udpClient.Receive(ref remotePoint);
                        string info = Encoding.UTF8.GetString(received);
                        string from=$」 {remotePoint.Address}:{remotePoint.Port}」; 
                    }
                }
            }); 
        }
   }

View Code

三、丟包和亂序問題

當發送端發送一包數據時，不管對方是否接收都是發送成功的，UDP協議本身並不會對發送的可靠性進行驗證。（這裡的可靠性是指是否接收到，如果對方接收到數據包，其內容還是可靠的，這個在鏈路層進行了保證。）同時，由於網路延時等因素，先發送的包並不能確定先被接收到，所以由於這兩個原因，UDP通訊存在丟包和亂序的情況。

某些業務場景下，比如實時狀態監控，可能對丟包和亂序情況並不敏感，可以不用處理，但大部分情況下還是介意丟包的，簡單的處理辦法就是把包的頭部固定長度的空間拿出來存放核對資訊，比如包編號，如果有缺失，可以要求發送方重發，也可以進行排序。

四、將數據接收包裝為事件

我們對UdpClent又進行一次封裝，啟用一個執行緒進行接收數據，將接收到的數據包通過事件發布出來，這樣使用起來就更方便了。

namespace Communication.UDPClient
{
    public class UdpStateEventArgs : EventArgs
    {      
        public IPEndPoint remoteEndPoint;      
        public byte[] buffer = null;
    }

    public delegate void UDPReceivedEventHandler(UdpStateEventArgs args);

    public class UDPClient
    {
        private UdpClient udpClient;
        public event UDPReceivedEventHandler UDPMessageReceived;

        public UDPClient(string locateIP, int locatePort)
        {
            IPAddress locateIp = IPAddress.Parse(locateIP);
            IPEndPoint locatePoint = new IPEndPoint(locateIp, locatePort);
            udpClient = new UdpClient(locatePoint);

            //監聽創建好後，創建一個執行緒，開始接收資訊
            Task.Run(() =>
            {
                while (true)
                {
                    UdpStateEventArgs udpReceiveState = new UdpStateEventArgs();

                    if (udpClient != null)
                    {
                        IPEndPoint remotePoint = new IPEndPoint(IPAddress.Parse("1.1.1.1"), 1);
                        var received = udpClient.Receive(ref remotePoint);
                        udpReceiveState.remoteEndPoint = remotePoint;
                        udpReceiveState.buffer = received;
                        UDPMessageReceived?.Invoke(udpReceiveState);
                    }
                    else
                    {
                        break;
                    }
                }
            });
        }
    }
}

具體使用辦法：

        private void btnConnect_Click(object sender, EventArgs e)
        {
            string locateIP = "127.0.0.1";
            int locatePort = 9002;           
            UDPClient udpClient = new UDPClient(locateIP, locatePort);
            udpClient.UDPMessageReceived += UdpClient_UDPMessageReceived;           
        }

        private void UdpClient_UDPMessageReceived(UdpStateEventArgs args)
        {
            var remotePoint = args.remoteEndPoint;
            string info = Encoding.UTF8.GetString(args.buffer); 
        }

限於篇幅，我們只封裝了數據接收，時間使用時需要把發送功能也封裝進去，使這個類同時具備發送和接收功能，發送功能的封裝比較簡單就不貼程式碼了。

Tags: C#網路編程 http TCP UDP