一次.net Socket UDP编程的10万客户端测试记录

最近想写一个网络服务器端的程序,想看看在大量客户端数下程序的运行情况。于是对.net 的Socket编程进行了一些研究,发现.net 3.5 里SocketAsyncEventArgs 是基于IOCP实现。MSDN上有相关的示例,但它是基于TCP协议的,而我想要的是基于UDP协议的。网上很难找到基于UDP协议的SocketAsyncEventArgs示例(UDP需要用IOCP吗?),于是决定自己写一个基于UDP协议的SocketAsyncEventArgs示例,看看它在和大量客户端通讯时的运行情况。

示例简介

  程序分为服务器端和客户端,它们使用UDP协议进行通讯。众所周知UDP是无连接的,可我又想计算出有多少客户端和服务器通信,其中又有多少是新的客户端。所以设计让服务器端程序绑定两个端口。一个端口专门用于接收客户端第一次发送过来的数据包;另一个端口负责和已经接入的客户端进行通讯(是不是有点像TCP的接入,例子本身也在模仿Tcp编程)。客户端比较简单让它生成足够多的Socket,然后不断的向服务器端发送数据包即可。

UDPReceiceSocket

  UdpReceiceSocket类负责接收从客户端发送来的数据包,客户端第一次发送过来的数据包和后期的通讯数据都是由它负责接收的。新建实例时会创建一个 Socket 套接字和一个SocketAsyncEventArgs,并且对其进行相应的初始化。OnDataReceived 事件用于计算收到了多少数据。
一次.net Socket UDP编程的10万客户端测试记录代码

 

用StartReceive()方法启动接收。根据Socket类的 ReceiveFromAsync()方法返回值判断操作是异步还是同步,如果返回值为False 时说明是同步的操作(说明在运行ReceiveFromAsync方法前数据已经准备好了,即已接收到客户端发来的数据包,并且放在了通知队列中),需要直接调用processReceived方法处理。在processReceived方法里又调用了StartReceive:处理完接收后再次进行数据接收,形成一个循环。注:一个Socket中的 receive 和send 最好分别对应一个SocketAsyncEventArgs,当同一个SocketAsyncEventArgs挂起后再调用receiveAsync 或者 SendAsync方法时会抛出异常。

UDPSendSocket

  负责发送数据包给客户端。
一次.net Socket UDP编程的10万客户端测试记录代码

 

SocketAsyncEventArgsPoolBufferManager 是MSDN上的示例。在Init()方法里初始化一定数量的SocketAsyncEventArgs对象,发送数据时从对象池中取出一个SocketAsyncEventArgs完成发送后再将其放回池中。使用对象池的好处就是不用反复创建SocketAsyncEventArgs对象减少消耗。

UdpServer

  主要负责对UdpReveivedSocket 和UdpSendSocket进行封装,初始化一些对象,并以事件方式提供数据接收和发送的处理。
一次.net Socket UDP编程的10万客户端测试记录代码

 

在communicationRec_OnDataReceived事件里,接收到客户端的数据后立刻向数据的发送数据。其实可以将数据的发送独立开来,在listen_OnDataReceived里记录远程的客户端信息(例如:EndPoint队列),然后通过 communicationSend.Send()进行数据的发送出去。

控制台代码

  直接上代码
一次.net Socket UDP编程的10万客户端测试记录代码

 

Interlocked.Increment以原子的方式进行递增操作,这样我们就可知道当前每秒的新客户连接数和收发数据数了。定期执行DrawDisplay方法,显示数据信息。

测试用客户端

  客户端的设计和UdpSendSocket很像,为了模拟大量的套接字,每个套接字使用不同的端口循环向服务器端发送数据包(为了简便操作这里没有设计客户端的数据接收)。比较麻烦的事Socket是很耗资源的,而且系统的端口数也有限(65535),这给我后面的测试多少带来些麻烦。
一次.net Socket UDP编程的10万客户端测试记录代码

 


测试

  本次的测试目标是:10万个客户端和服务器程序通讯时的运行情况。因为每台电脑的端口有限最大也就65535 ,而且我们也不可能开到这么多个套接字,所以我就在不同的机器上运行了上面的测试用客户端程序。
  测试环境:局域网。
  服务器端程序运行环境:Win7 操作系统、2GB内存、CPU:P core E5200 2.50GHz。
     客户端环境:3台电脑、一台win7 两台Win2003。
运行服务器端程序设置两个端口,并设定最大的客户端数为110000。下面是客户端没有发送数据时的计数器截图
一次.net Socket UDP编程的10万客户端测试记录
  接下来就是在各台电脑上奔走,运行客户端的测试程序向服务器发送数据包。为了加快并发数,实际上我实在每台电脑上运行多个客户端程序。下图是在客户端连接数到达6万时的计数器情况。
一次.net Socket UDP编程的10万客户端测试记录
对比两张图片可以看出Private Bytes 和 Virtual Bytes 即 Handle Count 有所上升。Context Switches线程间的切换开销变大很多。接下来看看连接数上升到9万时的情况。
一次.net Socket UDP编程的10万客户端测试记录
  Private Bytes还在慢慢上升当中,难道有Memory Leak!最后再来一张客户端数达到10万时的计数器截图
一次.net Socket UDP编程的10万客户端测试记录
  整个过程中Handle Count 和Private Bytes总在上升当中(也有可能是因为不断的有新来的客户端加入的原因),程序可能有Handle Leak和Memory Leak。

UdpSocketAsyncEventArgs.rar




本文转自94cool博客园博客,原文链接:http://www.cnblogs.com/94cool/archive/2012/07/16/2594154.html,如需转载请自行联系原作者

上一篇:KVM虚拟化主机HA功能实践


下一篇:基础为重,Python的基础,成就月薪过万