正确的方法来停止TcpListener

Question

我目前正在使用TcpListener来处理传入的连接,每个连接都有一个用于处理通信的线程,然后关闭该单个连接.代码如下:

TcpListener listener = new TcpListener(IPAddress.Any, Port);
System.Console.WriteLine("Server Initialized, listening for incoming connections");
listener.Start();
while (listen)
{
     // Step 0: Client connection
     TcpClient client = listener.AcceptTcpClient();
     Thread clientThread = new Thread(new ParameterizedThreadStart(HandleConnection));
     clientThread.Start(client.GetStream());
     client.Close();
}

该listen变量是一个布尔值,是在类的字段.现在,当程序关闭时,我希望它停止监听客户端.设置听false会阻止它承担更多的连接,但由于AcceptTcpClient是一个阻塞调用,它将在最低采取下一个客户端,然后退出.有没有办法迫使它简单地突破并停止,就在那时？调用listener.Stop()有什么影响,而另一个阻塞调用正在运行？

Answer 1

鉴于代码我有两个建议,我认为是你的设计.但是,我想首先指出在使用I/O(如网络或文件系统)时应该使用非阻塞I/O回调.这是迄今为止FAR更高效,应用程序将工作好了很多,虽然他们难以编程.我将在最后简要介绍一下建议的设计修改.

1. 对TcpClient使用Using(){}
2. Thread.Abort的()
3. TcpListener.Pending()
4. 异步重写

对TcpClient使用Using(){}

***请注意,您应该将您的TcpClient调用封装在using(){}块中,以确保即使在发生异常时也调用TcpClient.Dispose()或TcpClient.Close()方法.或者你可以将它放在try {} finally {}块的finally块中.

Thread.Abort的()

我认为你可以做两件事.1如果你从另一个线程启动了这个TcpListener线程,你可以简单地在线程上调用Thread.Abort实例方法,这将导致在阻塞调用中抛出threadabortexception并向上移动堆栈.

TcpListener.Pending()

第二个低成本修复是使用listener.Pending()方法来实现轮询模型.然后,您将在查看新连接是否挂起之前使用Thread.Sleep"等待".一旦你有一个挂起的连接,你就会调用AcceptTcpClient,这将释放挂起的连接.代码看起来像这样.

while (listen){
     // Step 0: Client connection
     if (!listener.Pending())
     {
          Thread.Sleep(500); // choose a number (in milliseconds) that makes sense
          continue; // skip to next iteration of loop
     }

     TcpClient client = listener.AcceptTcpClient();
     Thread clientThread = new Thread(new ParameterizedThreadStart(HandleConnection));
     clientThread.Start(client.GetStream());
     client.Close();
}

异步重写

最后,我建议您真正转向应用程序的非阻塞方法.在框架下,框架将使用重叠I/O和I/O完成端口来实现异步调用的非阻塞I/O. 它也不是非常困难,只需要稍微考虑一下你的代码.

基本上,您可以使用BeginAcceptTcpClient方法启动代码,并跟踪返回的IAsyncResult.你指出一个方法,它负责获取TcpClient并将其传递给一个新的线程,而不是传递给ThreadPool.QueueUserWorkerItem的一个线程,这样你就不会为每个客户端请求启动并关闭一个新线程(注意你如果您有特别长时间的请求,则可能需要使用您自己的线程池,因为线程池是共享的,如果您独占所有线程,则系统实现的应用程序的其他部分可能会被饿死.一旦侦听器方法将新的TcpClient启动到它自己的ThreadPool请求,它再次调用BeginAcceptTcpClient并将委托指向自身.

实际上,您只是将当前的方法分解为3种不同的方法,然后由各个部分调用.1.引导一切,2.成为调用EndAcceptTcpClient的目标,启动TcpClient到它自己的线程然后再调用自己,3.处理客户端请求并在完成后关闭它.

Answer 2

listener.Server.Close() 从另一个线程打破阻塞调用.

A blocking operation was interrupted by a call to WSACancelBlockingCall