升级MassTransit至8.3.5后注入IRequestClient<>遇异常求助

问题描述 #

未修改任何配置，将MassTransit从8.3.3升级至8.3.5后，注入IRequestClient<>时出现如下异常：

MassTransit.MassTransitException: Unable to resolve client factory or mediator for request client: <MyRequestTye>
   at MassTransit.DependencyInjection.GenericRequestClient`1.GetRequestClient(IServiceProvider provider) in /_/src/MassTransit/DependencyInjection/DependencyInjection/GenericRequestClient.cs:line 137
   at MassTransit.DependencyInjection.GenericRequestClient`1..ctor(IServiceProvider provider) in /_/src/MassTransit/DependencyInjection/DependencyInjection/GenericRequestClient.cs:line 18

仅回退MassTransit至8.3.3后恢复正常，使用的配置代码如下：

builder.Services.AddMassTransit<TBus>(x =>
{
    var opts = builder.Configuration.GetRequiredSection(key).Get<RabbitMQOptions>() ?? throw new ConfigurationException($"Configuration key '{key}' of type '{nameof(RabbitMQOptions)}' missing!");

    foreach (var consumer in consumers)
    {
        x.AddConsumer(consumer);
    }

    foreach (var request in requestTypes)
    {
        x.AddRequestClient(request);
    }

    x.UsingRabbitMq((context, cfg) =>
    {
        cfg.Host(opts.Host, opts.Port, bus, builder.Environment.ApplicationName, h =>
        {
            h.Username(opts.UserName);
            h.Password(opts.Password);
            h.Heartbeat(30);
        });

        cfg.ConfigureJsonSerializerOptions(options => options
            .AddConvertersFrom(CustomJsonSerializationOptions.ContractOptions)
            .ConfigureForNodaTime(DateTimeZoneProviders.Tzdb)
            );

        cfg.ConfigureEndpoints(context, new KebabCaseEndpointNameFormatter(bus, false));
    });
});

在MassTransit 8.3.5升级文档中未找到相关说明。

解决方案 #

1. 统一所有MassTransit相关包版本 #

升级时容易出现主包升级到8.3.5，但依赖包（如MassTransit.RabbitMQ、MassTransit.Extensions.DependencyInjection等）仍停留在旧版本的情况，这会导致DI容器无法正确注册请求客户端工厂。

• 检查项目中所有MassTransit NuGet包的版本，统一设置为8.3.5

2. 验证自定义Bus类型的注册（针对AddMassTransit<TBus>场景） #

如果TBus是自定义Bus接口/类型，确保它正确继承自IBus，并且在DI容器中被正确注册。新版本对泛型参数约束更严格，可尝试替换为非泛型AddMassTransit方法测试：

builder.Services.AddMassTransit(x =>
{
    // 原配置内容保持不变
});

3. 显式指定RequestClient的端点配置 #

尝试在AddRequestClient时显式指定发送端点，确保DI能正确解析客户端：

foreach (var request in requestTypes)
{
    x.AddRequestClient(request, context =>
    {
        var endpointUri = new Uri($"exchange:{bus}-{request.Name}");
        return context.GetSendEndpoint(endpointUri);
    });
}

4. 排查Mediator相关配置 #

如果项目未使用MassTransit Mediator，确保配置中没有添加相关注册。新版本中Mediator与Bus的客户端工厂注册逻辑有区分，误配置会导致解析冲突。

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