3

我有一个非关闭流类，它包含在带有二进制读取器的 using 块中，但由于某种原因，当块结束时，我的非关闭流仍然关闭。

流定义为：

internal class NonClosingStream : Stream, IDisposable
{
    private Stream baseStream;

    public NonClosingStream(Stream baseStream)
    {
        this.baseStream = baseStream;
    }

    public override bool CanRead{ get { return baseStream.CanRead; } }
    public override bool CanSeek{ get { return baseStream.CanSeek; } }
    public override bool CanWrite { get { return baseStream.CanWrite; } }

    public override void Flush()
    {
        baseStream.Flush();
    }

    public override long Length { get { return baseStream.Length; } }

    public override long Position
    {
        get { return baseStream.Position; }
        set { baseStream.Position = value; }
    }

    public override int Read(byte[] buffer, int offset, int count)
    {
        return baseStream.Read(buffer, offset, count);   
    }

    public override long Seek(long offset, SeekOrigin origin)
    {
        return baseStream.Seek(offset, origin);
    }

    public override void SetLength(long value)
    {
        baseStream.SetLength(value);
    }

    public override void Write(byte[] buffer, int offset, int count)
    {
        baseStream.Write(buffer, offset, count);
    }

    public override void Close()
    {
        // Disconnects from base stream, but does not close it
        this.baseStream = null;
    }

    void IDisposable.Dispose()
    {
        // Disconnects from base stream, but does not close it
        this.baseStream = null;
    }
}

读取块如下所示：

public T Deserialize<T>(Stream stream)
{
    using (NonClosingStream nonClosingStream = new NonClosingStream(stream))
    using (BinaryReader reader = new BinaryReader(nonClosingStream, Encoding.ASCII, true))
    {
        // Read the type name, then convert it to an actual type
        String typeName = reader.ReadString();
        Type graphType = AvailableTypes.GetType(typeName);

        // If a deserializer for this type already exists, use it.
        if (deserializerFunctions.ContainsKey(graphType))
        {
            return (T)deserializerFunctions[graphType](reader);
        }

        // Otherwise, create one and use it
        T graph = (T)FormatterServices.GetUninitializedObject(graphType);

        typeof(ServiceSerializer).GetMethod("DeserializeObject",
                BindingFlags.NonPublic | BindingFlags.Static)

            .MakeGenericMethod(graphType)
            .Invoke(this, new Object[] { reader, graph });

        return graph;
    }
}

我究竟做错了什么？

更新

所以我写了这个小家伙：

static void Main()
{
    MemoryStream stream = new MemoryStream();
    using (NonClosingStream nonCloser = new NonClosingStream(stream))
    using (BinaryWriter writer = new BinaryWriter(nonCloser))
    using (BinaryReader reader= new BinaryReader(nonCloser))
    {
        writer.Write("Lorem ipsum");

        stream.Seek(0, SeekOrigin.Begin);
        String data = reader.ReadString();

        Console.WriteLine(data);
    }

    stream.Seek(0, SeekOrigin.Begin);

    using (NonClosingStream nonCloser = new NonClosingStream(stream))
    using (BinaryWriter writer = new BinaryWriter(nonCloser))
    using (BinaryReader reader = new BinaryReader(nonCloser))
    {
        writer.Write("Lorem ipsum");

        stream.Seek(0, SeekOrigin.Begin);
        String data = reader.ReadString();

        Console.WriteLine(data);
    }

    Console.ReadLine();
}

它似乎工作正常，流保持打开状态，就像它应该的那样。所以我认为共识是正确的。不知何故，我正在关闭其他地方的流。当我弄清楚我会发布结果时。谢谢大家。

更新

Gaaaahhh，我发现了问题。因此，代码的工作方式是在序列化/反序列化对象时，然后从表达式树构建自定义序列化器，然后对其进行编译，以便将来的序列化更加流畅。这意味着我的代码充满了这样的东西：

Action<BinaryReader, Object> assignmentAction = delegate(BinaryReader bReader, Object oGraph)
{
    bReader.ReadByte();      // Read the next action
    bReader.ReadString();    // Read the field name
    bReader.ReadByte();      // Read the field type

    // Call the assignment lambda
    assignmentLambda(reader, deserializerFunctions[primitiveType], (T)oGraph);
};

你抓到了吗？不？我显然也没有。让我们添加一些上下文：

private static void DeserializeObject<T>(BinaryReader reader, T graph)
{
    ...

    Action<BinaryReader, Object> assignmentAction = delegate(BinaryReader bReader, Object oGraph)
    {
        bReader.ReadByte();      // Read the next action
        bReader.ReadString();    // Read the field name
        bReader.ReadByte();      // Read the field type

        // Call the assignment lambda
        assignmentLambda(reader, deserializerFunctions[primitiveType], (T)oGraph);
    };

    ...
}

lambda 正在reader从外部块关闭，而不是bReader在缓存的反序列化程序运行时使用提供的。因此，当反序列化器运行时，它使用的是已经丢弃的二进制读取器对象，而不是提供给它的新读取器对象。我想问题不在于我正在关闭流，而在于我使用的是已处置的阅读器。至少这解释了为什么它会工作一次，然后第二次失败，因为第二次它依赖于缓存的反序列化器。哎呀！

谢谢大家。

4

3 回答 3

1

由于您的流不会创建内部流，因此外部代码很可能会关闭您的内部流。您的代码可能如下所示：

 NonClosingStream nonClosing;
 using(var stream = new FileStream(...))
 {
   nonClosing = new NonClosingStream(stream );
  ....
 } 
 // inner stream now closed and nonClosing will fail all operations.
于 2013-04-24T21:59:55.003 回答
1 
void IDisposable.Dispose()

你的类有两个Dispose() 方法。您明确实施的那个。以及您从 Stream 类继承的那个。问题是，BinaryStream 不知道你的 bean。它只知道 Stream 实现的那个。此外，当您使用 BinaryStream(Stream) 构造函数时，BinaryStream 对象将承担传递的 Stream 对象的所有权。这意味着它会在它自己处置时处置该流。也许您现在看到了问题，继承的 Dispose() 方法将被调用，而不是您的。它关闭了基本流。

这就是 Stream 实现 Dispose 模式的原因。你需要让它看起来像这样：

internal class NonClosingStream : Stream {
    protected override Dispose(bool disposing) {}
}
于 2013-04-25T00:54:21.837 回答
0

这取决于您的 NonClosingStream 类包装的流是否在其他地方引用。如果不是，那么底层流将没有引用，因此在之后的某个时刻，它的终结器将关闭该流。

于 2013-04-24T21:57:03.907 回答