如何在单个套接字上进行多个stream.writes和读取

Question

我的应用程序连接到设备并通过单个套接字连接发送多个命令。然后它读取对这些的响应，基本

命令

1stream.writestream.read

结构

命令

2stream.writestream.read

是

。 。 。

我想知道是否有更好的方法来做到这一点。我并不担心阻塞，因为它与程序的其余部分运行在不同的线程上。我遇到的问题是，有时命令 1 的数据会落在命令 2 的读取中。另一件事是我收到的第一个字节对于该命令是唯一的。

任何帮助将不胜感激

Answer 1

假设 TCP - 无法确保每个命令在发送时都被读取。在目标端，每个命令都可以被分割或连接到其他命令，因此您需要手动确定它们之间的边界。

一种常见的技术是在命令前加上其长度前缀，您可以先读取该长度，并准确地知道在下一个命令之前要读取多少字节。在目标端，您通常有某种队列，将所有接收到的数据推送到其中，并且仅当有一个或多个完全接收到的命令时，一次从队列中读取一个命令。

我不建议在任何情况下使用阻塞套接字，即使您使用单独的线程。如果您需要在同一个套接字上发送和接收，则可能会遇到这样的问题：在没有数据等待时尝试调用 Read，并且在收到数据之前您将无法发送任何数据。

不要使用阻塞调用，而是使用 BeginRead、EndRead 进行异步接收，这样您就可以在同一个线程中发送和接收，而不必担心这些问题。

Answer 2

因为您处于多线程中，所以在发送命令时使用锁定，例如：

public void SendCommand(Command command)
{
    lock (_commandLocker)
    {
       stream write
       stream read 
    }
}

因此一次只有一个命令会发送和接收数据。

但是，如果您随时从设备接收数据“也许它会发送通知..”，那么请考虑执行以下操作：

private Queue<Notification> _notificationsBuffer = new Queue<Notification>();//Or use BlockingCollection if your are using 4.0

在 SendCommand

...
while (stream read)
{
    if (this is a notification)
    {
     then add it to the notification buffer and continue read
     continue;
    }
    else (this is our command)
    { ... read the response..}
}