P2P编程

开发平台：
C#

SockUDP.cs：源码内容
							using System;
using System.ComponentModel;
using System.Collections;
using System.Diagnostics;
using System.IO;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
namespace LanMsg.Controls
{
	/// <summary>
	/// SockUDP 的摘要说明。
	/// </summary>
	public class SockUDP : System.ComponentModel.Component
	{
		/// <summary>
		/// 必需的设计器变量。
		/// </summary>
		private System.ComponentModel.Container components = null;
		public SockUDP(System.ComponentModel.IContainer container)
		{
			///
			/// Windows.Forms 类撰写设计器支持所必需的
			///
			container.Add(this);
			InitializeComponent();
			//
			// TODO: 在 InitializeComponent 调用后添加任何构造函数代码
			//
		}
		public SockUDP()
		{
			///
			/// Windows.Forms 类撰写设计器支持所必需的
			///
			InitializeComponent();
			//
			// TODO: 在 InitializeComponent 调用后添加任何构造函数代码
			//
		}
		/// <summary> 
		/// 清理所有正在使用的资源。
		/// </summary>
		protected override void Dispose( bool disposing )
		{
			if( disposing )
			{
				if(components != null)
				{
					components.Dispose();
				}
			}
			base.Dispose( disposing );
		}
		private int UDP_Server_Port  ;
		private System.Threading.Thread  thdUdp;
		private IPEndPoint _Server =new IPEndPoint(IPAddress.Any, 0);
		public  delegate void DataArrivalEventHandler(byte[] Data  ,IPAddress   Ip  , int  Port  );
		public  event DataArrivalEventHandler DataArrival; 
		private UdpClient UDP_Server = new UdpClient(); 
		//Socket UDP_Server; 
		public  delegate void Sock_ErrorEventHandler(string ErrString);
		public  event Sock_ErrorEventHandler Sock_Error; 
		[Browsable(true), Category("Client"), Description("获得对方IP地址与端口号等信息.")] 
		public IPEndPoint Server 
		{ 
			get 
			{ 
				return _Server; 
			} 
			set 
			{ 
				_Server = value; 
			} 
		} 
		public void Send(System.Net.IPAddress Host, int Port,byte[] Data) 
		{ 
			try 
			{ 
				IPEndPoint server = new IPEndPoint( Host , Port); 
				UDP_Server.Send(Data, Data.Length, server); 
                //UDP_Server.SendTo(Data,server);
			} 
			catch (Exception e) 
			{ 
				if (Sock_Error!= null)
					Sock_Error(e.ToString()); 
			} 
		} 
		public void Listen(int Port) 
		{ 
			try 
			{ 
				UDP_Server_Port = Port; 
				UDP_Server = new  UdpClient(Port); 
				// UDP_Server = new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Udp) ; 
				thdUdp = new Thread(new ThreadStart(GetUDPData) ); 
				thdUdp.Start(); 
			} 
			catch (Exception e) 
			{ 
				if (Sock_Error!= null)
					Sock_Error(e.ToString()); 
			} 
		} 
		private  void GetUDPData() 
		{ 
			while (true) 
			{ 
				try 
				{ 
					byte[] RData= UDP_Server.Receive(ref _Server);
					
					//byte[] RData= null;
//					UDP_Server.Receive(RData);
					if (DataArrival != null) 
					{ 
						DataArrival(RData, _Server.Address, _Server.Port); 
					} 
					Thread.Sleep(0); 
				} 
				catch (Exception e) 
				{ 
				   if (Sock_Error!= null)
                    Sock_Error(e.ToString()); 
				} 
			} 
		} 
		public  void CloseSock() 
		{ 
			Thread.Sleep(30); 
			try
			{
				UDP_Server.Close(); 
				thdUdp.Abort();
			}
			catch(Exception e)
			{
				if (Sock_Error!= null)
					Sock_Error(e.ToString()); 
			}
		} 
	 
	#region 组件设计器生成的代码
	/// <summary>
	/// 设计器支持所需的方法 - 不要使用代码编辑器修改
	/// 此方法的内容。
	/// </summary>
	private void InitializeComponent()
{
	components = new System.ComponentModel.Container();
}
	#endregion
	}
}

						