如何在 C# 中在不关闭 NetworkStream 的情况下发出数据结束信号

Question

我有一个将对象序列化并将其发送到服务器应用程序的客户端应用程序。服务器应该反序列化对象，对其进行更改，然后将其序列化并发送回。

服务器代码：

TcpClient client = server.AcceptTcpClient();
using(NetworkStream stream = client.GetStream())
{
    using(StreamReader streamReader = new StreamReader(stream))
    {
       string xmlData = streamReader.ReadToEnd();
    }
}

除非客户端关闭流，否则 ReadToEnd 不会返回。但是如果客户端关闭流，我就无法发送响应。

有没有更好的方法来做到这一点？

Answer 1

您可以通过仅关闭一半的双工 TCP 连接来发出“数据结束”的信号。这是通过Socket.Disconnect 完成的。

看看这个例子是如何工作的，我和你的例子很相似。客户端发送数据，然后调用Disconnect；这允许ReadToEnd 返回同时仍保持服务器的一半连接打开。然后服务器发送响应并断开连接，之后双方可以Close结束连接以将其断开。

static void Main(string[] args)
{
    Action clientCode = () =>
        {
            var buffer = new byte[100];
            var clientSocket = new Socket(AddressFamily.InterNetwork,
                                          SocketType.Stream, ProtocolType.Tcp);
            clientSocket.Connect(IPAddress.Loopback, 6690);
            clientSocket.Send(buffer);
            clientSocket.Disconnect(false);
            Console.WriteLine("Client: message sent and socket disconnected.");
            while (true) {
                var bytesRead = clientSocket.Receive(buffer);
                if (bytesRead == 0) {
                    break;
                }

                Console.WriteLine("Client: read " + bytesRead + " bytes.");
            }

            clientSocket.Dispose();
        };

    var server = new TcpListener(IPAddress.Loopback, 6690);
    var thread = new Thread(new ThreadStart(clientCode));
    server.Start();
    thread.Start();
    var client = server.AcceptTcpClient();

    using(NetworkStream stream = client.GetStream()) {
        using(StreamReader streamReader = new StreamReader(stream))
        {
            var data = streamReader.ReadToEnd();
            Console.WriteLine("Server: read " + data.Length + " bytes.");

            // Since we 're here we know that the client has disconnected.
            // Send the response before StreamReader is disposed, because
            // that will cause the socket itself to be closed as well!
            Thread.Sleep(TimeSpan.FromSeconds(1));
            Console.WriteLine("Server: sending response.");
            stream.Write(new byte[10], 0, 10);
            Console.WriteLine("Server: closing socket.");
        }
    }

    server.Stop();
    Console.WriteLine("Server: waiting for client thread to complete.");
    thread.Join();


    return;
}

Answer 2

您可以使用更高级别的框架，例如 WCF，或者如果您一心想要管理自己的流，则不要使用 ReadToEnd() - 使用 ReadLine()（并让客户端以行的形式发送消息），或使用 Read() 并使用特殊字符（sentinel）表示消息的结束。