MemoryStream泄漏

Question

谁能告诉我们下面这段代码有什么问题？我们这里有一个对象序列化程序,它应该返回传递给它的任何对象的XML字符串.

我们一直在讨论这个问题,因为我们有一个多次调用这个程序的程序,我们看到我们的内存使用量一直很高(甚至在程序完成后仍然存在)...我们已经完成了搜索但是徒劳无功.stream对象在一个"using"语句中,所以我们认为这应该是自己处理的..请帮忙.

    public static string ToXML(this IMessage m)
    {          
        try
        {
            var serializer = SerializerFactory.Create(m.GetType());
            using (var stream = new MemoryStream())
            {
                serializer.Serialize(new[] { m }, stream);
                stream.Position = 0;
                var s = Encoding.ASCII.GetString(stream.ToArray());
                return s;
            }
        }
        catch (Exception e)
        {
            return string.Format("Message unserializable: {0}", e.Message);
        }
    }

btw SerializerFactory看起来像这样:

public class SerializerFactory
{
    public static IMessageSerializer Create(Type t)
    {
        var types = new List<Type> { t };
        var mapper = new MessageMapper();
        mapper.Initialize(types);
        var serializer = new XmlMessageSerializer(mapper);

        serializer.Initialize(types);

        return serializer;
    }
}

Answer 1

这段代码没有什么大错; 请注意,using它本质上是 a上的无操作MemoryStream,因为它只有托管资源,托管资源是GC的域; GC 收集一些内存是不合理的,这是正常的,所以我不会过分强调 - 或者:如果有问题,可能不是这个.

但有一点是,您可以在编码步骤中避免使用缓冲区:

var s = Encoding.ASCII.GetString(stream.GetBuffer(), 0, (int)stream.Length);

实际上,我很想在默认情况下使用UTF8,而不是ASCII.

最后一个想法:你SerializerFactory 自己在做什么泄漏吗？例如,您是否正在创建new XmlSerializer(...)任何更复杂的构造函数？最简单的形式:

new XmlSerializer(typeof(SomeType));

是细 -它在内部缓存内部/实际每型串行器,并重新使用该用于每个XmlSerializer这种方式创建的实例.然而,它并没有为更复杂的构造函数重载这样做缓存:它创建和每次加载一个新的动态组装.并且以这种方式加载的程序集永远不会被卸载 - 所以是的,这可能会导致内存泄漏.我非常希望看到如何创建序列化程序实例,看看这是否是实际问题.请注意,通过在工厂中创建自己的序列化程序缓存,这种情况通常很容易解决:

public class SerializerFactory
{
    // hashtable has better threading semantics than dictionary, honest!
    private static readonly Hashtable cache = new Hashtable();
    public static IMessageSerializer Create(Type t)
    {
        var found = (IMessageSerializer)cache[t];
        if(found != null) return found;

        lock(cache)
        {   // double-checked
            found = (IMessageSerializer)cache[t];
            if(found != null) return found;

            var types = new List<Type> { t };
            var mapper = new MessageMapper();
            mapper.Initialize(types);
            var serializer = new XmlMessageSerializer(mapper);

            serializer.Initialize(types);

            cache[t] = serializer;

            return serializer;
        }
    }
}