C# 創建UDP服務器並接收客戶端數據

C# 創建UDP服務器並接收客戶端數據

2015-02-11 17:20 1218人閱讀 評論(0) 收藏 舉報

 分類：

 

C#開發技術（22） 

版權聲明：本文爲博主原創文章，未經博主容許不得轉載。

 

 

 

服務器端對象類庫：

 

 

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net.Sockets;
using System.Net;
using System.Threading;
using System.IO;
namespace UdpChatExample
{
    /// <summary>
    /// UDP服務器對象
    /// </summary>
    public class UDPServerClass
    {
        public delegate void MessageHandler(string Message);//定義委託事件
        public event MessageHandler MessageArrived;
        public UDPServerClass()
        {
            //獲取本機可用IP地址
            IPAddress[] ips = Dns.GetHostAddresses(Dns.GetHostName());
            foreach (IPAddress ipa in ips)
            {
                if (ipa.AddressFamily == AddressFamily.InterNetwork)
                {
                    MyIPAddress = ipa;//獲取本地IP地址
                    break;
                }
            }
            Note_StringBuilder = new StringBuilder();
            PortName = 8080;

        }

        public UdpClient ReceiveUdpClient;

        /// <summary>
        /// 偵聽端口名稱
        /// </summary>
        public int PortName;

        /// <summary>
        /// 本地地址
        /// </summary>
        public IPEndPoint LocalIPEndPoint;

        /// <summary>
        /// 日誌記錄
        /// </summary>
        public StringBuilder Note_StringBuilder;
        /// <summary>
        /// 本地IP地址
        /// </summary>
        public IPAddress MyIPAddress;

        public void Thread_Listen()
        {
            //建立一個線程接收遠程主機發來的信息
            Thread myThread = new Thread(ReceiveData);
            myThread.IsBackground = true;
            myThread.Start();
        }
        /// <summary>
        /// 接收數據
        /// </summary>
        private void ReceiveData()
        {
            IPEndPoint local = new IPEndPoint(MyIPAddress, PortName);
            ReceiveUdpClient = new UdpClient(local);
            IPEndPoint remote = new IPEndPoint(IPAddress.Any, 0);
            while (true)
            {
                try
                {
                    //關閉udpClient 時此句會產生異常
                    byte[] receiveBytes = ReceiveUdpClient.Receive(ref remote);
                    string receiveMessage = Encoding.Default.GetString(receiveBytes, 0, receiveBytes.Length);
                    //  receiveMessage = ASCIIEncoding.ASCII.GetString(receiveBytes, 0, receiveBytes.Length);
                    MessageArrived(string.Format("{0}來自{1}:{2}", DateTime.Now.ToString(), remote, receiveMessage));
                    //try
                    //{
                    //    Byte[] sendBytes = Encoding.ASCII.GetBytes("Is anybody there?");
                    //    ReceiveUdpClient.Send(sendBytes, sendBytes.Length, local);
                    //}
                    //catch (Exception e)
                    //{
                    //}
                    //break;

                }
                catch
                {
                    break;
                }
            }
        }

        /// <summary>
        /// 添加日誌信息到Note_StringBuilder
        /// </summary>
        public void AddMessage_Note_StringBuilder()
        {

        }
    }
}

 

界面簡單代碼：

 

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;

namespace UdpChatExample
{
    public partial class UDPServerForm : Form
    {
        public UDPServerForm()
        {
            InitializeComponent();
        }
        public delegate void DelegateChangeText(string Messages);
        void ChangeTxt(string Messages)
        {
            string SBText = SB.ToString();
            SB.Remove(0, SB.Length);
            SB.Append(Messages + "\r\n" + SBText);
            richTextBox1.Text = SB.ToString();
        }
        StringBuilder SB = new StringBuilder();
        private void UDPServerForm_Load(object sender, EventArgs e)
        {

        }

        UDPServerClass UDPServerClass1;
        private void button1_Click(object sender, EventArgs e)
        {
            UDPServerClass1 = new UDPServerClass();
            UDPServerClass1.Thread_Listen();
            UDPServerClass1.MessageArrived += new UDPServerClass.MessageHandler(UDPServerClass1_MessageArrived);
        }

        void UDPServerClass1_MessageArrived(string Message)
        {
            richTextBox1 .Invoke (new DelegateChangeText(ChangeTxt),Message);
        }

        private void UDPServerForm_FormClosing(object sender, FormClosingEventArgs e)
        {
            System.Environment.Exit(System.Environment.ExitCode);
        }
    }
}