如何在.NET中的套接字编程（TCP/IP）中收集接收到的缓冲区？

Question

我使用服务器-客户机模型与使用套接字编程的硬件板进行通信。

我使用“NetworkStream”类的“read（）”方法从板上接收数据，该方法读取指定最大大小的缓冲区，并返回缓冲区中有效数据的长度。我已经考虑了一个足够大的数字缓冲区的最大大小。

该板每100ms发送一组消息。每条消息包含一个2字节的常量报头和一个作为报头字节之后的数据的可变字节数。

Answer 1

您需要在您的使用者DFA和套接字客户端之间添加一个额外的缓冲区组件。

每当数据可以从NetworkStream中获得时，buffer组件就会读取它，并将它追加到自己的专用缓冲区中，增加一个“可用字节”计数器。缓冲区组件至少需要向其用户公开以下功能：

1. BytesAvailable属性--返回计数器的值
2. peekbytes(int count)方法--如果缓冲区的第一个count字节至少可用，则返回该字节，并且不修改计数器或缓冲区
3. 一个readbytes(int count)方法--如上所述，但它会将计数器递减count并移除从缓冲区读取的字节，以便后续的peekbytes调用将永远不会再读取它们

请记住，您不需要能够为任意高的count参数提供服务；如果您能够为count提供与它在任何时候都可能接收到的最长消息一样长的服务，这就足够了。

显然，缓冲区组件需要保留某种数据结构，这种结构允许某种类型的“环绕”；您可能希望查看循环（环形）缓冲区实现，或者您可以只使用两个大小为n的固定缓冲区，其中n是最长消息的长度，并在它们满时从一个切换到另一个。您应该小心，以便在缓冲区已满时停止从NetworkStream中拉入数据，并且只有在DFA调用ReadBytes以释放一些缓冲区空间后才继续拉入数据。

每当您的DFA需要读取数据时，它会首先询问您的缓冲级已经积累了多少数据，然后相应地进行。它看起来像这样：

if BytesAvailable < 2
    return; // no header to read, cannot do anything

// peek at the header -- do not remove it from the buffer!
header = PeekBytes(2);

// calculate the full message length based on the header
// if this is not possible from just the header, you might want to do this
// iteratively, or you might want to change the header so that it is possible
length = X; 

if BytesAvailable < X
    return; // no full message to read, cannot continue

header = ReadBytes(2); // to remove it from the buffer
message = ReadBytes(X); // remove the whole message as well