NetworkStream BeginRead 只读取一次？

Question

我有一些非常简单的代码，可以从它连接到的网络流中读取行。在代码示例中，每次读取只有一行，并且不会继续从服务器获取更多信息。

怎么了？

        byte[] readBuffer = new byte[1024];
        byte[] tempBuff = new byte[1024];
        int tempBuffSize = 0;    


private void btnConnect_Click(object sender, EventArgs e)
            {

            TcpClient tcpClient = new TcpClient("192.168.1.151", 5505);
            NetworkStream stream = tcpClient.GetStream();
            stream.BeginRead(readBuffer, 0, 1024, readHandler, tcpClient); 
        }

void readHandler(IAsyncResult result)
        {
            TcpClient tcpClient = (TcpClient)result.AsyncState;
            int dataLen = tcpClient.GetStream().EndRead(result);

            int currStart = 0;
            int currEnd = -1;

            for (int i = 0; i < dataLen; i++)
            {
                if (readBuffer[i] == '\r' && i < (readBuffer.Length - 1) &&
                    readBuffer[i + 1] == '\n')
                {
                    // Set the end of the data 
                    currEnd = i - 1;

                    // If we have left overs from previous runs: 
                    if (tempBuffSize != 0)
                    {

                        byte[] joinedData = new byte[tempBuffSize + (currEnd - currStart + 1)];
                        Array.Copy(tempBuff, 0, joinedData, 0, tempBuffSize);
                        Array.Copy(readBuffer, currStart, joinedData, tempBuffSize, (currEnd - currStart + 1));

                        System.Text.Encoding enc = System.Text.Encoding.ASCII;
                        string myString = enc.GetString(joinedData);
                        System.Diagnostics.Debug.Write(myString);

                        tempBuffSize = 0;
                    }
                    else
                    {
                        System.Text.Encoding enc = System.Text.Encoding.ASCII;
                        string myString = enc.GetString(readBuffer);
                        System.Diagnostics.Debug.Write(myString);

                        // HandleData(readBuffer, currStart, currEnd);
                    }

                    // Set the new start - after our delimiter 
                    currStart = i + 2;
                }

            }

            // See if we still have any leftovers 
            if (currStart < dataLen)
            {
                Array.Copy(readBuffer, currStart, tempBuff, 0, dataLen - currStart);
                tempBuffSize = dataLen - currStart;
            }
        }  

Answer 1

为什么您希望它首先读取整个信息？我不是专家，但在我看来，同步和异步方法都不能保证读取所有数据（无论这意味着什么，因为只要套接字打开，更多数据就可以到达）。在 EndRead 方法中的代码之后，如果您需要更多数据，则应再次调用 Read 或 BeginRead。您应该知道根据您与客户端建立的协议是否需要更多数据。

Answer 2

当我为嵌入式设备开发 TCP 应用程序时，我遇到了类似的问题。就我而言，问题是设备在延迟时间内发出数据，因此在其余数据进入之前，控件移动到程序中的下一行，仅从服务器获取初始数据。我通过引入延迟来解决这个问题。

就在从服务器读取数据的行之后引入了延迟，因此最好在单独的线程上运行它

thread.sleep(3000)

这最有可能是您的问题。

Answer 3

也许您的流对象在超出范围时被释放，然后再次调用 readHandler 。尝试将 tcpClient 和流提升到类范围而不是方法范围，或者将读取移动到操作完成时退出的单独线程。