不是在套接字 C# WP8 中接收到的全部数据

Question

当我收到“小”数据时，下面的代码可以正常工作。 但是当我尝试接收大数据时，它总是被切断。 我收到的数据不完整

static ManualResetEvent _clientDone = new ManualResetEvent(false);

        const int TIMEOUT_MILLISECONDS = 500000000;

        const int MAX_BUFFER_SIZE = 2048;

 public string Receive_msg()
        {
            string response = "Operation Timeout";

            if (_socket != null)
            {
                SocketAsyncEventArgs socketEventArg = new SocketAsyncEventArgs();
                socketEventArg.RemoteEndPoint = _socket.RemoteEndPoint;

                socketEventArg.SetBuffer(new Byte[MAX_BUFFER_SIZE], 0, MAX_BUFFER_SIZE);


                socketEventArg.Completed += new EventHandler<SocketAsyncEventArgs>(delegate(object s, SocketAsyncEventArgs e)
                {
                    if (e.SocketError == SocketError.Success)
                    {
                        response = Encoding.UTF8.GetString(e.Buffer, e.Offset, e.BytesTransferred);
                        response = response.Trim('\0');
                        Debug.WriteLine(response);
                    }
                    else
                    {
                        response = e.SocketError.ToString();
                    }

                    _clientDone.Set();
                });

                _clientDone.Reset();

                _socket.ReceiveAsync(socketEventArg);

                _clientDone.WaitOne(TIMEOUT_MILLISECONDS);
            }
            else
            {
                response = "Socket is not initialized";
            }
            return response;
        }

我尝试增加 TIMEOUT_MILLISECONDS 的值和我的 MAX_BUFFER_SIZE 的大小，但没有任何改变。我需要能够获得更大的数据。 而且我必须使用这种方式，我不能使用WebClient或HttpWebRequest...

Answer 1

如果您没有收到您想要的所有数据，只需再次调用您的接收函数。

另外，这一点非常重要，在您在 TCP 之上实现任何东西之前，记录您正在使用的协议，除非您正在实现一个已经记录在案的协议。阅读一些基于 TCP 的协议（如 SMTP、IRC、HTTP 等）的协议文档可能会有所帮助。

Answer 2

您不能指望在单个套接字读取中获取所有数据。您必须放入一个循环，该循环将继续接收数据，直到没有更多数据要接收。

那么，您如何判断何时收到了所有数据？您有两个选择：您可以发送一个仅出现在消息末尾的分隔符字节；如果你看到这是收到的最后一个字节，你就完成了。否则，您可以在消息的开头发送消息的长度（这就是 HTTP 所做的，顺便说一句）。或者您可以让发送方在消息完成后关闭套接字，然后继续阅读直到套接字上出现 EOF 条件。

Answer 3

问题是接收调用只会读取接收数据包大小和您用于读取的缓冲区之间的最小长度。我怀疑您发送的数据太大并且被系统分成更小的数据包（称为碎片）。

我会在你发送的任何东西前面加上一个整数（4 个字节，即将到来的数据的大小），在接收端读取它并从套接字读取字节，只要你没有收到你发送的长度一个标题。

编辑：由于您可以使用 TcpClient，我建议您使用它和 .GetStream()。如果我错了，请告诉我，但这个程序应该只发送和接收字符串（根据你的代码）。这就是我要做的：

public async Task<string> ReceiveString()
{
    NetworkStream netStream = _client.GetStream(); //Using _client instead of _socket
    StreamReader streamReader = new StreamReader(netStream);
    string result = await streamReader.ReadLine(); //Reading the stream until we find a newline
    return result;
}

你会像这样使用它：

void MyMethod()
{
    string message = await ReceiveString(); //This is the fully async way, the "MyMethod" signature should be "async void" too in order to use "await"

    string message = ReceiveString().Result; //This is a blocking call, waits for everything to be received before proceding
}

注意：如果您以换行符结束所有消息，则此代码有效。它也仅适用于您只想传输字符串（如上所述，我假设）。