如何读取套接字流直到换行？

Question

我有一个 Node.js 服务器 + Unity (.NET 3.5) 应用程序，我确保通过套接字进行通信。我在从 Node.js 服务器接收数据到 C# 套接字客户端时遇到问题。

我希望我的 C# 客户端读取套接字流，直到找到换行符 (/n)。这就是我确保数据从 C# 流向 Node.js 服务器的方式，因为有一个名为 split 的 NPM 模块可以确保逐行读取缓冲区。

以下是我的代码，如果您能提出解决方案以实现上述接收数据的方式，我将不胜感激：

在这里，我毫无问题地连接到 Node.js 服务器：

private Socket ClientSocket;
private byte[] _receiveBuffer = new byte[8142];

public string hostname;
public int port;

public void onnectClient()
{
    ClientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
    ClientSocket.Connect(hostname, port);
    ClientSocket.BeginReceive(_receiveBuffer, 0, _receiveBuffer.Length, SocketFlags.None, new AsyncCallback(ReceiveCallback), null);
}

以下是当前ReceiveCallback,:

private void ReceiveCallback(IAsyncResult AR)
{
    int received = ClientSocket.EndReceive(AR);
    byte[] recData = new byte[received];
    Buffer.BlockCopy(_receiveBuffer, 0, recData, 0, received);

    string resultString = System.Text.Encoding.UTF8.GetString(recData);

    currentlyReceivedData = JsonUtility.FromJson<ReceivedData>(resultString);

    ClientSocket.BeginReceive(_receiveBuffer, 0, _receiveBuffer.Length, SocketFlags.None, new AsyncCallback(ReceiveCallback), null);
}

更新 1：

现在我使用 TcpClient 和 StreamReader 代替上面的代码，但是由于某种原因，while 循环没有继续：

    private void ListenForData()
{
    try
    {
        socketConnection = new TcpClient("localhost", 6670);
        Byte[] bytes = new Byte[1024];
        while (true)
        {

            using (StreamReader sr = new StreamReader(socketConnection.GetStream()))
            {
                string line;
                // Read and display lines from the file until the end of 
                // the file is reached.
                while ((line = sr.ReadLine()) != null)
                {
                    Debug.Log("line");
                }
            }
        }
    }
    catch (SocketException socketException)
    {
        Debug.Log("Socket exception: " + socketException);
    }
}

Answer 1

如果您不需要使用Socket 的所有可用选项，我建议您改用TcpClient 类。连接后，您可以调用GetStream() 以接收NetworkStream¹，您可以将其传递给StreamReader。

到达那里后，您只需致电ReadLine()（或道德等价物）即可检索每个完整的行。这使您可以忽略使用“原始” TCP 的许多现实情况，例如必须重建/保存缓冲区以反映它不是消息传递而是字节流的现实。

ReadLine 可以处理任何正常形式的行尾，包括\n、\r 和\r\n。

---

¹请注意，您可以从现有的Socket 构建一个作为替代方案。但我会尝试使用更简单的选项，除非我需要更复杂的选项。

Answer 2

我建议你看看这个：https://blogs.msdn.microsoft.com/dotnet/2018/07/09/system-io-pipelines-high-performance-io-in-net/

这可以为你省去不少麻烦！

如果您不能使用 System.IO.Pipelines，您仍然可以学习示例如何从套接字读取，直到您到达新行！