知识大全 .NET Socket开发之同步Socket实现两例

Posted 2022-07-17 需求

篇首语：赋料扬雄敌，诗看子建亲。本文由小常识网(cha138.com)小编为大家整理，主要介绍了知识大全 .NET Socket开发之同步Socket实现两例相关的知识，希望对你有一定的参考价值。

.NET Socket开发之同步Socket实现两例 以下文字资料是由(全榜网网www.cha138.com)小编为大家搜集整理后发布的内容，让我们赶快一起来看一下吧！

　　今天我们来讲一下在 NET 网络应用程序开发中同步Socket的应用很多人认为在网络应用的服务端Socket不应该使用同步Socket 是的在大多数情况下是这样的但是也有一些场景下我们使用同步Socket可能会得到更的结果如在下面的两种场景下我们便可以考虑使用同步的Socket

　　一客户端数量比较少

　　数量比较少是指会同时连接到服务器的客户端数量一般在人以下这种情况下我们可以考虑使用同步Socket＋Thread来实现我们的服务端这样会让我们编写逻辑更清晰的代码而性能不会下降太多

　　二客户端数量较多但都是短连接

　　短连接是指客户端的连接在处理完一次收发之后就产即断开的场景比如说HTTP协议就是一种短连接 HTTP在客户端发出请求时建立一个Socket连接并通过Socket发出一个URL请求服务端在处理完这个请求并回发相应的页面后便会断开这个连接那么在这种场景下我们也可以使用同步Socket来实现我们的需求

　　那么应该如果实现我上面提到的两种需求呢对于这两种需求我将采用不同的方案来实现它们

　　首先我们来看看第一种需求这里我采用Socket＋Thread来实现基本的流程如下

　　首先创建一个Socket 并且给它绑定一个EndPoint后开始监听接下来我们创建一个线程在这个线程中我们用一个无限循环来接收来自客户端的连接请求在接收到一个请求后为这个客户端创建一个新的线程并且在这个线程中也使用一个无限循环接收来自这个客户端的数据下面让我们来看看代码

　　首先我们创建一个Socket用来侦听客户端的连接

　　Socket listener = new Socket(AddressFamily InterNeork SocketType Stream ProtocolType Tcp); IPEndPoint locEP= new IPEndPoint(IPAddress Any ); listener Bind(locEP); listener Listen( );

　　然后创建一个线程来处理客户端的连接请求

　　Thread acceptThread = new Thread(new ThreadStart(AcceptWorkThread)); acceptThread Start(); private void AcceptWorkThread() Thread CurrentThread IsBackground = true; while (true) Socket accept = listener Accept(); IPEndPoint remoEP = (IPEndPoint)accept RemoteEndPoint; string recString = 接收到来自 + remoEP Address ToString() + 的连接 ; this Invoke(new AddListItemHandler(this AddListItem) new string[] recString ); Thread receiveThread = new Thread(new ParameterizedThreadStart(ReceiveWorkThread)); receiveThread Start(accept);

　　最后我们来看看如何接收数据

　　private void ReceiveWorkThread(object obj) Thread CurrentThread IsBackground = true; Socket socket = (Socket)obj; byte[] buffer = new byte[ ]; while (true) int receiveCount = socket Receive(buffer); if (receiveCount > ) IPEndPoint remoEP = (IPEndPoint)socket RemoteEndPoint; string recString = 来自客户端 + remoEP Address ToString() + 的消息 + Encoding Default GetString(buffer receiveCount); this Invoke(new AddListItemHandler(this AddListItem) new string[] recString ); socket Send(buffer receiveCount SocketFlags None); else socket Close(); break;

　　好了整个实现就完成了

　　现在让我们来看看第二个需求

　　这个方案我们将采用另外一个方法来实现为什么不采用上一个方法来实现呢？让我们来分析一下我们知道在上一个实现中每接入一个客户端就要创建一个线程如果有大量的客户端接入的话就会创建过多的线程但是如果线程过多的话 Windows就需要更多的CPU时间来切换线程的上下文（这也是上一个实现不能接入很多客户端的原因）

　　我们知道在这个方案中每一个连接都是短连接而且顺序都是固定的都是接入 >接收 >发送这样的顺序那么我们就可以在一个方法中完成整个处理这样我们就可以利用线程池来实现我们所需要的好了让我们用代码来说话吧

　　首先我们创建一个Socket用来侦听客户端的连接

　　Socket listener = new Socket(AddressFamily InterNeork SocketType Stream ProtocolType Tcp); IPEndPoint locEP= new IPEndPoint(IPAddress Any ); listener Bind(locEP); listener Listen( );

　　接下来我们要创建一个线程池

　　Thread[] ClientThreadList = new Thread[ ]; foreach (Thread th in ClientThreadList) th = new Thread(new ThreadStart(ClientWorkThread)); th Start();

　　最后让我们看看线程都要做些什么

　　private void ClientWorkThread() byte[] buffer = new byte[ ]; while (true) Socket socket = listener Accept(); string recString = 接收到来自 + remoEP Address ToString() + 的连接 ; this Invoke(new AddListItemHandler(this AddListItem) new string[] recString ); int receCount = socket Receive(buffer); if (receCount> ) string recString = 来自客户端 + remoEP Address ToString() + 的消息 + Encoding Default GetString(buffer receiveCount); this Invoke(new AddListItemHandler(this AddListItem) new string[] recString ); socket Send(buffer receCount SocketFlags None); socket Shutdown(SocketShutdown Both); socket Close();

　　为什么我们要这样做呢？

　　首先我们创建了一个Socket用于侦听客户端的连接请求接下我们创建了一个拥有个线程的线程池并在每个线程中实现了Accept Receive Send和Close（）以完成连接接收发送关闭的操作

cha138/Article/program/net/201311/13321