c# - Rebus RabbitMQ 对象序列化

Question

为什么当我通过 rebus 向 RabbitMQ 发送消息时，它添加了如下所示的额外对象数据，主要是 $type。

{"$type":"ThreeSquared.VTGPAM.Objects.Wagon, ThreeSquared.VTGPAM.Objects","WagonId":"a98a06ab-33b9-4a11-9de2-df0b8787b713","WamosId":12324,"Description":"test","YearBuilt":1982,"Token":"3cce443c-249f-4fd2-9882-5830fb308b6b"}

我们有一个客户端，它将仅使用 Java RabbitMQ 库，没有 rebus。我相信这种方法我们只是发送没有类型声明的 JSON。因此，当我尝试读取简单的 JSON 对象时，这不起作用。我们怎样才能让它工作，这样它就不会定义消息中的$type？

Answer 1

这只是因为 Rebus 默认使用 Newtonsoft JSON.NET 和 TypeNameHandling.All ，这意味着 $type 字段包含在每个包含序列化类型的完整 .NET 类型名称的序列化对象中。

好处是您可以序列化几乎任何内容，即使它可能包含由(可能是抽象的)父类(super class)型甚至接口(interface)引用的实例。

例如该命令消息类型

public class ProcessFile
{
    public ProcessFile(string filePath, IEnumerable<IFileProcessingTask> tasks)
    {
        FilePath = filePath;
        Tasks = tasks;
    }

    public string FilePath { get; }

    public IReadOnlyCollection<IFileProcessingTask> Tasks { get; }
}

可以包含IFileProcessingTask的任意实现，例如类似的东西

public class GZipFileProcessingTask : IFileProcessingTask
{
    // ...    
}

只要接收者可以通过 $type 字段的值查找类型即可。

如果你想在另一个平台上处理这种类型的消息，你可以简单地让它忽略每个对象的$type字段。这可能很容易/很难/不可能，具体取决于您的 JSON 序列化器的灵活性。

另一种选择是简单地用您自己的实现替换 Rebus 的序列化器

Configure.With(...)
    .(...)
    .Serialization(s => s.UseCustomJsonSerialization())
    .Start();

其中 UseCustomJsonSerialization 是您实现的扩展方法，如下所示:

public static class RebusConfigEx
{
    public static void UseCustomJsonSerialization(this StandardConfigurer<ISerializer> configurer)
    {
        configurer.Register(c => new YourCustomJsonSerializer());
    }
}

然后剩下要做的就是创建类 YourCustomJsonSerializer 作为 ISerializer 的实现.