C# SocketHelper 源码

玄机论坛Socket类库源码+Demo

本类库采用C# TcpLister,TcpClient高度封装,
采用C# NetworkStream进行异步模式读取数据.
采用C# Semaphore来进行并发控制,
 
我使用的是同步方式连接,海量数据并发不是靠异步就能解决的问题,在对学习Socket和想快速使用Socket的朋友来说,同步是很好的选择.
使用IOCP的Socket类正在测试阶段,稳定,排除BUG后一样会分享给大家.
可同时接受5000+连接同时访问,而CPU消耗完全忽略不计..
本着代码简洁,简单.通俗易懂的原则,进行代码封装,不像其他通信框架写很多各式各样的接口.对新手朋友和刚接触通信程序的朋友带来很大的困扰.
本代码完全开源,但请保留署名,以示尊重.!

下面我和大家一起来分享这个类库的使用方式.

服务端的调用

先来看下服务端的界面
<ignore_js_op> 
第一个列表框用来获取服务端状态信息.
第二个列表框用来获取客户端发来的消息.
一个下来列表框来记录客户端上线.边上的0来记录当前连接数

界面非常简洁,咱们来看类库的使用方式.

第一步,引入命名空间

当引用xuanjiSocket类库以后,请添加

[C#]  纯文本查看 复制代码

?

1	using XuanJiSocket;

添加服务端类.如果没有引入命名空间,那么可以将鼠标光标置于类变量中,按快捷键 Shift + Alt + F10 自动引入类库命名空间

[C#]  纯文本查看 复制代码

?

1	SocketHelper.TcpServer server;

 

[C#]  纯文本查看 复制代码

?

1 2 3 4 5

private void ServerDemo_Load( object sender, EventArgs e)        {            server = new SocketHelper.TcpServer(); //初始化变量                   }

在窗体加载事件中,完成对server变量的初始化.

SocketHelper.pushSockets = new SocketHelper.PushSockets(Rec);

这是本类非常重要的委托变量. 
它的作用就是推送所有信息.!请在Start前对其初始化.!

[C#]  纯文本查看 复制代码

?

1 2 3

private void Rec(SocketHelper.Sockets sks)          {          }

这是处理推送器消息的方法.!

SocketHelper.Sockets

大家可以看下这个自定义对象

[C#]  纯文本查看 复制代码

?

01 02 03 04 05 06 07 08 09 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54

/// <summary>         /// 自定义Socket对象         /// </summary>         public class Sockets         {             /// <summary>             /// 接收缓冲区             /// </summary>             public byte [] RecBuffer = new byte [8 * 1024];              /// <summary>             /// 发送缓冲区             /// </summary>             public byte [] SendBuffer = new byte [8 * 1024];             /// <summary>             /// 异步接收后包的大小             /// </summary>             public int Offset { get ; set ; }             /// <summary>             /// 空构造             /// </summary>             public Sockets() { }             /// <summary>             /// 创建Sockets对象             /// </summary>             /// <param name="ip">Ip地址</param>             /// <param name="client">TcpClient</param>             /// <param name="ns">承载客户端Socket的网络流</param>             public Sockets(IPEndPoint ip, TcpClient client, NetworkStream ns)             {                 Ip = ip;                 Client = client;                 nStream = ns;             }             /// <summary>             /// 当前IP地址,端口号             /// </summary>             public IPEndPoint Ip { get ; set ; }             /// <summary>             /// 客户端主通信程序             /// </summary>             public TcpClient Client { get ; set ; }             /// <summary>             /// 承载客户端Socket的网络流             /// </summary>             public NetworkStream nStream { get ; set ; }             /// <summary>             /// 发生异常时不为null.             /// </summary>             public Exception ex { get ; set ; }             /// <summary>             /// 新客户端标识.如果推送器发现此标识为true,那么认为是新的连接             /// </summary>             public bool NewClientFlag { get ; set ; }         }

每个属性都有注释,来解释这个属性的作用..具体处理细节.请下载demo阅读
上面那些信息绝非无用,而是整个类的重中之重以及消息处理方式.

启动类库,并开始监听

 

[C#]  纯文本查看 复制代码

?

1 2	server.InitSocket(IPAddress.Any, 9527); //监听所有地址,监听端口为9527                  server.Start(); //启动服务端

之前在窗体加载时已经初始化过变量,现在直接使用它的InitSocket来配置服务端.使用Start方法启动监听.!
默认调用后便认为监听成功.!
如若其他情况,例如异常时： 会推送监听失败消息至服务端Rev方法中.具体参阅源码.

停止服务端

直接调用Stop方法即可停止服务端.Stop方法调用后,可继续启动服务端.!
至此,服务端的描述就介绍完了,使用非常简单,
你要做的就下面几件事：
                                               1 、 声明服务端变量。
                                               2 、 初始化推送器。
                                               3 、 配置服务端。
                                               4 、 启动服务端

服务端发送信息

服务端有两个自带方法
                    

[C#]  纯文本查看 复制代码

?

1	server.SendToAll( "服务端消息:[url=http://www.msdn5.com]www.msdn5.com[/url] 随机消息:" +Guid.NewGuid().ToString());//直接发送字符串

该方法将会对所有连接至服务端的客户端发送消息.如果在发送中客户端下线或发生异常,服务端将维护客户端集合 ClientList
ClientList  会在客户端接入时添加.如果发生异常等情况会自动删除

[C#]  纯文本查看 复制代码

?

1	SendToClient(IPEndPoint ip, string SendData);

像单独某位客户发起数据.
当客户端连接时,除去ClientList会自动维护列表外,也会将客户端推送至UI界面,供大家组合自己想要的客户端列表.详细请阅读demo

客户端介绍

<ignore_js_op> 
客户端与服务端一样,需要先声明客户端变量,

[C#]  纯文本查看 复制代码

?

1	SocketHelper.TcpClients client; //声明客户端变量 与服务端一样在窗体加载时初始化.

接着初始化推送器,

[C#]  纯文本查看 复制代码

?

1	SocketHelper.pushSockets = new SocketHelper.PushSockets(Rec); //在窗体加载时初始化推送器

配置客户端,启动客户端.

[AppleScript]  纯文本查看 复制代码

?

1 2	client.InitSocket ( ip , int.Parse ( port ) ) ; / / IP地址支持字符串类型                 client.Start ( ) ;

客户端发送方法,与服务端一致.调用Send方法.调用Start方法来连接服务器,调用Stop方法断开连接.支持断开后重新连接服务端


最后来一张运行时的截图吧
<ignore_js_op> 

运行截图.jpg (250.42 KB, 下载次数: 6)

 

 

 

Demo + 类库下载地址：

 

玄机论坛Socket类库源码 当前版本 2.6.3 更新日期：10-09/2015
http://bbs.msdn5.com/thread-27-1-1.html
(出处: C#论坛-玄机论坛-C#论坛-玄机宝盒-玄机类库-C#)