C# 实现UDP打洞通信,一

最近研究了一下网络打洞的相关技术,TCP的方式据说可行性不高,各种困难,因此决定采用UDP(UDP是什么就不解释了)的方式。

原理:

  我们都知道局域网内的主机想要访问外网的服务器是比较容易的,比如浏览器输入www.baidu.com就可以访问到百度的服务器,但是如果在局域网的主机部署一个服务,让外网的机器进行访问一般是无法访问的,因为外部访问的请求会被路由器给阻碍掉了,这是为什么呢?

  比如我内网的主机IP是192.168.1.128,我访问外网的服务器的时候系统会自动给我的访问分配端口(也可以自定义端口),我对外的访问请求会经过路由器,路由器又会分配一个对外的端口,如果还有外部网络路由器,那么每一层都会分配一个独立的对外端口,一直到最终处于公网的路由器通过公网的IP及分配的端口对外部的服务器发起访问请求,服务器收到请求的同时会得到我处于公网的路由器的IP及分配的端口,然后将请求的反馈结果发送给我,反馈的信息会发到我的公网IP及端口,然后路由器内部再逐层向内发送给对应的IP和端口最终到达发起请求的应用程序。

  如内网主机(192.168.1.128:12345)访问外网服务器(111.110.213.99:15000),那么实际的请求过程是这样的:内网主机(192.168.1.128:12345)发起请求,请求通过路由器A(假设只有一个路由器),路由器为内网的(192.168.1.128:12345)绑定一个动态的端口(18876)并通过路由器的外网IP(120.145.15.87:18876)访问外网服务器(111.110.213.99:15000),服务器收到请求后发送反馈数据给路由器(120.145.15.87:18876),路由器再根据记录的列表中18876端口绑定的内网地址,将信息转发给内网主机(192.168.1.128:12345),于是主机就收到外部的信息了。

  注意,如果内网没有向外部访问,那么路由器就没有分配(18876)这个端口,那么外部发来的数据会被路由器丢弃掉,我们通过先连接服务器,服务器收到的(18876)并使用该端口或将该端口发送给其它客户端使用,那么这个端口其实就是我们打的一个(洞)。

  由于一些原因没能用多台内网机器进行试验,只是简单的通过内网主机和外网的服务器进行的试验,下面贴上代码:

  1 using System;
  2 using System.Net;
  3 using System.Net.Sockets;
  4 using System.Text;
  5 using System.Threading;
  6 
  7 namespace P2MP
  8 {
  9     class MainClass
 10     {
 11         /// <summary>
 12         /// 用于UDP发送的网络服务类
 13         /// </summary>
 14         private static UdpClient udpcSend = null;
 15 
 16         static IPEndPoint localIpep = null; 
 17 
 18         public static void Main(string[] args)
 19         {
 20             Console.Write("IP:");
 21             string ip = Console.ReadLine();
 22             Console.Write("Port:");
 23             int port = int.Parse(Console.ReadLine());
 24             localIpep = new IPEndPoint(IPAddress.Parse(ip), port); // 本机IP,指定的端口号
 25 
 26             udpcSend = new UdpClient(localIpep);
 27 
 28             StartReceive();
 29 
 30             // 实名发送
 31             string msg = null;
 32             while ((msg = Console.ReadLine()) != null)
 33             {
 34                 if ("stop" == msg)
 35                 {
 36                     StopReceive();
 37                     udpcSend.Close();
 38                 }
 39                 else
 40                 {
 41                     //string[] arr = Console.ReadLine().Split(' ');
 42                     Thread thrSend = new Thread(SendMessage);
 43                     thrSend.Start(msg);
 44                 }
 45             }
 46             Console.ReadKey();
 47         }
 48 
 49         /// <summary>
 50         /// 发送信息
 51         /// </summary>
 52         /// <param name="obj"></param>
 53         private static void SendMessage(object obj)
 54         {
 55             try
 56             {
 57                 string message = obj.ToString();
 58                 string[] array = message.Split(' ');
 59                 IPAddress iPAddress = IPAddress.Parse(array[0]);
 60                 int port = int.Parse(array[1]);
 61                 byte[] sendbytes = Encoding.Unicode.GetBytes(array[2]);
 62                 IPEndPoint remoteIpep = new IPEndPoint(iPAddress, port); // 发送到的IP地址和端口号
 63                 udpcSend.Send(sendbytes, sendbytes.Length, remoteIpep);
 64             }
 65             catch{}
 66         }
 67 
 68         /// <summary>
 69         /// 开关:在监听UDP报文阶段为true,否则为false
 70         /// </summary>
 71         static bool IsUdpcRecvStart = false;
 72         /// <summary>
 73         /// 线程:不断监听UDP报文
 74         /// </summary>
 75         static Thread thrRecv;
 76 
 77         private static void StartReceive()
 78         {
 79             if (!IsUdpcRecvStart) // 未监听的情况,开始监听
 80             {
 83                 thrRecv = new Thread(ReceiveMessage);
 84                 thrRecv.Start();
 85                 IsUdpcRecvStart = true;
 86                 Console.WriteLine("UDP监听器已成功启动");
 87             }
 88         }
 89 
 90         private static void StopReceive()
 91         {
 92             if (IsUdpcRecvStart)
 93             {
 94                 thrRecv.Abort(); // 必须先关闭这个线程,否则会异常
 96                 IsUdpcRecvStart = false;
 97                 Console.WriteLine("UDP监听器已成功关闭");
 98             }
 99         }
100 
101         /// <summary>
102         /// 接收数据
103         /// </summary>
104         /// <param name="obj"></param>
105         private static void ReceiveMessage(object obj)
106         {
108             while (IsUdpcRecvStart)
109             {
110                 try
111                 {
112                     byte[] bytRecv = udpcSend.Receive(ref localIpep);
113                     string message = Encoding.Unicode.GetString(bytRecv, 0, bytRecv.Length);
114                     Console.WriteLine(string.Format("{0}[{1}]", localIpep, message));
115                 }
116                 catch (Exception ex)
117                 {
118                     Console.WriteLine(ex.Message);
119                     break;
120                 }
121             }
122         }
123     }
124 }

  可以同时在多个内网主机运行,并且保证其中有一个实在外网的服务器上运行,启动后输入本机的IP和使用的端口,当所有机器都显示“UDP监听器已成功启动”后,分别使用内网程序向 服务器IP地址[空格]端口号[空格]消息内容如:"188.90.9.145 12345 hello你好",发送消息给服务器,服务器收到的消息上附带客户端发来的对外端口,这时候就知道各个客户端的对外IP和端口了,各个主机想要给另一台主机发消息只要从服务器上看其它客户端的IP和端口,并通过“IP 端口 消息”的格式发送消息,网络良好不丢包的情况下就能发送进去了。

  由于路由器会定时销毁记录的列表,因此还需要保持客户端跟服务器之间的心跳,比如每10秒发送一个消息,服务器端将各个客户端最新的列表保存下来。

  暂时先贴出简单的代码,后续打算开发一个P2P文件服务,代码逐步完善中。