开发者社区> 杰克.陈> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

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

简介: 原文:C#高性能大容量SOCKET并发(零):代码结构说明 C#版完成端口具有以下特点: 连接在线管理(提供在线连接维护,连接会话管理,数据接收,连接断开等相关事件跟踪); 发送数据智能合并(组件会根据资源使用情况,对多个同时发送向同一连接的多个消息数据进行合并写入缓冲区; 内存池管理(提供一系列的接收和发送buffer可复用池); 数据读写封装; 通讯协议封装; 由不同的类负责实现,比MSDN的例子代码多了不少逻辑,为了方便大家阅读和理解,把整体类框架设计整体如下。
+关注继续查看
原文:C#高性能大容量SOCKET并发(零):代码结构说明

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

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

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

类结构图


类说明

  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都从这里继承。

DEMO下载地址:http://download.csdn.net/detail/sqldebug_fan/7467745
免责声明:此代码只是为了演示C#完成端口编程,仅用于学习和研究,切勿用于商业用途。水平有限,C#也属于初学,错误在所难免,欢迎指正和指导。邮箱地址:fansheng_hx@163.com。

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
POJ-2524,Ubiquitous Religions(并查集模板题)
POJ-2524,Ubiquitous Religions(并查集模板题)
24 0
C#高性能大容量SOCKET并发(五):粘包、分包、解包
原文:C#高性能大容量SOCKET并发(五):粘包、分包、解包 粘包 使用TCP长连接就会引入粘包的问题,粘包是指发送方发送的若干包数据到接收方接收时粘成一包,从接收缓冲区看,后一包数据的头紧接着前一包数据的尾。
1859 0
C#高性能大容量SOCKET并发(二):SocketAsyncEventArgs封装
原文:C#高性能大容量SOCKET并发(二):SocketAsyncEventArgs封装 1、SocketAsyncEventArgs介绍 SocketAsyncEventArgs是微软提供的高性能异步Socket实现类,主要为高性能网络服务器应用程序而设计,主要是为了避免在在异步套接字 I/O 量非常大时发生重复的对象分配和同步。
2424 0
新浪微博千万级规模高性能、高并发的网络架构经验分享
【本文转载自新浪微博千万级规模高性能、高并发的网络架构经验分享】 架构以及我理解中架构的本质 在开始谈我对架构本质的理解之前,先谈谈对今天技术沙龙主题的个人见解,千万级规模的网站感觉数量级是非常大的,对这个数量级我们战略上要重视它,战术上又要藐视它。 先举个例子感受一下千万级到底是什么数量级?现在很流行的优步(Uber),从媒体公布的信息看,它每天接单量平均在百万左右
3468 0
从零开始_学_数据结构(五)——STL(map、set、list、vector)
STL容器   前注: STL(标准模板库)是一个C++的软件库,也是C++标准程序库的一部分。 这些容器,应该都是STL里面的一个类。 vector封装数组、list封装链表、map和set封装二叉树   一、list 在不懂的时候,list可以理解为双向链表(很像,但事实上不是)。 (1)声明一个list对象: ①包含头文件list:#include<li
1508 0
从零开始_学_数据结构(五)——STL(map、set、list、vector)
STL容器   前注: STL(标准模板库)是一个C++的软件库,也是C++标准程序库的一部分。 这些容器,应该都是STL里面的一个类。 vector封装数组、list封装链表、map和set封装二叉树   一、list 在不懂的时候,list可以理解为双向链表(很像,但事实上不是)。 (1)声明一个list对象: ①包含头文件list:#include<li
2503 0
基于C++的纯面向对象的通用高性能大并发TCP-SERVER/CLIENT开发框架实践系列之基础篇
基于C++的纯面向对象的通用高性能大并发TCP-SERVER/CLIENT开发框架实践系列之基础篇 yijian 2008-12-21 technologier@126.com 1. 前言 本篇主要介绍Servant和Client都会使用到的公共基础,主要包括两大部分:一是对线程相关的封装;另是对Socket相关的封装。
1016 0
+关注
杰克.陈
一个安静的程序猿~
10424
文章
2
问答
文章排行榜
最热
最新
相关电子书
更多
低代码开发师(初级)实战教程
立即下载
阿里巴巴DevOps 最佳实践手册
立即下载
冬季实战营第三期:MySQL数据库进阶实战
立即下载