我有一个应用程序,通过套接字连接发送不同大小的可序列化对象,我希望它尽可能地扩展.也可能有数十甚至数百个连接.
> NetworkStream来自一个持续侦听传入消息的TcpClient.
>我不想用标准的NetworkStream.Read()来阻塞一个线程.这需要扩展.我只假设Read()块,因为这是这类类的非常标准的行为,并且在类上有一个ReadTimeout属性.
>我不确定BinaryFormatter是否只使用Read(),或者它是否为我做了一些Async的东西.我的猜测是否定的.
> TcpClient需要获取消息,将其读取到最后,然后返回监听消息.
所以似乎有太多的方法可以给这只猫留下光彩,而且我不确定什么才是最有效的.我是：
只需使用BinaryFormatter读取NetworkStream？
- var netStream = client.GetStream();
- var formatter = new BinaryFormatter();
- var obj = formatter.Deserialize(netStream);
或者使用新的异步/等待内容做一些魔术：
- using(var ms = new MemoryStream())
- {
- var netStream = client.GetStream();
- var buffer = new byte[1028];
- int bytesRead;
- while((bytesRead = await netStream.ReadAsync(buffer,buffer.length)) > 0) {
- ms.Write(buffer,buffer.Length);
- }
- var formatter = new BinaryFormatter();
- var obj = formatter.Deserialize(ms);
- }
或者与上面类似,只利用新的CopyToAsync方法：
- using(var ms = new MemoryStream())
- {
- var netStream = client.GetStream();
- await netStream.CopyToAsync(ms); //4096 default buffer.
- var formatter = new BinaryFormatter();
- var obj = formatter.Deserialize(ms);
- }
或者是其他东西？
我正在寻找能够提供最大可扩展性/效率的答案.
[注意：以上是所有PSUEDO代码,作为示例给出]
解决方法
第一种方法遇到了大流的问题.如果您要发送大量数据,那么该代码将会因内存不足而导致应用程序崩溃.
第二种方法看起来非常好 – 它是异步的(意味着您不使用一些有价值的线程来等待读取完成)并且它使用数据块(这是您应该如何使用流).
所以选择第二个选项,可能稍作修改 – 一次只反序列化大块数据,不要读取整个内容(除非你绝对确定流长度).
这就是我的想法(伪代码)
- using (var networkStream = client.GetStream()) //get access to stream
- {
- while(!networkStream.EndOfStream) //still has some data
- {
- var buffer = new byte[1234]; //get a buffer
- await SourceStream.ReadAsync(result,buffer); //read from network there
- //om nom nom buffer
- Foo obj;
- using(var ms = new MemoryStream()) //process just one chunk
- {
- ms.Write(buffer,buffer.Length);
- var formatter = new BinaryFormatter();
- obj = formatter.Deserialize(ms); //desserialise the object
- } // dispose memory
- //async send obj up for further processing
- }
- }
