537-C#编写的基于TCP通信的IMV3源码
我们知道在网络通信中,如果所有的通信都通过服务器转发,会增加服务器的负担,如果实现了P2P,客户端之间直接通讯,比如聊天或者传送文件时不再通过服务器,而是客户端之间直接通信,将会有效的减轻服务器的负担,提高程序的效率。
本节相关的P2P,指的是通过TCP协议,在局域网中实现的P2P,广域网中的P2P暂时没有涉及。
本Demo基于来自英国的networkComms2.3.1开源通信框架
工作原理-通过服务器,在客户端之间建立P2P通道,之后客户端之间的通讯可以脱离服务器
流程如下:
NetworkComms通信框架的内在通信机制,使得我们实现P2P通信非常的简单。
(1):服务器开始监听
(2) :客户端,开始连接服务器,然后也开始监听工作,其实成为一个服务器。连接的过程中,系统会给客户端随机分派一个端口,以便完成与服务器的通信。连接完成后,我们获取到客户端的IP和与服务器通信的端口,客户端在此端口上展开监听,也就是说每个客户端都会展开监听,具备作为服务器的所有特质。
模拟代码:
ConnectionInfo connInfo = new ConnectionInfo("服务器IP", "服务器端口");
//客户端与服务器进行连接
Connection newTcpConnection = TCPConnection.GetConnection(connInfo);
//客户端与服务器连接成功后,开始监听本地端口,客户端也称为可以监听的服务器
TCPConnection.StartListening(connInfo.LocalEndPoint);
//客户端与服务器进行连接
Connection newTcpConnection = TCPConnection.GetConnection(connInfo);
//客户端与服务器连接成功后,开始监听本地端口,客户端也称为可以监听的服务器
TCPConnection.StartListening(connInfo.LocalEndPoint);
(3):每个客户端需要维护一个“P2P通信的连接”表
我们用一个静态类来实现,具体可查看Common类
//字典中存储 用户ID 和相应的连接引用
//字典中存储 用户ID 和相应的连接引用
public static Dictionary UserConnList = new Dictionary();
相关操作方法
(4):客户端成功登陆后,从服务器获取所有在线其他客户端用户的本地端点(IP和端口)(即在其他客户端在步骤一中展开监听的端点),并进行连接
《1》客户端甲与其他客户端逐个进行连接,连接成功后,客户端甲添加对方用户ID和连接引用到本地P2P通道字典中
《2》客户端甲发送一个消息类型为”setupP2PMessage"的消息,给对方,以便于对方添加相应的记录到对方的P2P字典中
《3》客户端甲与其他用户进行连接时,客户端甲为“客户端”,其他的客户端为“服务器端”,所以在P2P通道的2端,总有一端为“客户端”,另一端为“服务器”。
配合NetworkComms通信框架,此种概念上的区分,并不影响P2P通道的通信。
客户端甲与其他客户端通信时,无论是作为”客户端“或者”服务器“均可,只要与对方存在TCP长连接即可。
《4》 这种由客户端之间彼此通信而建成的”服务器“,具备真正服务器的所有功能,会进行相应的”心跳检测“与”连接“维护等。
下面的代码:某客户端登陆后,获取所有已在线用户,并与之连接,连接完成后,发送”SetupP2PMessag"类型消息给对方。通过此过程,彼此双方的“P2P连接”都会建立完成。
上面的代码中,我们把相关的P2P通道建立消息写入程序文件夹下“P2PINFO.txt文件”,以便于观察P2P消息通道的建立。和通过P2P通道发送消息
(5):通过P2P通道发送消息
客户端发送消息时,查看是否与对方存在 P2P通道,如果存在通过P2P连接发送消息,否则通过服务器发送
举例说明,发送聊天消息时,先查看是否有 p2p 通道
(6)P2P通道的注销
当某个客户端掉线后,我们要把其从其他相应客户端的P2P通道注销掉。
方法:服务器通过心跳检测,知道某连接掉线后,发送消息给其他所有客户端。

本源码地址:http://www.codehy.com/vip/net/2019/0512/19165.html