我们可以通过 masstransit 一起使用 RabbitMQ 和 Mediatr 吗？

Question

我创建了一个微服务应用程序，该应用程序使用 MassTransit 和 RabbitMQ 进行微服务通信。
每个微服务都使用干净的架构开发，因此我们在每个微服务中都有 MediatR。
是否也可以使用 MassTransit 进行内部通信？所以我可以对所有服务使用相同的签名，当我想公开一个服务以在微服务间使用时，它会很容易做到。 所以 MediatR 用于内部通信，RabbitMQ 用于内部通信，整个宇宙都在 MassTransit 系统上。
[更新]我的问题是我们如何配置消费者，以便一些可以用于内部通信（通过 MediatR），有些可用于外部通信（通过 RabbitMQ），并且可以轻松地将它们从内部更改为外部。
[Update2] 例如，这是我的 MassTransit 注册：

services.AddMassTransit(x =>
        {
            x.AddConsumers(Assembly.GetExecutingAssembly());

            x.AddBus(provider =>
                Bus.Factory.CreateUsingRabbitMq(cfg =>
                {
                    cfg.Host(new Uri(config.RabbitMQ.Address), h =>
                    {
                        h.Username(config.RabbitMQ.Username);
                        h.Password(config.RabbitMQ.Password);
                    });

                    cfg.ReceiveEndpoint("my-queue", ep => { ep.ConfigureConsumers(provider); });
                }));


            x.AddMediator((provider, cfg) => { cfg.ConfigureConsumers(provider); });
        });

内部沟通和外部沟通有什么不同？换句话说，我怎样才能将一些消费者注册到 MediatR 而一些消费者注册到 RabbitMQ？

Answer 1

它们可以一起使用，MassTransit 也有自己的 Mediator 实现，因此您可以编写一次处理程序，然后通过 Mediator 或通过 RabbitMQ 等持久传输来使用它们。

有可用的videos 可以带您了解这些功能，从调解器开始，然后迁移到 RabbitMQ。

Answer 2

我发现我应该为每个创建一个单独的总线。然后外部服务继承自 IExternalConsumer 之类的接口，因此我可以将它们与内部服务分开并将它们添加到相关总线： 第 7 版更新

        // find consumers
        var types = AssemblyTypeCache.FindTypes(new[]{Assembly.GetExecutingAssembly()},TypeMetadataCache.IsConsumerOrDefinition).GetAwaiter().GetResult();
        var consumers = types.FindTypes(TypeClassification.Concrete | TypeClassification.Closed).ToArray();
        var internals = new List<Type>();
        var externals = new List<Type>();
        foreach (Type type in consumers)
        {
            if (type.HasInterface<IExternalConsumer>())
                externals.Add(type);
            else
                internals.Add(type);
        }

        services.AddMediator(x =>
        {
            x.AddConsumers(internals.ToArray());
            x.ConfigureMediator((provider, cfg) => cfg.UseFluentValidation());
        });
        services.AddMassTransit<IExternalBus>(x =>
        {
            x.AddConsumers(externals.ToArray());
            x.AddBus(provider =>
                Bus.Factory.CreateUsingRabbitMq(cfg =>
                {
                    cfg.Host(new Uri(config.RabbitMQ.Address), h =>
                    {
                        h.Username(config.RabbitMQ.Username);
                        h.Password(config.RabbitMQ.Password);
                    });

                    cfg.ReceiveEndpoint(apiProviderName, ep => { ep.ConfigureConsumers(provider); });

                }));
        });

        services.AddMassTransitHostedService();