首页 > 其他 > 详细

C#高性能大容量SOCKET并发(零):代码结构说明

时间:2014-04-08 05:30:20      阅读:598      评论:0      收藏:0      [点我收藏+]

C#版完成端口具有以下特点:

  • 连接在线管理(提供在线连接维护,连接会话管理,数据接收,连接断开等相关事件跟踪);
  • 发送数据智能合并(组件会根据资源使用情况,对多个同时发送向同一连接的多个消息数据进行合并写入缓冲区;
  • 内存池管理(提供一系列的接收和发送buffer可复用池);
  • 数据读写封装;
  • 通讯协议封装;

由不同的类负责实现,比MSDN的例子代码多了不少逻辑,为了方便大家阅读和理解,把整体类框架设计整体如下。

类结构图

bubuko.com,布布扣

类说明

  1. AsyncSocketServer:服务入口,建立Socket监听,负责接收连接,绑定连接对象,处理异步事件返回的接收和发送事件;m_asyncSocketUserTokenPool是管理所有空闲的AsyncSocketUserToken,采用栈的管理方式,后进先出;m_asyncSocketUserTokenList是管理所有正在执行的AsyncSocketUserToken,是一个列表;m_logOutputSocketProtocolMgr是LogOutputSocketProtocol的管理对象;m_uploadSocketProtocolMgr是UploadSocketProtocol的管理对象,用于检测是否同时上传同一个文件;m_downloadSocketProtocolMgr是DownloadSocketProtocol的管理对象;m_daemonThread是守护进程,用于关闭超时连接。
  2. AsyncSocketUserToken:用于SocketAsyncEventArgs绑定,保存每个Socket服务对象,包括:m_receiveEventArgs接收数据异步事件;m_asyncReceiveBuffer接收数据异步事件使用的缓存;m_sendEventArgs发送数据异步事件;m_receiveBuffer接收异步事件返回的数据存放缓存,用于后续的分包;m_sendBuffer用于保存发送的数据缓存;m_asyncSocketInvokeElement是用于协议调用的基类,主要实现分包,并发发送的包加到发送列表中,发送完成回调时继续发送下一个包;m_connectSocket是连接的Socket对象。
  3. AsyncSocketInvokeElement:用于协议调用的基类,主要实现分包,并发发送的包加到发送列表中,发送完成回调时继续发送下一个包,包括:m_incomingDataParser用于分析接收到的数据包,把协议解析出命令、关键字、数据,并存储到列表中;m_outgoingDataAssembler用于组装需要发送的数据,把命令、关键字、数据组成符合协议格式的数据,并存储在列表中。
  4. BaseSocketProtocol是所有协议的基类,把一些公共的方法放在这里,后续的ControlSocketProtocol、DownloadSocketProtocol、LogOutputSocketProtocol、RemoteStreamSocketProtocol、ThroughputSocketProtocol、UploadSocketProtocol都从这里继承。

C#高性能大容量SOCKET并发(零):代码结构说明,布布扣,bubuko.com

C#高性能大容量SOCKET并发(零):代码结构说明

原文:http://blog.csdn.net/sqldebug_fan/article/details/23092673

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!