C#实现UDP打洞 原理及代码（一）

下面是UDP打洞程序包的源码：
//WellKnown公用库
using System;
using System.IO;
using System.Runtime.Serialization.Formatters.Binary;
using System.Net ;
using System.Net .Sockets ;
using System.Collections ;

namespace P2PWellKnown
{
/// <summary>
/// UDP用户登录事件委托
/// </summary>
/// <param name="sender">事件源对象</param>
/// <param name="e">事件实体</param>
public delegate void UdpUserLogInDelegate(object sender,UDPSockEventArgs e);

/// <summary>
/// 一般UDP消息事件委托
/// </summary>
/// <param name="sender">事件源对象</param>
/// <param name="e">事件实体</param>
public delegate void UdpMessageDelegate(object sender,UDPSockEventArgs e);

/// <summary>
/// 初始化一个新连接的事件委托
/// </summary>
/// <param name="sender">事件源对象</param>
/// <param name="e">事件实体</param>
public delegate void UdpNewConnectDelegate(object sender,UDPSockEventArgs e);

/// <summary>
/// P2P共享数据类
/// </summary>
public class P2PConsts
{
/// <summary>
/// UDP服务器监听端口
/// </summary>
public const int UDP_SRV_PORT = 2280;

/// <summary>
///TCP服务器监听端口
/// </summary>
public const int TCP_SRV_PORT =2000;
}

/// <summary>
/// FormatterHelper 序列化，反序列化消息的帮助类
/// </summary>
public class FormatterHelper

{

public static byte[] Serialize(object obj)

{

BinaryFormatter binaryF = new BinaryFormatter();

MemoryStream ms = new MemoryStream(1024*10);

binaryF.Serialize(ms, obj);

ms.Seek(0, SeekOrigin.Begin);

byte[] buffer = new byte[(int)ms.Length];

ms.Read(buffer, 0, buffer.Length);

ms.Close();

return buffer;

}

public static object Deserialize(byte[] buffer)

{

BinaryFormatter binaryF = new BinaryFormatter();

MemoryStream ms = new MemoryStream(buffer, 0, buffer.Length, false);

object obj = binaryF.Deserialize(ms);

ms.Close();

return obj;

}

}

/// <summary>
/// 用于承载UDPSock信息的事件类
/// </summary>
public class UDPSockEventArgs:EventArgs
{
/// <summary>
/// 要承载的消息
/// </summary>
private string m_strMsg;

/// <summary>
/// 用户信息
/// </summary>
private string m_strUserName;

/// <summary>
/// 触发该事件的公共终端
/// </summary>
private IPEndPoint m_EndPoint;

/// <summary>
/// 初始化UDPSock事件
/// </summary>
/// <param name="sMsg">用户发送的信息</param>
public UDPSockEventArgs(string sMsg):base()
{
this.m_strMsg =sMsg;
}

/// <summary>
/// 远端用户名
/// </summary>
public string RemoteUserName
{
get
{
return m_strUserName;
}
set
{
m_strUserName=value;
}
}

/// <summary>
/// 一般套接字消息
/// </summary>
public string SockMessage
{
get
{
return m_strMsg;
}
set
{
m_strMsg = value;
}
}

/// <summary>
/// 公共远端节点
/// </summary>
public IPEndPoint RemoteEndPoint
{
get
{
return m_EndPoint;
}
set
{
m_EndPoint = value;
}
}
}
}