.NET 5 独立进程 Azure Functions 如何实现 ServiceBus 多消息输出？

你正在使用.NET 5版本的隔离进程模型Azure Functions对接Service Bus，需要从触发函数中发送多条消息。在旧版进程内（In-Process）模型中，可以通过IAsyncCollector实现批量发送，示例代码如下：

[FunctionName("HttpToServiceBusQueue")]
public static async Task<IActionResult> Run(
    [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post", Route = null)] HttpRequest req,
    [ServiceBus("testqueue",Connection ="connectionString")] IAsyncCollector<string> outputEvents,
    ILogger log)
{
    log.LogInformation("C# HTTP trigger function processed a request.");
    // ...
    
    await outputEvents.AddAsync("message1");
    await outputEvents.AddAsync("message2");

    // ...
    return new OkObjectResult(responseMessage);
}

隔离进程模型不再支持IAsyncCollector，你当前将消息列表整体序列化后返回的实现确实不够规范，这种方式依赖隐式的类型转换逻辑，可读性和可维护性都较差，以下是两种规范的替代实现方案。

方案1：返回IEnumerable<T>类型的输出绑定（推荐简单场景） #

隔离进程模型的Service Bus输出绑定原生支持集合类型返回值，直接返回消息集合即可，框架会自动将集合中的每个元素作为独立的消息发送到队列/主题，完全可以替代原来的IAsyncCollector能力。
示例代码如下：

[Function("FileTriggerFunction")]
[ServiceBusOutput("fileupload", Connection = "ServiceBusConnectionWrite")]
public IEnumerable<string> Run(
    [BlobTrigger("file-storage/{name}", Connection = "ConnectionString")] string myBlob, string name,
    FunctionContext context)
{
    var logger = context.GetLogger("FileTriggerFunction");
    // 构造需要发送的消息列表，支持自定义类型，框架会自动做序列化处理
    var messageList = new List<string>
    {
        "message1",
        "message2"
        // 追加更多需要发送的消息
    };
    logger.LogInformation($"准备发送{messageList.Count}条消息到Service Bus");
    // 直接返回集合即可，无需手动序列化
    return messageList;
}

该方案优势：

• 写法简洁，完全符合Azure Functions输出绑定的设计规范
• 无需手动处理序列化，框架自动完成类型转换
• 不需要额外引入第三方依赖

方案2：手动实例化ServiceBusClient发送（推荐复杂场景） #

如果需要对消息做更精细的控制，比如设置自定义属性、定时发送、事务控制、批量发送参数配置等，可以直接使用官方Service Bus SDK手动发送消息。

实现步骤 #

1. 安装NuGet依赖包：Azure.Messaging.ServiceBus
2. 在程序启动文件Program.cs中注册ServiceBusClient为单例，避免重复创建客户端带来的性能损耗：

var host = new HostBuilder()
    .ConfigureFunctionsWorkerDefaults()
    .ConfigureServices(services =>
    {
        services.AddSingleton<ServiceBusClient>(sp => 
        {
            // 从环境变量读取Service Bus连接字符串
            var connectionString = Environment.GetEnvironmentVariable("ServiceBusConnectionWrite");
            return new ServiceBusClient(connectionString);
        });
    })
    .Build();

host.Run();

3. 改造函数代码，注入ServiceBusClient完成消息发送：

public class FileTriggerFunction
{
    private readonly ServiceBusClient _serviceBusClient;

    // 构造函数注入ServiceBusClient
    public FileTriggerFunction(ServiceBusClient serviceBusClient)
    {
        _serviceBusClient = serviceBusClient;
    }

    [Function("FileTriggerFunction")]
    public async Task Run(
        [BlobTrigger("file-storage/{name}", Connection = "ConnectionString")] string myBlob, string name,
        FunctionContext context)
    {
        var logger = context.GetLogger<FileTriggerFunction>();
        // 创建队列发送器
        using var sender = _serviceBusClient.CreateSender("fileupload");
        
        // 构造Service Bus消息列表，支持自定义配置
        var serviceBusMessages = new List<ServiceBusMessage>
        {
            new ServiceBusMessage("message1")
            {
                // 可配置消息的自定义属性、延迟发送时间、消息Id等参数
                ApplicationProperties = { {"customKey", "customValue"} }
            },
            new ServiceBusMessage("message2")
        };

        // 批量发送消息
        await sender.SendMessagesAsync(serviceBusMessages);
        logger.LogInformation($"{serviceBusMessages.Count}条消息已成功发送到Service Bus");
    }
}

该方案优势：

• 灵活度极高，支持所有Service Bus原生特性
• 完全可控消息发送的全流程，适合复杂业务场景

• 如果你只是需要简单发送多条消息，没有额外定制需求，优先选择方案1，代码量最少且符合框架设计规范
• 如果你需要用到消息自定义属性、事务、延迟发送等高级能力，选择方案2

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