具有 IEnumerable的消息的 NServiceBus Xml 序列化问题财产

Question

我正在尝试发送带有 IEnumerable 属性的消息，NServiceBus Xml 序列化程序不支持此操作，我是否正确？ 如果我切换到使用数组而不是 IEnumerable 它会工作，如果我使用二进制序列化器它也可以工作

我的消息看起来像这样

[Serializable]
public class Parent : IMessage
{
  public string Identifier { get; private set; }
  public IEnumerable<Child> Children { get; private set; }

  public Parent(string identifier, IEnumerable<Child> children)
  {
    this.Identifier = identifier;
    this.Children = children;
  }
}

[Serializable]
public class Child
{
  public string Identifier { get; private set; }
}  

如果默认的 Xml 序列化器不能满足这一点，是否有任何方法可以配置替代的 Xml 序列化器，例如BCL 的 DataContractSerializer ？

预先感谢

帕特

Answer 1

首先，请注意，NServiceBus 中的 XML 序列化与 .NET XML 序列化不同。 .NET 变体旨在能够使用属性定制生成的 XML，以生成特定的 XML 模式，从而可能实现与其他语言的互操作性。 NServiceBus XML 序列化程序是功能的一个极小的子集，专门用于尽可能高效地在 XML 与预定义消息模式之间进行传输。

虽然 NServiceBus 序列化的结果是可读的（这在检查错误队列时非常好），但它不支持所有类型或所有格式选项。它做了它该做的事情，而且做得很好。

也就是说，IEnumerable 的问题在于它可能有很多东西。实际上，它可能只是一个数组，但也可能很容易成为一个调用数据库查询的复杂 Linq-to-SQL 表达式。为了序列化 IEnumerable，您必须将其表示为集合（列表或数组），因此您必须枚举项目。你具体什么时候会这样做？这可能会引发哪些交易问题？这就是为什么注重性能的 NServiceBus XML 序列化器不关心的原因。

NServiceBus 消息只是传递消息数据的契约。我建议只使用数组。将 IEnumerable 转换为数组（使用 ToArray() 扩展方法）并转换回来（使用 AsEnumerable() 扩展方法）非常容易，那么为什么将它作为 IEnumerable 很重要呢？

要完全回答您的问题，应该可以通过编写自己的实现 IMessageSerializer 的类并配置依赖项注入框架来使用它来交换序列化器，但我自己还没有尝试过。这将是一项艰巨的任务，因为每个端点都必须使用相同的序列化器，并且您还必须进行修改才能使用分发器、TimeoutManager、网关等。

编辑：注意到这个问题是交叉发布的NSB 组 http://tech.groups.yahoo.com/group/nservicebus /消息/8838

Answer 2

有没有办法配置替代的 Xml 序列化器，例如 BCL 的 DataContractSerializer？

是的，这当然是可能的。我们将 DataContractSerializer 用于我们的某些服务。要实现此功能，您需要实现 IMessageSerialzer 接口来完成这项工作，然后在 NServiceBus.Configure 方法链期间向 NServiceBus 注册该序列化器。

这是消息序列化器的代码。这非常简单。

public class WcfMessageSerializer : IMessageSerializer
{
    private readonly IList<Type> knownTypes = new List<Type>();

    public IList<Type> MessageTypes
    {
        get { return knownTypes; }
        set
        {
            knownTypes.Clear();
            foreach (var type in value)
            {
                if (!type.IsInterface && typeof(IMessage).IsAssignableFrom(type)
                    && !knownTypes.Contains(type))
                {
                    knownTypes.Add(type);
                }
            }
        }
    }

    public void Serialize(IMessage[] messages, Stream stream)
    {
        var xws = new XmlWriterSettings
        {
            ConformanceLevel = ConformanceLevel.Fragment
        };
        using (var xmlWriter = XmlWriter.Create(stream, xws))
        {
            var dcs = new DataContractSerializer(typeof(IMessage), knownTypes);
            foreach (var message in messages)
            {
                dcs.WriteObject(xmlWriter, message);
            }
        }
    }

    public IMessage[] Deserialize(Stream stream)
    {
        var xrs = new XmlReaderSettings
        {
            ConformanceLevel = ConformanceLevel.Fragment
        };
        using (var xmlReader = XmlReader.Create(stream, xrs))
        {
            var dcs = new DataContractSerializer(typeof(IMessage), knownTypes);
            var messages = new List<IMessage>();
            while (false == xmlReader.EOF)
            {
                var message = (IMessage)dcs.ReadObject(xmlReader);
                messages.Add(message);
            }
            return messages.ToArray();
        }
    }
}

为了插入它，您可以使用如下扩展方法：

public static class ConfigureWcfSerializer
{
    public static Configure WcfSerializer(this Configure config)
    {
        var messageTypes = Configure.TypesToScan
            .Where(t => typeof(IMessage).IsAssignableFrom(t))
            .ToList();

        config.Configurer
            .ConfigureComponent<WcfMessageSerializer>(ComponentCallModelEnum.Singleton)
            .ConfigureProperty(ms => ms.MessageTypes, messageTypes);

        return config;
    }
}

当您像这样配置 NServiceBus 时将调用该方法：

NServiceBus.Configure
    // Other configuration...
    .WcfSerializer()
    // Other configuration...
    .CreateBus()
    .Start();