首頁 > 軟體

C#使用udp如何實現訊息的接收和傳送

2023-02-27 06:00:31

使用udp實現訊息的接收和傳送

程式碼比較簡單,但是別忘記關閉防火牆進行測試。

首先便是伺服器端,使用Socket進行實現,參考程式碼如下:

        private static Socket udpServer;
        static void startUdpReceive()
        {
            Console.WriteLine("------startUdpReceive--");
            udpServer = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
            udpServer.Bind(new IPEndPoint(IPAddress.Parse("192.168.2.106"), 10023));
            new Thread(ReceiveMessage)
            {
                IsBackground = true
            }.Start();
        }
 
        private static void ReceiveMessage()
        {
            Console.WriteLine("------ReceiveMessage--");
            while (true)
            {
                byte[] data = new byte[1024];
                EndPoint endPoint = new IPEndPoint(IPAddress.Any, 0);
                int count = udpServer.ReceiveFrom(data, ref endPoint);
                if (count > 0)
                {
                    string message = Encoding.UTF8.GetString(data, 0, count);
                    Console.WriteLine
                        ("-----從ip" + (endPoint as IPEndPoint).Address.ToString()
                        + ":" + (endPoint as IPEndPoint).Port + "Get" + message);
                }
 
            }
        }

在繫結socket埠的時候,需要提供繫結的ip和埠號,如這裡是

udpServer.Bind(new IPEndPoint(IPAddress.Parse("192.168.2.106"), 10023));

本機ip是是192.168.2.106,繫結埠是10023。然後使用while迴圈監聽訊息。對於本機來說,也可以使用 udpServer.Bind(new IPEndPoint(IPAddress.Any, 10023)); 只繫結埠,對於ip則不限制。

也可以不用Socket而是直接使用UdpClient類來寫接收端,效果類似:

        static UdpClient udpcRecv;
        public static void UdpServices()
        {
            try
            {
                IPAddress ip = IPAddress.Parse("192.168.2.106");
                IPEndPoint remoteIpep = new IPEndPoint(ip, 10023);
                udpcRecv = new UdpClient(remoteIpep);
                Thread thrRecv = new Thread(ReceiveMessage22);
                thrRecv.IsBackground = true;
                thrRecv.Start();
            }
            catch (Exception ex)
            {
                MessageBox.Show("錯誤", "請檢查網路");
            }
 
        }
 
 
        private static void ReceiveMessage22()
        {
            IPEndPoint remoteIpep = new IPEndPoint(IPAddress.Any, 0);
            Console.WriteLine("-----remoteIpep:" + remoteIpep.Address + ":" + remoteIpep.Port);
            while (true)
            {
                try
                {
                    byte[] bytRecv = udpcRecv.Receive(ref remoteIpep);
                    string message = Encoding.UTF8.GetString(
                        bytRecv, 0, bytRecv.Length);
                    Console.WriteLine("-----reveice  message:" + message);
                }
                catch (Exception ex)
                {
                    MessageBox.Show("UDP異常", ex.Message);
                }
            }
        }

接下來是傳送端:

            UdpClient udpClient = new UdpClient();
            try
            {
                udpClient.Connect("192.168.2.106", 10023);
                Byte[] sendBytes = Encoding.ASCII.GetBytes("Is anybody there??????");
                udpClient.Send(sendBytes, sendBytes.Length);
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.ToString());
            }

如果程式碼爆紅則應該是導包的問題,加入以下即可。

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using System.Net.Sockets;
using System.Net;
using System.Net.NetworkInformation;
using System.Management;
using System.Threading;

上面都寫好後可以測試了,但是我卻遇到了問題,後面才知道是電腦端防火牆沒開導致,所以和電腦端偵錯網路通訊的時候,需要關閉防火牆,才能收到資料。

C# 運用UDP

面試的時候偶爾會問到UDP和TCP的一個區別。

  • TCP是一種面向連線的、可靠的、基於位元組流的傳輸層通訊協定。舉例:打電話,需要雙方都接通,才能進行對話。特點:效率低,資料傳輸比較安全。
  • UDP是一種面向無連線的傳輸層通訊協定。舉例:傳簡訊,不需要雙方建立連線,但是,資料包的大小應限制在64k以內。特點:效率高,資料傳輸不安全,容易丟包

然後發現在網上查詢關於C#執行UDP的範例,確實不好找,雜亂無章。痛定思痛!

進行一個簡單的傳送和接收測試。

目前,UDP本人親自用過的場景,使用者端和伺服器端需要進行資料傳輸,但是伺服器端,在開始時是連線的別的網路,切換過來之後,並不能知道當前的一個具體的IP地址。但是使用者端的IP地址是固定的,此種場景下,伺服器端網路切換過來之後,建立UDP伺服器端,像指定的使用者端(IP地址和埠號)傳送資料,即可知道當前伺服器端的ip地址。

伺服器端介面

 using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;

namespace MyTest.UDP
{
    public partial class UDP_Sever : Form
    {
        IPEndPoint remotePoint;
        UdpClient sever = null;

        public UDP_Sever()
        {
            InitializeComponent();
        }
              
        private void button1_Click(object sender, EventArgs e)
        {
            IPAddress remoteIP = IPAddress.Parse(textBox1.Text.Trim()); //假設傳送給這個IP
            int remotePort =int.Parse(textBox2.Text.Trim());
            remotePoint = new IPEndPoint(remoteIP, remotePort);//範例化一個遠端端點
            sever = new UdpClient();
        }

        private void button2_Click(object sender, EventArgs e)
        {
            if (!string.IsNullOrWhiteSpace(textBox3.Text.Trim()))
            {
                string sendString = textBox3.Text.Trim();//要傳送的字串
                byte[] sendData = Encoding.Default.GetBytes(sendString);//要傳送的位元組陣列
                sever.Send(sendData, sendData.Length, remotePoint);//將資料傳送到遠端端點
                textBox3.Text = "";
            }
        }

        private void UDP_Sever_FormClosing(object sender, FormClosingEventArgs e)
        {
            sever.Close();
        }
    }
}

使用者端介面

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;

namespace MyTest.UDP
{
    public partial class UDP_Client : Form
    {
        UdpClient client = null;
        IPEndPoint remotePoint;
        string receiveString = null;
        byte[] receiveData = null;


        public UDP_Client()
        {
            InitializeComponent();
            CheckForIllegalCrossThreadCalls = false;
        }

        private void button1_Click(object sender, EventArgs e)
        {         
            //範例化一個遠端端點,IP和埠可以隨意指定,等呼叫client.Receive(ref remotePoint)時會將該端點改成真正傳送端端點
            remotePoint = new IPEndPoint(IPAddress.Any, 0);
            client = new UdpClient(int.Parse(textBox2.Text.Trim()));

            Thread thread = new Thread(Revice);
            thread.IsBackground = true;
            thread.Start();
        }
        private void Revice()
        {
            while (true)
            {             
                receiveData = client.Receive(ref remotePoint);//接收資料
                receiveString = Encoding.Default.GetString(receiveData);
                listBox1.Items.Add(remotePoint.Address.ToString()+":"+ receiveString);               
            }
        }
    }
}

親測有效!

總結

以上為個人經驗,希望能給大家一個參考,也希望大家多多支援it145.com。


IT145.com E-mail:sddin#qq.com