如何使用C#使用Protobuf进行非阻塞套接字读取?

让我们说我想从网络套接字进行非阻塞读取。 我可以异步等待套接字读取x字节,一切都很好。

但是如何通过protobuf将其与反序列化相结合?

从流中读取对象必须阻塞? 也就是说,如果流包含的解析器数据太少,那么必须在后台进行一些阻塞,以便读者可以获取所需的所有字节。

我想我可以使用lengthprefix分隔符并读取第一个字节,然后计算出在解析之前我必须获取最少的字节数,这是正确的方法吗? 例如,如果我的缓冲区是500字节,则等待那500个字节,并解析长度前缀,如果长度超过500,则再次等待,直到读取所有内容。

结合非阻塞IO和protobuf解析的惯用方法是什么?

(我现在正在使用Jon Skeet的实现http://code.google.com/p/protobuf-csharp-port/ )

作为一般规则,序列化程序通常不包含DeserializeAsync方法,因为这真的很难(至少,有效)。 如果数据大小适中,那么我建议使用异步代码缓冲所需的数据量 – 然后在所有需要的数据可用时进行反序列化。 如果数据非常大并且您不希望缓冲内存中的所有内容,那么请考虑在工作线程上使用常规同步反序列化。

(请注意,这是特定于实现的,但如果您使用的序列化程序确实支持异步反序列化:那么请确保使用它)

使用BeginReceive/EndRecieve()方法将数据接收到字节缓冲区(通常为1024或2048字节)。 在AsyncCallback ,确保您没有读取-1/0字节(流结束/ disconnect / io错误)后,尝试使用ProtocolBuf反序列化数据包。

你的接收回调将是异步的,并且在与读取相同的线程中解析数据包是有意义的,恕我直言。 处理可能会导致最大的性能损失。