c# - 如何使用 MassTransit 为多个消费者订阅一个队列？

Question

我正在使用 Azure 服务总线作为 MassTransit 的传输，并且我正在尝试将消息(命令)发送到队列:

var sendEndpoint = await busControl.GetSendEndpoint(sericeUri);
sendEndpoint.Send<ISimpleRequest>(new SimpleRequest(customerId));

我还尝试通过两个消费者连接到该队列:

var _busControl = Bus.Factory.CreateUsingAzureServiceBus(cfg =>
            {
                var host =  cfg.Host("...", h =>
                {
                    h.OperationTimeout = TimeSpan.FromMinutes(1);
                });
                cfg.ReceiveEndpoint(host, "queueName",
                    e => { e.Consumer<RequestConsumer>(); });
                cfg.UseServiceBusMessageScheduler();
            });

第二个消费者具有相同队列名称的相同代码。我发送消息后，只有一个消费者收到响应。那么我如何配置它以与两个或更多消费者一起使用？

Answer 1

如果您想获取消息的两份副本，每个消费者一份，则应使用两个单独的队列并发布消息。在这种情况下，MassTransit 会将其发送到主题，每个队列都会收到从主题转发的副本。