如何将 à 大众运输消费者连接到由不同应用程序创建的交换

问题描述

我使用 Masstransit 和 RabbitMq 在两个 Web 应用程序 .net core 之间进行通信。在发布者应用程序中，我向交换“生产者”发布一条消息。

rabbitConfigurator.Message<TMessage>(x => x.SetEntityName("producer"));

在同一个应用程序中，我有一个上述消息的消费者 A 并且工作正常（消费者有一个交换和一个队列，如连接到生产者交换的兔子/大众运输所推荐的那样）

rabbitConfigurator.ReceiveEndpoint("consumer-A",x =>
            {
                x.Consumer<TConsumer>(context);
                x.Bind("producer");
            });

在第二个应用程序中，我试图设置另一个连接到交换“生产者”的相同消息类型的消费者 B。

rabbitConfigurator.ReceiveEndpoint("consumer-B",x =>
                {
                    x.Consumer<TConsumer>(context);
                    x.Bind("producer");
                });

然而，发往第二个应用程序的消息被发送到一个跳过的队列。不过从我所见，第二个使用者在 RabbitMq 中已正确配置。

我看不到我错过了什么。

编辑：在生产应用程序中，我也可以在第二个消费者中成功接收消息。但是从另一个 Web 应用程序它不起作用 - 也许与存在不同连接/通道的事实有关？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

asp.net-core masstransit