Azure Functions用MassTransit发布到RabbitMQ遇配置异常求助

问题根源 #

你遇到的SetBusFactory can be called only once异常，是因为AddMassTransitForAzureFunctions方法在传入第二个参数"AzureWebJobsServiceBus"时，内部会自动配置Azure Service Bus的总线工厂；而你又手动调用UsingRabbitMq配置了RabbitMQ传输，导致总线工厂被重复设置，触发了MassTransit的配置校验异常。

Azure Functions本身支持RabbitMQ，问题出在MassTransit扩展方法的使用方式上。

解决方案 #

通过环境区分配置逻辑，本地开发时配置RabbitMQ，生产环境配置Azure Service Bus，避免同时初始化两种传输。修改你的Startup.cs代码如下：

using Microsoft.Extensions.Hosting;

public override void Configure(IFunctionsHostBuilder builder)
{
    var config = builder.Services.BuildServiceProvider().GetRequiredService<IConfiguration>();
    var isLocalDev = config.GetValue<string>("FUNCTIONS_ENVIRONMENT") == Environments.Development;

    builder
        .Services
        .AddScoped<MyService1>()
        .AddScoped<MyService2>()
        .AddMassTransitForAzureFunctions(mtConfig =>
        {
            mtConfig.SetKebabCaseEndpointNameFormatter();

            if (isLocalDev)
            {
                // 本地开发环境配置RabbitMQ
                mtConfig.UsingRabbitMq((context, rmqConfig) =>
                {
                    rmqConfig.Host("localhost", "/", h =>
                    {
                        h.Username("guest");
                        h.Password("guest");
                    });
                    // 按需添加RabbitMQ的其他配置（如接收端点、序列化方式等）
                });
            }
            else
            {
                // 生产环境配置Azure Service Bus
                var sbConnection = config.GetConnectionString("AzureWebJobsServiceBus");
                mtConfig.UsingAzureServiceBus((context, sbConfig) =>
                {
                    sbConfig.Host(sbConnection);
                    // 按需添加Azure Service Bus的其他配置
                });
            }
        });
}

关键说明 #

1. 环境判断：使用Azure Functions默认的FUNCTIONS_ENVIRONMENT变量区分环境，本地开发时该变量值为Development，生产环境为Production。
2. 避免重载冲突：不再使用带连接字符串参数的AddMassTransitForAzureFunctions重载，改为手动根据环境配置对应传输，彻底避免总线工厂重复设置的问题。
3. 配置完整性：根据业务需求，可在对应传输的配置块中添加接收端点、序列化规则等额外配置。

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