MassTransit请求响应多消费者负载均衡异常问题咨询

我查阅MassTransit文档得知，同一接收端点连接多个消费者时，请求会在消费者间负载均衡，仅一个消费者会执行。但实际配置后，两个消费者会并发执行。请问是配置有误还是我的理解错误？

配置代码 #

builder.Services.AddMassTransit(configure =>
{
    configure.SetKebabCaseEndpointNameFormatter();
    configure.AddConsumer<ObjectCreatedEventHandlerFirst>()
        .Endpoint(x => { x.Name = "custom-endpoint"; });
    configure.AddConsumer<ObjectCreatedEventHandlerSecond>()
        .Endpoint(x => { x.Name = "custom-endpoint"; });
    configure.AddRequestClient<ObjectCreatedEvent>(new Uri("exchange:custom-endpoint"));
    configure.UsingRabbitMq((context, cfg) =>
    {
        cfg.Host(rabbitMqSettings.Host, h =>
        {
            h.Username(rabbitMqSettings.User);
            h.Password(rabbitMqSettings.Password);
        });
        cfg.ConfigureEndpoints(context);
    });
});

请求发起代码 #

app.MapGet("/",
async (IRequestClient<ObjectCreatedEvent> requestClient) =>
{
    var response =
        await requestClient.GetResponse<ObjectDeletedEvent>(
            new(Guid.NewGuid(), "123"));
    return response.Message.Name;
});

消费者代码 #

public class ObjectCreatedEventHandlerFirst
    : IConsumer<ObjectCreatedEvent>
{

    public async Task Consume(ConsumeContext<ObjectCreatedEvent> context)
    {
        await context.RespondAsync<ObjectDeletedEvent>(
            new(Guid.NewGuid(), "1"));
    }
}

public class ObjectCreatedEventHandlerSecond
    : IConsumer<ObjectCreatedEvent>
{
    public async Task Consume(ConsumeContext<ObjectCreatedEvent> context)
    {
        await context.RespondAsync<ObjectDeletedEvent>(
            new(Guid.NewGuid(), "2"));
    }
}

你的理解和配置都存在偏差：

• 理解偏差：MassTransit中，同一端点绑定多个消费者时，每个消费者都会收到并处理消息，而非负载均衡仅执行一个。负载均衡针对的是同一消费者的多个实例（比如横向扩展部署多个服务实例，每个实例里的消费者会分摊消息），而非同一端点下的不同消费者类型。

• 配置问题：当前配置把两个不同的消费者都绑定到了同一个custom-endpoint端点，这会导致该端点收到的ObjectCreatedEvent消息被两个消费者同时消费。

如果要实现“同一请求仅被一个消费者处理”的效果，有两种可行方案：

• 方案一：竞争消费者模式：只注册一个消费者类型，部署多个服务实例，MassTransit会自动在这些实例间做负载均衡，每个消息仅被一个实例的消费者处理。
• 方案二：消息路由机制：为不同消费者配置独立端点，通过请求客户端指定对应的端点，或使用消息过滤规则将消息路由到特定消费者。

如果业务需求是让两个消费者处理不同场景的同一消息，当前配置符合预期；如果是想让请求在两个消费者间二选一，则需要调整配置或变更实现方式。

内容的提问来源于stack exchange，提问作者Kosmonik