UDP 网络通信 C#

接收端

 

using System;

using System.Net;

using System.Net.Sockets;

using System.Text;

using System.Threading;

using System.Windows.Forms;

 

namespace UDPReceiveTest

{

    public partial class Form1 : Form

    {

        public UdpClient udpClient;

        public Thread UdpThread;

 

        public Form1()

        {

            InitializeComponent();

        }

 

        private void Form1_Load(object sender, EventArgs e)

        {

            if (UdpThread != null)

            {

                UdpThread.Abort();

                Thread.Sleep(TimeSpan.FromMilliseconds(500d));

            }

 

            System.Windows.Forms.Control.CheckForIllegalCrossThreadCalls = false;

 

            if (udpClient != null)

            {

                UdpThread.Abort();

                Thread.Sleep(TimeSpan.FromMilliseconds(500d));

                udpClient.Close();

            }

            try

            {

                udpClient = new UdpClient(int.Parse(txtPort.Text));

                UdpThread = new Thread(new ThreadStart(UdpReciveThread));

                UdpThread.Start();

            }

            catch (Exception y)

            {

                MessageBox.Show(this, y.Message, "Error", MessageBoxButtons.OK,MessageBoxIcon.Error);

                this.Dispose(true);

            }

        }

 

        private void button1_Click(object sender, EventArgs e)

        {

            txtMessage.Text = string.Empty;

        }

 

        delegate void SetTextCallback(IPEndPoint remoteHost, byte[] buf, string bufs);

        //接收数据线程

        void UdpReciveThread()

        {

            IPHostEntry oIPHost = Dns.GetHostEntry(Environment.MachineName);

            IPEndPoint remoteHost = new IPEndPoint(IPAddress.Any, 0);

 

            while (udpClient != null &&Thread.CurrentThread.ThreadState.Equals(ThreadState.Running))

            {

                try

                {

                    byte[] buf = udpClient.Receive(ref remoteHost);

                    string bufs = Encoding.UTF8.GetString(buf);

 

                    txtMessage.Text += remoteHost.Address.ToString() + "说：" +Environment.NewLine;

                    txtMessage.Text += bufs + Environment.NewLine;

                }

                catch (Exception y)

                {

 

                }

            }

 

            txtMessage.Text += "结束..." + (char)13;

        }

 

        private void Form1_FormClosing(object sender, FormClosingEventArgs e)

        {

            try

            {

                udpClient.Close();

                UdpThread.Abort();

            }

            catch

            {

 

            }

        }

    }

}

发送端

using System;

using System.Net.Sockets;

using System.Text;

using System.Windows.Forms;

 

namespace UDPSendTest

{

    public partial class Form1 : Form

    {

        public Form1()

        {

            InitializeComponent();

        }

 

        private void btnSend_Click(object sender, EventArgs e)

        {

             try

            {

                UdpClient uc = new UdpClient(txtIP.Text, int.Parse(txtPort.Text));

 

                byte[] sendbuf = Encoding.UTF8.GetBytes(txtMessage.Text);

                uc.Send(sendbuf, sendbuf.Length);

            }

            catch (Exception y)

            {

                MessageBox.Show(this, y.Message, "发送失败", MessageBoxButtons.OK,MessageBoxIcon.Hand);

            }

        }

    }

}