C# UDP操作執行個體

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;

namespace Udp
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }

        /// 
        /// 用于UDP發送的網絡服務類
        /// 
        private UdpClient udpcSend;
        /// 
        /// 用于UDP接收的網絡服務類
        /// 
        private UdpClient udpcRecv;
        private void button1_Click(object sender, EventArgs e)
        {
            if (string.IsNullOrWhiteSpace(richTextBox1.Text))
            {
                MessageBox.Show("請先輸入待發送内容");
                return;
            }

            // 匿名發送
            //udpcSend = new UdpClient(0);             // 自動配置設定本地IPv4位址
            // 實名發送
            IPEndPoint localIpep = new IPEndPoint(IPAddress.Parse("192.168.1.3"), 8847); // 本機IP，指定的端口号
             udpcSend = new UdpClient(localIpep);
            Thread thrSend = new Thread(SendMessage);
            thrSend.Start(richTextBox1.Text);
        }
        private void SendMessage(object obj)
        {
            string message = (string)obj;
            byte[] sendbytes = Encoding.Unicode.GetBytes(message);
            IPEndPoint remoteIpep = new IPEndPoint(IPAddress.Parse("192.168.1.3"), 8848); // 發送到的IP位址和端口号
            udpcSend.Send(sendbytes, sendbytes.Length, remoteIpep);
            udpcSend.Close();
            ResetTextBox(richTextBox1);
        }

        /// <summary>
        /// 開關：在監聽UDP封包階段為true，否則為false
        /// </summary>
        bool IsUdpcRecvStart = false;
        /// <summary>
        /// 線程：不斷監聽UDP封包
        /// </summary>
        Thread thrRecv;


        private void button2_Click(object sender, EventArgs e)
        {
            if (!IsUdpcRecvStart) // 未監聽的情況，開始監聽
            {
                IPEndPoint localIpep = new IPEndPoint(IPAddress.Parse("192.168.1.3"), 8848); // 本機IP和監聽端口号
                udpcRecv = new UdpClient(localIpep);
                thrRecv = new Thread(ReceiveMessage);
                thrRecv.Start();
                IsUdpcRecvStart = true;
               // MessageBox.Show("1123");
                ShowMessage(richTextBox2, "UDP監聽器已成功啟動");
            }
            else // 正在監聽的情況，終止監聽
            {
                thrRecv.Abort(); // 必須先關閉這個線程，否則會異常
                udpcRecv.Close();
                IsUdpcRecvStart = false;
                ShowMessage(richTextBox2, "UDP監聽器已成功關閉");
            }

        }
        /// <summary>
        /// 接收資料
        /// </summary>
        /// <param name="obj"></param>
        private void ReceiveMessage(object obj)
        {
            IPEndPoint remoteIpep = new IPEndPoint(IPAddress.Any, 0);//
            while (true)
            {
                try
                {

                    byte[] bytRecv = udpcRecv.Receive(ref remoteIpep);
                    string message = Encoding.Unicode.GetString(bytRecv, 0, bytRecv.Length);
                    ShowMessage(richTextBox2, string.Format("{0}[{1}]", remoteIpep, message));
                }
                catch (Exception ex)
                {
                    ShowMessage(richTextBox2, ex.Message);
                    break;
                }
            }
        }
        // 向RichTextBox中添加文本
        delegate void ShowMessageDelegate(RichTextBox txtbox, string message);
        private void ShowMessage(RichTextBox txtbox, string message)
        {
            if (txtbox.InvokeRequired)
            {
                ShowMessageDelegate showMessageDelegate = ShowMessage;
                txtbox.Invoke(showMessageDelegate, new object[] { txtbox, message });
            }
            else
            {
                txtbox.Text += message + "\r\n";
            }
        }

        // 清空指定RichTextBox中的文本
        delegate void ResetTextBoxDelegate(RichTextBox txtbox);
        private void ResetTextBox(RichTextBox txtbox)
        {
            if (txtbox.InvokeRequired)
            {
                ResetTextBoxDelegate resetTextBoxDelegate = ResetTextBox;
                txtbox.Invoke(resetTextBoxDelegate, new object[] { txtbox });
            }
            else
            {
                txtbox.Text = "";
            }
        }

        /// <summary>
        /// 關閉程式，強制退出
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void Form1_FormClosing(object sender, FormClosingEventArgs e)
        {
            Environment.Exit(0);
        }


    }



    
}
           

複制