.net - MassTransit - 初始化复杂消息的最佳实践

问题描述

假设我有一个 ASP.NET Core Web API 应用程序，并且我的一个操作方法接收IEnumerable<AddressModel> addresses，其中AddressModel如下所示：

public class AddressModel
{
    public string Street { get; set; }
    public string ZipCode { get; set; }
    public string City { get; set; }
    public string Country { get; set; }
}

我想用它来构造一个更复杂的消息对象并通过 MassTransit 发送它 -Addresses将是一个嵌套属性，我将设置更多字段：

public interface ICreateContact
{
    ContactTypeEnum Type { get; }
    List<IAddress> Addresses { get; }
}

public interface IAddress
{
    string Street { get; }
    string ZipCode { get; }
    string City { get; }
    string Country { get; }
}

那么，如何以最方便易读的方式创建这样的消息呢？我看到了一些选择，但它们都有缺点：

最直接的选择：

await _messageBus.Send<ICreateContact>(new {
    Type = ContactTypeEnum.Single,
    Addresses = addresses.Select(a => new
    {
        Street = a.Street,
        ZipCode = a.ZipCode,
        City = a.City,
        Country = a.Country
    })
});

会工作，但我不想写很多代码来分配每个属性，我不能使用 Automapper，因为ICreateContact/IAddress.

中级：

public class CreateContact
{
    public ContactTypeEnum Type { get; set; }
    public List<Address> Addresses { get; set; }

    public class Address
    {
        public string Street { get; set; }
        public string ZipCode { get; set; }
        public string City { get; set; }
        public string Country { get; set; }
    }
}

var command = new CreateContact
{
    Type = ContactTypeEnum.Single,
    Addresses = addresses.Select(a => _mapper.Map<CreateContact.Address>(a)).ToList()
};

await _messageBus.Send<ICreateContact>(command);

看起来更好，但是如果我想实现它怎么办ICreateContact/IAddress，所以编译器会告诉我是否错误地构造了消息？我不能这样做，因为如果我 write CreateContact : ICreateContact，我的Addresses字段必须是 type List<IAddress>（即使我 make Addressimplement IAddress）。

所以总结一下我的问题：

是否可以避免中间类并使用带有属性自动映射的选项 1（带或不带 Automapper）？
在每个服务中为消息契约创建一个强类型类是个好主意吗？
如果是这样 - 如何处理接口类型的嵌套属性？
如果不是 - 如果消息合约有 30 个字段，其中一个被重命名并且您需要知道哪个没有文档，该怎么办？

标签： .netrabbitmqmessagingmasstransit

首先，您不需要立即类，您可以使用另一个嵌套匿名类型来初始化地址列表。MassTransit 的消息初始值设定项按约定执行大多数类型之间的映射，包括类型转换（字符串到 int、日期等）。

由于所有属性名称都匹配，您可以轻松使用：

await _messageBus.Send<ICreateContact>(new {
    Type = ContactTypeEnum.Single,
    Addresses = addresses
});

它会使用来自输入地址的元素来初始化地址列表。

其次，您对生产者的强类型类的问题？这取决于。我绝对不会在消息生产者之外分享这些具体类型。如果您想要该级别的属性类型/名称验证，您可以这样做。它只是在您的项目中管理更多的类。我已经在一些需要工程师级别指导的团队中看到了它，但更多时候我看到团队很乐意放手并在存储库级别保护合同变更。

第三，您可以使具体类型具有正确的元素类型（IAddress）并将地址具体类型添加到其中。这消除了数组类型问题，并且仍然允许您使用实现 IAddress 的地址具体类型。

第四，说真的，不要重命名属性！如果这是一个错误，请使用工具和 grep 全局修复它以查找跨存储库的任何用法。但是一旦它投入生产，重命名它可能会破坏事情。在这种情况下，添加一个新属性（拼写正确，无论如何）并更新生产者以最终发送两者，一旦系统全面升级，弃用原始属性。

文档中有更多关于 MassTransit 对消息初始化程序的支持的详细信息。

.net - MassTransit - 初始化复杂消息的最佳实践

问题描述

解决方案

推荐阅读