udp客户端通信示例源码

【实例简介】

 wonform 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.Windows.Forms;
using System.Net;
using System.Net.Sockets;
using System.Threading;

namespace udpForm
{
    public partial class Form1 : Form
    {
        UdpClient udpcSend;
        UdpClient udpcRecv;
        Thread thrRecv;
        Thread thrSend;
        bool IsUdpcRecvStart = false;
        
        public Form1()
        {
            InitializeComponent();
        }
        
        private void Form1_Load(object sender, EventArgs e)
        {
            btnSend.Enabled = true;
            //Control.CheckForIllegalCrossThreadCalls = false;
            
        }
             
        private void btnSet_Click(object sender, EventArgs e)
        {
            if (!IsUdpcRecvStart)
            {
                IPAddress locateIp = IPAddress.Parse(txtLocateIP.Text);
                IPEndPoint locatePoint = new IPEndPoint(locateIp, Convert.ToInt32(txtLocatePort.Text));
                udpcRecv = new UdpClient(locatePoint);
                thrRecv = new Thread(RecMessage);
                thrRecv.IsBackground = true;
                thrRecv.Start();
                btnSet.Text = "关闭";
                IsUdpcRecvStart = true;
            }
            else
            {
                thrRecv.Abort();
                udpcRecv.Close();
                IsUdpcRecvStart = false;
                btnSet.Text = "连接";
            }
        }

        private void RecMessage()
        {
            //接收所有发来的信息
            IPEndPoint remotePoint = new IPEndPoint(IPAddress.Any, 0);
            while (true)
                try
                {
                    //此时关闭udpcRecv时会产生异常
                    byte[] bytRecv = udpcRecv.Receive(ref remotePoint);
                    if (bytRecv != null)
                    {
                        string str = Encoding.UTF8.GetString(bytRecv, 0, bytRecv.Length);
                        ShowMessageforView(rtxtRec, string.Format("{0}[{1}]", remotePoint, str));
                    }
                }
                catch (Exception e)
                {
                    ShowMessageforView(rtxtRec,e.ToString());
                    break;
                }
            //udpcRecv.Close();
            //Start();
            //thrRecv.Abort();
        }

        //利用委托回调机制实现界面上消息内容显示
        delegate void ShowMessageforViewCallBack(ListBox listbox,string text);
        private void ShowMessageforView(ListBox listbox, string text)
        {
            if (listbox.InvokeRequired)
            {
                ShowMessageforViewCallBack showMessageforViewCallBack = ShowMessageforView;
                listbox.Invoke(showMessageforViewCallBack, new object[] { listbox, text });
            }
            else
            {
                rtxtRec.Items.Add(text);
                rtxtRec.SelectedIndex = rtxtRec.Items.Count - 1;
                rtxtRec.ClearSelected();
            }
        }
        
        /********************************************************************/
        private void btnSend_Click(object sender, EventArgs e)
        {
            if (string.IsNullOrWhiteSpace(rtxtSend.Text.Trim()))
            {
                MessageBox.Show("请先输入待发送内容");
                return;
            }           
            thrSend = new Thread(SendMessage);
            thrSend.Start();
        }

        private void SendMessage()
        {
            IPAddress locateIp = IPAddress.Parse(txtLocateIP.Text);
            IPEndPoint locatePoint = new IPEndPoint(locateIp, Convert.ToInt32(txtLocatePort.Text));
            //udpcSend = new UdpClient(0);          //匿名发送（自动分配本地IPV4地址）
            udpcSend = new UdpClient(locatePoint);
            byte[] buffer = Encoding.UTF8.GetBytes(rtxtSend.Text.Trim());
            IPAddress remoteIp = IPAddress.Parse(txtRemoteIP.Text);
            IPEndPoint remotePoint = new IPEndPoint(remoteIp, Convert.ToInt32(txtRemotePort.Text));
            udpcSend.Send(buffer, buffer.Length, remotePoint);
            udpcSend.Close();
            //清空发送消息框
            //ResetMessageText(rtxtSend);
        }

        //采用回调机制
        //使用委托实现跨线程界面的操作方式
        delegate void ResetMessageCallback(TextBox textbox);
        private void ResetMessageText(TextBox textbox)
        {
            //Control.InvokeRequired属性代表
            //如果控件的处理与调用线程在不同线程上创建，则为true,否则为false
            if (textbox.InvokeRequired)
            {
                ResetMessageCallback resetMessagecallback = ResetMessageText;
                textbox.Invoke(resetMessagecallback, new object[] { textbox });
            }
            else
            {
                textbox.Clear();
                textbox.Focus();
            }
        }
        /*
        //获得本地局域网IP地址
        private string getIpAddress()
        {
            IPAddress[] AddressList = Dns.GetHostByName(Dns.GetHostName()).AddressList;
            if(AddressList.Length < 1)
            {
                return "";
            }
            return AddressList[0].ToString();
        }
        */
        private void Form1_FormClosing(object sender,FormClosingEventArgs e)
        {
            Environment.Exit(0);
        }

    }
}