为什么 MassTransit 中的简单配置会创建 2 个队列和 3 个交换?
Why a simple configuration in MassTransit creates 2 queues and 3 exchanges?
我创建了一个 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
:耐用
我想知道为什么所有这些都是必需的或者是默认配置?特别是,我不太确定要创建 so "many".
中都有描述
ConsoleApp1:Program-YourMessage
是消息合约交易所,这里正在发布消息。
test_queue
是端点交换。它绑定到消息交换。这样,当您有多个消费者使用相同的消息类型 (pub-sub) 时,他们都会获得消息的副本。
test_queue
是队列,它绑定到端点交换。 Publish-subscribe 在 RMQ 中需要交换器,队列可以找到交换器,因此消息可以正确传递。
名字怪异的non-durable队列和交换都是端点临时队列和交换,用于request-response。
我创建了一个 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 60000test_queue
:耐用
我想知道为什么所有这些都是必需的或者是默认配置?特别是,我不太确定要创建 so "many".
ConsoleApp1:Program-YourMessage
是消息合约交易所,这里正在发布消息。
test_queue
是端点交换。它绑定到消息交换。这样,当您有多个消费者使用相同的消息类型 (pub-sub) 时,他们都会获得消息的副本。
test_queue
是队列,它绑定到端点交换。 Publish-subscribe 在 RMQ 中需要交换器,队列可以找到交换器,因此消息可以正确传递。
名字怪异的non-durable队列和交换都是端点临时队列和交换,用于request-response。