8

我想在单台 PC 上模拟网络类型的流。

我通过创建一个Stream接收 2 个底层流（一个用于读取，另一个用于写入）来完成此操作。

然后我创建了这个类的 2 个实例来交换 2 个流。目前我使用MemoryStreams 作为 2 个底层流。

我现在遇到的问题是，如果我将 X 字节写入 a，MemoryStream那么它的位置将是 X，如果我再执行 a Read，我将没有数据，因为我在流的末尾。

鉴于我通常会进行几次读取/写入（所以不能在每次写入后将位置重置为 0）我Stream可以用什么来获得这种行为？

实际上，我想要一种可以以流的形式写入和读取的字节队列。

即（忽略实际的方法参数）

MyStream.Write({ 1, 2, 3, 4, 5, 6 });
MyStream.Write({ 7, 8 });
MyStream.Read(3) // Returns { 1, 2, 3 }
MyStream.Read(4) // Returns { 4, 5, 6, 7 }
4

1 回答 1

11

它实际上比我想象的要简单得多（无论如何就我而言）。
我只是在执行任何操作之前恢复/记录读/写位置：

public class QueueStream : MemoryStream
{
    long ReadPosition;
    long WritePosition;

    public QueueStream() : base() { }

    public override int Read(byte[] buffer, int offset, int count)
    {
        Position = ReadPosition;

        var temp = base.Read(buffer, offset, count);

        ReadPosition = Position;

        return temp;
    }

    public override void Write(byte[] buffer, int offset, int count)
    {
        Position = WritePosition;

        base.Write(buffer, offset, count);

        WritePosition = Position;
    }
}
于 2012-04-27T14:50:06.603 回答