为什么 MassTransit 中的简单配置会创建 2 个队列和 3 个交换机?

Eho*_*ret 5 c# masstransit rabbitmq .net-core

我创建了一个 MassTransit 快速启动程序来与我的本地主机 RabbitMQ 交互:

namespace ConsoleApp1
{
    public static class Program
    {
        public class YourMessage
        {
            public string Text { get; set; }
        }

        public static async Task Main(params string[] args)
        {
            var bus = Bus.Factory.CreateUsingRabbitMq(sbc =>
            {
                var host = sbc.Host(new Uri("rabbitmq://localhost"), h =>
                {
                    h.Username("guest");
                    h.Password("guest");
                });

                sbc.ReceiveEndpoint(host, "test_queue", ep =>
                {
                    ep.Handler<YourMessage>(async context => await Console.Out.WriteLineAsync($"Received: {context.Message.Text}"));
                });
            });

            await bus.StartAsync(); 
            await bus.Publish(new YourMessage{Text = "Hi"});
            Console.WriteLine("Press any key to exit");
            Console.ReadKey();
            await bus.StopAsync();
        }
    }
}
Run Code Online (Sandbox Code Playgroud)

一切看起来都很好,直到我实际检查了底层 RabbitMQ 管理并发现,仅仅为了这个非常简单的程序,MassTransit 创建了 3 个交换器和 2 个队列。

交易所,所有扇出:

  • ConsoleApp1:Program-YourMessage: 耐用的
  • VP0003748_dotnet_bus_6n9oyyfzxhyx9ybobdmpj8qeyt:自动删除且持久?
  • test_queue: 耐用的

队列:

  • VP0003748_dotnet_bus_6n9oyyfzxhyx9ybobdmpj8qeyt: x-过期 60000
  • test_queue: 耐用的

我想知道为什么所有这些都是必要的或者是默认配置?特别是,我不太确定创建如此“多”的意义。

Ale*_*rev 6

这一切都在文档中进行了描述。

ConsoleApp1:Program-YourMessage是消息合约交换,这里正在发布消息。

test_queue是端点交换。它绑定到消息交换。这样,当同一消息类型(发布-订阅)有多个使用者时,他们都会获得消息的副本。

test_queue是队列,它绑定到端点交换。RMQ 中的发布-订阅需要交换器和队列可以找到交换器,以便消息得到正确传递。

非持久队列和名称奇怪的交换器都是端点临时队列和交换器,用于请求响应。

  • 我在文档中找不到该信息,我可以阻止创建非持久队列和交换吗?我的意思是,如果我们不使用请求响应而只是常规发布呢?不同的 .NET 类型具有相同的交换名称也是一个问题吗? (2认同)
  • 只是想要一种方法,要么用更明确的东西来改变他们的名字,要么避免他们的创造。我的意思是,如果我们不使用 RabbitMQ 的这一功能,那么拥有它们还有什么意义呢? (2认同)