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

eh57zj3b  于 2023-06-23  发布在  RabbitMQ
关注(0)|答案(1)|浏览(162)

我创建了一个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();
        }
    }
}

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

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

队列:

  • VP0003748_dotnet_bus_6n9oyyfzxhyx9ybobdmpj8qeyt:x-expire 60000
  • test_queue:耐用

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

vc9ivgsu

vc9ivgsu1#

所有这些都在文档中描述。
ConsoleApp1:Program-YourMessage是消息合约交换,这里消息正在发布。
test_queue是端点交换。它绑定到消息交换。这样,当同一消息类型(pub-sub)有多个消费者时,他们都可以获得消息的副本。
test_queue是绑定到端点交换的队列。RMQ中的发布-订阅需要交换,队列可以找到交换,因此消息可以正确传递。
非持久性队列和名称怪异的交换都是端点临时队列和交换,用于请求-响应。

相关问题