我创建了一个 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 : 耐用

  • 我想知道为什么所有这些都是必要的还是默认配置?特别是,我不太确定要创建这么多“许多”。

    最佳答案

    这一切都在 documentation 中进行了描述。
    ConsoleApp1:Program-YourMessage 是消息合约交换,这里正在发布消息。
    test_queue 是端点交换。它绑定(bind)到消息交换。这样,当您有多个消费者使用相同的消息类型 (pub-sub) 时,他们都会获得消息的副本。
    test_queue 是队列,它绑定(bind)到端点交换。 RMQ 中的发布订阅需要交换器和队列可以找到交换器,因此消息才能正确传递。

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

    关于c# - 为什么 MassTransit 中的简单配置会创建 2 个队列和 3 个交换?,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/56064182/

    10-16 02:15