在我正在处理的应用程序中，我想断开试图向我发送过大数据包的客户端。 在断开连接之前，我想向他们发送一条消息，告知他们断开连接的原因。

我遇到的问题是客户端无法接收此服务器消息，如果服务器没有读取客户端首先发送给他的所有内容。我不明白为什么会这样。

我已经设法将其缩小到一个非常小的测试设置，在该设置中证明了问题。

StreamUtil 类是一个简单的包装类，有助于解决 TCP 消息边界问题，基本上在发送方它首先发送每条消息的大小，然后发送消息本身，在接收方它接收大小首先是消息，然后是消息。

客户端使用 ReadKey 命令模拟发送和接收之间的某个时间，在我的实际应用程序中看到这两个 Action 也不是立即背靠背。

这是一个有效的测试用例:

1. 如下所示运行服务器
2. 如下图所示运行客户端，它会显示“按键信息”，等待不要按键
3. 关闭服务器，因为一切都已经在客户端接收缓冲区中了(我使用数据包嗅探器验证了这一点)
4. 在客户端按下 key -> 客户端正确显示来自服务器的消息。

这是我所期待的，到目前为止还没有问题。

现在在服务器代码中，注释掉第二个接收调用并重复上述步骤。 步骤 1 和 2 成功完成，从客户端发送到服务器没有错误。 然而，在第 3 步，客户端在从服务器读取时崩溃，即使服务器回复已到达客户端(再次使用数据包嗅探器验证)。

如果我在不关闭服务器上的套接字的情况下执行部分关闭(例如 socket.Shutdown (...send...))，一切正常。

1:我无法理解为什么不在服务器上处理来自客户端的文本行会导致客户端无法接收从服务器发回的文本。

2:如果我将内容从服务器发送到客户端，但在实际关闭套接字之前停止了服务器，则该内容永远不会到达，但字节已经传输到服务器端...(请参阅服务器中的 ReadKey 进行模拟，基本上我会阻塞在那里然后退出服务器)

如果有人能阐明这两个问题，我将不胜感激。

客户:

class TcpClientDemo
{
    public static void Main (string[] args)
    {
        Console.WriteLine ("Starting....");
        TcpClient client = new TcpClient();

        try
        {
            client.Connect("localhost", 56789);

            NetworkStream stream = client.GetStream();

            StreamUtil.SendString(stream, "Client teststring...");

            Console.WriteLine("Press key to initiate receive...");
            Console.ReadKey();

            Console.WriteLine("server reply:" + StreamUtil.ReceiveString(stream));
        }
        catch (Exception e)
        {
            Console.WriteLine(e.Message);
        }
        finally
        {
            client.Close();
        }

        Console.WriteLine("Client ended");
        Console.ReadKey(true);
    }

}

服务器:

class TcpServerDemo
{
    public static void Main (string[] args)
    {
        TcpListener listener = new TcpListener (IPAddress.Any, 56789);
        listener.Start ();
        Console.WriteLine ("Waiting for clients to serve...");

        while (true)
        {
            TcpClient client = null;
            NetworkStream stream = null;

            try
            {
                client = listener.AcceptTcpClient();
                stream = client.GetStream();

                //question 1: Why does commenting this line prevent the client from receiving the server reply??
                Console.WriteLine("client string:" + StreamUtil.ReceiveString(stream));

                StreamUtil.SendString(stream, "...Server reply goes here...");

                //question 2: If I close the server program without actually calling client.Close (while on this line), the client program crashes as well, why?
                //Console.ReadKey();
            }
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
                break;
            }
            finally
            {
                if (stream != null) stream.Close();
                if (client != null) client.Close();
                Console.WriteLine("Done serving this client, everything closed.");
            }
        }

        listener.Stop();
        Console.WriteLine("Server ended.");
        Console.ReadKey(true);
    }

}

流工具:

public class StreamUtil
{

    public static byte[] ReadBytes (NetworkStream pStream, int byteCount) {
        byte[] bytes = new byte[byteCount];
        int bytesRead = 0;
        int totalBytesRead = 0;

        try {
            while (
                totalBytesRead != byteCount && 
                (bytesRead = pStream.Read (bytes, totalBytesRead, byteCount - totalBytesRead)) > 0
            ) {
                totalBytesRead += bytesRead;
                Console.WriteLine("Read/Total:" + bytesRead + "/" + totalBytesRead);
            }
        } catch (Exception e) {
            Console.WriteLine(e.Message);
        }

        return (totalBytesRead == byteCount) ? bytes : null;
    }

    public static void SendString (NetworkStream pStream, string pMessage) {
        byte[] sendPacket = Encoding.ASCII.GetBytes (pMessage);
        pStream.Write (BitConverter.GetBytes (sendPacket.Length), 0, 4);
        pStream.Write (sendPacket, 0, sendPacket.Length);
    }

    public static string ReceiveString (NetworkStream pStream) {
        int byteCountToRead = BitConverter.ToInt32(ReadBytes (pStream, 4), 0);
        Console.WriteLine("Byte count to read:"+byteCountToRead);
        byte[] receivePacket = ReadBytes (pStream, byteCountToRead);

        return Encoding.ASCII.GetString (receivePacket);
    }

}

最佳答案

1. 客户端失败，因为它检测到套接字已经关闭。
2. 如果 C# 套接字操作在之前的操作中检测到​​一个关闭的连接，则会在下一个操作中抛出异常，该异常可以屏蔽本来会收到的数据

当连接在读取之前/期间关闭时，StreamUtil 类会做一些事情:

• 读取异常被吞没
• 不处理读取零字节

当意外关闭击中客户端时，这些混淆了正在发生的事情。

编辑

我在您的示例中遗漏了一些微妙的东西 - 您的第一个示例导致服务器关闭连接后立即发送 TCP RST 标志，因为套接字已关闭且数据等待读取。

RST 标志会导致不保留未决数据的关闭。

This blog基于非常相似的场景(网络服务器发送 HTTP 错误)进行了一些讨论。

所以我认为没有简单的解决方法，选项是:

• 正如您已经尝试过的那样，在关闭之前关闭服务器上的套接字以强制在 RST 之前发送 FIN
• 读取有问题的数据但从不处理它(无故占用带宽)

关于c# - 如果服务器在从客户端读取所有内容之前发送，为什么我的 C# TcpClient 无法从服务器接收内容？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/37856807/