1

我有一个运行良好的客户端/服务器应用程序，但是它缺少一个关键的行为来使它更可靠。

目前，就网络能力而言，它远非“强大”。我正在努力实现它，研究使我相信我需要某种协议来确保在网络传输过程中不会丢失任何数据。

我听说过几种方法。我认为最适合我们情况的一种方法是使用终止符，例如<EOF>标签。我的问题是我不确定实现这一点的最佳方法。

在找出最佳解决方案后，我将修改几个代码片段以包含终止符。

客户：

TcpClient client = new TcpClient();

client.Connect(hostname, portNo);

using (var stream = client.GetStream())
{
    //send request

    stream.Write(data, 0, data.Length);
    stream.Flush();

    //read server response

    if (stream.CanRead)
    {
        byte[] buffer = new byte[1024];
        string response = "";
        int bytesRead = 0;

        do
        {
            bytesRead = stream.Read(buffer, 0, buffer.Length);

            response += Encoding.ASCII.GetString(buffer, 0, bytesRead);

        } //trying to replace 'DataAvailable', it doesn't work well
        while (stream.DataAvailable); 
    }
}

请注意，我正在尝试替换stream.DataAvailable在流中检查更多数据的方法。它一直在造成问题。

服务器：

var listener = new TcpListener(IPAddress.Any, portNo);

listener.Start();

var client = listener.AcceptTcpClient();

using (var stream = client.GetStream())
{
    var ms = new System.IO.MemoryStream();

    byte[] buffer = new byte[4096];
    int bytesRead = 0;

    do
    {
        bytesRead = stream.Read(buffer, 0, buffer.Length);

        ms.Write(buffer, 0, bytesRead);

    } //also trying to replace this 'stream.DataAvailable'
    while (stream.DataAvailable);

    ms.Position = 0;

    string requestString = Encoding.UTF8.GetString(ms.ToArray());

    ms.Position = 0;

    /*
        process request and create 'response'
    */

    byte[] responseBytes = Encoding.UTF8.GetBytes(response);

    stream.Write(responseBytes, 0, responseBytes.Length);
    stream.Flush();
}

那么，给定这两个代码示例，我如何修改它们以包含并检查某种数据终止符，表明停止读取数据是安全的？

4

2 回答 2

0

您可以依靠 TCP 传输 FIN 之前的所有数据。您的代码的问题是 available() 不是流结束的有效测试。这是对现在可用数据的测试。

所以你过早地终止了你的阅读循环，因此在接收器处丢失了数据，并在发送器处得到了重置。

在从 API 收到 EOS 指示之前，您应该阻塞 Read() 方法，无论 C# 中的内容是什么。

您不需要自己的额外 EOS 指标。

于 2013-10-28T22:31:57.700 回答
0

我们最终在项目的两端都使用了 EOS（流结束）指示器。我不会发布完整的代码示例，但这里有一小段它是如何工作的：

stream.Write(data, 0, data.Length);
stream.WriteByte(Convert.ToByte(ConsoleKey.Escape));
stream.Flush();

在此流的接收端，循环逐字节读取数据。一旦它接收到ConsoleKey.Escape字节，它就会终止循环。有用！

于 2013-10-31T17:13:23.147 回答