EndianBinaryReader - 输入流的连续更新？

Question

我正在尝试使用 Jon Skeet 作为他的 misc utils 库。它非常适合我对它的两种用途。

从网络流 (TCPClient) 中进行第一次读取，我坐在循环中读取传入的数据。我可以创建一个 EndianBinaryReader，然后将其处理掉在应用程序关闭时。我通过传入 TCPClient.GetStream 构造 EndianBinaryReader。

我现在尝试在从 UdpClient 读取时执行相同的操作，但这没有流。连接少。所以我得到的数据就像这样

byte[] data = udpClientSnapShot.Receive(ref endpoint);

我可以将这些数据放入内存流中

var memoryStream = new MemoryStream(data);

，然后创建 EndianBinaryReader

var endianbinaryReader = new EndianBinaryReader(
    new BigEndianBitConverter(), memoryStream,Encoding.ASCII);

但这意味着我每次执行读取时都必须创建一个新的 endian 读取器。有没有一种方法可以让我只创建一个流，然后用来自 udp 客户端的数据不断更新输入流？

Answer 1

我不记得 EndianBinaryReader 是否缓冲 - 您可以覆盖单个 MemoryStream 吗？但说实话，这里额外的对象带来的开销非常小。数据包有多大？ （将其放入 MemoryStream 将克隆 byte[]）。

我很想使用最简单的可行方法，看看是否存在真正的问题。也许我想要做的一个改变是引入 using （因为它们是 IDisposable）：

using(var memoryStream = new MemoryStream(data))
using(var endianbinaryReader = ..blah..) {
    // use it
}

Answer 2

您最好的选择可能是重写 .NET Stream 类以提供自定义功能。该类被设计为可通过自定义行为覆盖。

由于成员数量众多，这可能看起来令人畏惧，但它比看起来容易。有许多布尔属性，例如“CanWrite”等。覆盖它们并让它们全部返回“false”，除了您的读者需要的功能（可能 CanRead 是您唯一需要为 true 的功能。）

然后，只需覆盖Stream 的帮助 并让不受支持的方法返回“UnsupportedException”（而不是默认的“NotImplementedException”）。

实现 Read 方法以从缓冲的 UDP 数据包中返回数据（可能使用缓冲区链接列表） ，当您读取已用缓冲区时将其设置为“null”，以便内存占用不会无限制地增长。