从关闭的 NetworkStream 读取不会导致任何异常

我正在尝试创建一个相当简单的客户端服务器应用程序，但为了进行通信，我想使用二进制序列化对象。通信本身看起来相当不错，但是当我关闭客户端的流时，服务器并没有真正注意到它并继续尝试读取流。

服务器端（Server 类，在单独的线程中执行）：

监听连接

listener = new TcpListener(IPAddress.Parse("127.0.0.1"), this.Port);
listener.Start();
while (!interrupted)
{
    Console.WriteLine("Waiting for client");
    TcpClient client = listener.AcceptTcpClient();
    AddClient(client);
    Console.WriteLine("Client connected");
}

添加客户端：

    public void AddClient(TcpClient socket)
    {
        Client client = new Client(this, socket);
        this.clients.Add(client);
        client.Start();
    }

监听消息（在 Client 类深处）：

BinaryFormatter deserializer = new BinaryFormatter();
while (!interrupted)
{
    System.Diagnostics.Debug.WriteLine("Waiting for the message...");
    AbstractMessage msg = (AbstractMessage)deserializer.Deserialize(stream);
    System.Diagnostics.Debug.WriteLine("Message arrived: " + msg.GetType());
    raiseEvent(msg);
}

单元测试：

Server server = new Server(6666);
server.Start();

Thread.Sleep(500);

TcpClient client = new TcpClient("127.0.0.1", 6666);
var message = new IntroductionMessage();
byte[] arr = message.Serialize();

client.GetStream().Write(arr, 0, arr.Length);

Thread.Sleep(500);

Assert.AreEqual(1, server.Clients.Count);

client.GetStream().Close();
client.Close();

Thread.Sleep(1000);

Assert.AreEqual(0, server.Clients.Count);

server.Stop();

所以消息被正确读取，但是，当我关闭流时， deserializer.Deserialize(stream) 似乎不会抛出任何异常...所以应该不以这种方式读取，还是应该关闭客户端另一种方式？

假设服务器中用于反序列化消息的流是网络流 http://msdn.microsoft.com/en-us/library/system.net.sockets.networkstream.aspx（这是返回的流的类型TcpClient.GetStream()），你应该做两件事：

1. 为“连接结束”定义特定消息。当服务器接收并反序列化该消息时，退出 while 循环。为了实现这一点，客户端显然需要在关闭其 TcpClient 连接之前发送这样的消息。 （您可以选择以类似方式工作的不同机制 - 但为什么不使用您已有的消息机制......）

2. Set a 读取超时 on the 网络流，因此，如果连接丢失并且客户端无法发送“连接结束”消息，服务器将超时并意识到客户端已“死亡”。

服务器中用于侦听客户端消息的代码应类似于以下内容：

//
// Time-out after 1 minute after receiving last message
//
stream.ReadTimeOut = 60 * 1000;

BinaryFormatter deserializer = new BinaryFormatter();

try
{
    while (!interrupted)
    {
        System.Diagnostics.Debug.WriteLine("Waiting for the message...");
        AbstractMessage msg = (AbstractMessage)deserializer.Deserialize(stream);
        System.Diagnostics.Debug.WriteLine("Message arrived: " + msg.GetType());

        //
        // Exit while-loop when receiving a "Connection ends"  message.
        // Adapt this if condition to whatever is appropriate for
        // your AbstractMessage type.
        //
        if (msg == ConnectionEndsMessage) break;

        raiseEvent(msg);
    }
}
catch (IOException ex)
{
    ... handle timeout and other IOExceptions here...
}