多线程的正确实现套接字应用程序

Question

我有一个服务器和一个客户端应用程序，以下是它当前的实现方式：服务器在其自己的线程中有一个循环，它通过 TcpListener 侦听新连接。如果有人连接，它会将 TcpClient 传递到专门侦听该 TcpClient 的循环，并通过 NetworkStream 处理与该用户的所有交互。

在客户端上，我有一个连接到服务器的 TcpClient。据我了解，我需要将其分支到不同的线程，因为任何 IO 都会将其置于阻塞模式，并且我不能让它停止主线程。

到目前为止，我的理解正确吗？是否有一种更简单的方法来确保异步通信而不停止任一程序的主线程？

无论哪种方式，对于我的主要问题：如何确保所有这些线程和套接字都得到正确处理？如果程序在仍处于阻塞模式时退出，则它似乎会冻结。那么我如何中止套接字上的所有 IO 并告诉子线程中的无限循环我们已经完成了？

顺便说一句，这也是一个 Unity3d 项目，以防发生任何变化。

Answer 1

将每个新连接移交给其自己的线程可能会限制您的可扩展性。此外，没有理由要求客户端中的 I/O 线程切换。

您可以使用异步 I/O 解决这两个问题。 BeginConnect/EndConnect 在客户端，BeginRead/EndRead、BeginWrite/EndWrite 在服务器端进行读写。

然后一切都可以由事件驱动，而不需要您自己的新线程。连接完成首先触发异步读取，然后每个读取完成都会在该套接字上发布一个新的异步读取调用 - 无论如何，写入始终是由您的 POV 确定的。

关闭套接字将导致挂起的读/写退出并出现错误，然后您应该能够干净地退出进程。请注意，您要实施适当的锁定（可能 lock() 就可以满足您的需要），以确保套接字在关闭后不会在任何地方使用。

Answer 2

您应该有两个单独的线程，一个用于 TcpListener，另一个用于单独运行的 TcpClient。初始化新线程时，使其 IsBackground 属性设置为 true，这样如果应用程序终止，它也会终止。

Thread listenerThread = new Thread(ListenerLoop);
listenerThread.IsBackground = true;
listernerThread.Start();

如果您使用 4.0 或 ThreadPool.QueueUserWorkItem 代替线程，则可以使用 Task。