C使用异步Socket编程实现TCP网络服务的CS的通讯构架基础类库部分doc(完整版).doc

在 C#中使用异步 Socket 编程实现 TCP 网络服务的 C/S 的通讯构架(一)----基础

类库部分

///////////////////////////////////////////////////////////////////////////////////

但是使用之后发现它们的力量太单薄了,我们需要一个更好的类库来替代它们.

下面提供了一些类,可以很好的完成 Tcp 的 C/S 通讯模式.在本文的第二部分,我将为大

家介绍怎么使用它们

主要通过事件来现实整个的功能:

服务器的事件包括:

服务器满

新客户端连接

客户端关闭

接收到数据

我的鼓励和支持.

*/

///////////////////////////////////////////////////////////////////////////////////

///////

/// <summary>

/// (C)2003-2005 C2217 Studio

/// 保留所有权利

///

/// 文件名称: TcpCSFramework.cs

/// 文件 ID:

///

/// 作者: 邓杨均

/// EMail: dyj057@gmail

/// 创建日期: 2005-3-9

/// 最后修改日期: 2005-3-17

///

/// 历史修改记录:

///

/// 时间: 2005-3-14

/// 修改内容:

/// 1.创建 Ibms.Net.TcpCSFramework 命名空间和添加 Session 对象.

/// 需要调用 Socket.Shutdown( SocketShutdown.Both )后才调用

/// Socket.Close()方法,而不是直接的调用 Socket.Close()方法,

/// 如果那样调用将产生强制退出类型.

///

/// 时间: 2005-3-16

/// 修改内容:

/// 1.创建 TcpCli,Coder,DatagramResover 对象,把抽象和实现部分分离

/// 2.文件版本修改为 1.1,1.0 版本仍然保留,更名为:

/// TcpCSFramework_vs

/// 3.在 TcpServer 中修改自定义的 hashtable 为系统 Hashtable 类型

using System.Diagnostics;

using System.Collections;

namespace Ibms.Net.TcpCSFramework

{

/// <summary>

/// 网络通讯事件模型委托

/// </summary>

public delegate void NetEvent(object sender, NetEventArgs e);

/// <summary>

/// 替换版本: 1.0

/// 1.使用 hash 表保存所有已连接客户端的状态，收到数据时能实现快速查找.每当

/// 有一个新的客户端连接就会产生一个新的会话(Session).该 Session 代表了客

/// 2.使用异步的 Socket 事件作为基础，完成网络通讯功能.

/// 3.支持带标记的数据报文格式的识别,以完成大数据报文的传输和适应恶劣的网

/// 络环境.初步规定该类支持的最大数据报文为 640K(即一个数据包的大小不能大于

/// 640K,否则服务器程序会自动删除报文数据,认为是非法数据),防止因为数据报文

/// 无限制的增长而倒是服务器崩溃

/// 5.使用 C# native code,将来出于效率的考虑可以将 C++代码写成的 32 位 dll 来

代替

/// C#核心代码, 但这样做缺乏可移植性,而且是 Unsafe 代码(该类的 C++代码也存

在)

/// 6.可以限制服务器的最大登陆客户端数目

/// 7.比使用 TcpListener 提供更加精细的控制和更加强大异步数据传输的功能,可作

为

/// TcpListener 的替代类

/// 8.使用异步通讯模式,完全不用担心通讯阻塞和线程问题,无须考虑通讯的细节

///

/// 注意:

/// 1.部分的代码由 Rational XDE 生成,可能与编码规范不符

///

/// 原理:

///

///

{

#region 定义字段

/// <summary>

/// 默认的服务器最大连接客户端端数据

/// </summary>

public const int DefaultMaxClient=100;

/// <summary>

/// 接收数据缓冲区大小 64K

/// </summary>

public const int DefaultBufferSize = 64*1024;

/// <summary>

/// 最大数据报文大小

/// <summary>

/// 通讯格式编码解码器

/// </summary>

private Coder _coder;

/// <summary>

/// 服务器程序使用的端口

/// </summary>

private ushort _port;

/// <summary>

/// 服务器程序允许的最大客户端连接数

/// <summary>

/// 接收数据缓冲区

/// </summary>

private byte[] _recvDataBuffer;

/// <summary>

/// 服务器使用的异步 Socket 类,

/// </summary>

private Socket _svrSock;

/// <summary>

/// 保存所有客户端会话的哈希表