MassTransit RabbitMq 发送消息

Question

我无法弄清楚在发送/发布消息时如何在我的GetSendEndpoint()) 任务中指定Exchange 和Queue？

根据 MassTransit 文档https://masstransit-project.com/usage/producers.html#send，您可以像这样指定交换和队列

GetSendEndpoint(new Uri("queue:input-queue"))

但是，我只能做其中一个吗？

是否有指定交换和队列的替代发送方式？

我在 Asp.Net Core 中执行此操作，所以这是我的配置：

Startup.cs

public void ConfigureServices(IServiceCollection services)
{
   services.AddMassTransit();

   services.AddSingleton(p => Bus.Factory.CreateUsingRabbitMq(cfg =>
   {
         cfg.Host("rabbitmq://localhost", h =>
         {
             h.Username("admin");
             h.Password("admin");
         });
   }));

   services.AddSingleton<IBus>(p => p.GetRequiredService<IBusControl>());
   services.AddSingleton<IHostedService, BusService>();
}

这就是发送消息的方式

var endpoint = await _bus.GetSendEndpoint(new Uri(queue:Test.Queue));
await endpoint.Send(new Message()
{
     Text = "This is a test message"
});

如您所见，我只能指定队列名称。

Answer 1

如果您指定交易所，则仅在代理上声明交易所。消息将直接发送到交易所。

"exchange:your-exchange-name"

如果你指定了一个队列，这个队列会连同一个同名的交换器一起被声明并且交换器将被绑定到队列中。消息将被传递到同名的交换器，该交换器将它们传递到队列。

"queue:your-queue-name"

如果您想要不同的交换和队列名称，您可以使用以下命令同时指定：

"exchange:your-exchange-name?bind=true&queue=your-queue-name"

或者你可以简化，但是两个队列有点混乱：

"queue:your-exchange-name&queue=your-queue-name"

Answer 2

在此处阅读 Chris 的回复 Mass Transit : No consumer

好像Exchanges are created by MassTransit when publishing messages, based on the message types. Publishing does not create any queues. Queues are where messages are stored for delivery to consumers.

和Queues are created when receive endpoints are added to a bus. For the consumers, handlers, and sagas added to a receive endpoint, the exchanges are created and bound so that messages published to the exchanges are received by the receive endpoint (via the queue).

所以如果我的发布者没有定义接收端点，那么我发送的任何消息都会丢失，因为没有队列或绑定？

进一步阅读这里https://groups.google.com/forum/#!topic/masstransit-discuss/oVzZkg1os9o 似乎进一步证实了这一点。

因此，基于上面的链接，为了实现我想要的，即创建交换并将其绑定到队列，我需要在 Uri 中指定它

var sendEndpoint = bus.GetSendEndpoint(new Uri("rabbitmq://localhost/vhost1/exchange1?bind=true&queue=queue1"));

exchange1 是 Exchange，queue1 是队列，bind=true 会将队列绑定到交换机。

如果坚持最初的 MT 设计，是否需要先运行消费者才能设置交换和队列，然后生产者才能开始发布？这似乎减少了发布者的灵活性？