如何在Azure函数中立即发送ServiceBusOutput绑定消息而非返回时发送

安全阿岳

2026-6-20

解决方案

你可以通过注入ICollector<string>或IAsyncCollector<string>类型的输出绑定来实现，无需返回OutputBindings类，直接添加消息即可自动发送到队列。

具体实现步骤

同步场景实现
修改函数端点的参数列表，注入对应两个队列的ICollector<string>，兼容原有代码结构的示例如下：

public static void Run(
    [HttpTrigger(AuthorizationLevel.Function, "post", Route = null)] HttpRequest req,
    [ServiceBus("%Queue1%", Connection = "ConnnectionString1")] ICollector<string> queue1Collector,
    [ServiceBus("%Queue2%", Connection = "ConnnectionString2")] ICollector<string> queue2Collector,
    ILogger log)
{
    // 保留原有实例化OutputBindings的逻辑
    var outputBindings = new OutputBindings();
    // 按原有逻辑设置消息内容
    outputBindings.Queue1 = "队列1的消息内容";
    outputBindings.Queue2 = "队列2的消息内容";

    // 将消息添加到collector，运行时会自动发送至对应队列
    queue1Collector.Add(outputBindings.Queue1);
    queue2Collector.Add(outputBindings.Queue2);
}

异步场景实现
如果你的函数是异步逻辑，改用IAsyncCollector<string>并调用异步添加方法：

public static async Task Run(
    [HttpTrigger(AuthorizationLevel.Function, "post", Route = null)] HttpRequest req,
    [ServiceBus("%Queue1%", Connection = "ConnnectionString1")] IAsyncCollector<string> queue1Collector,
    [ServiceBus("%Queue2%", Connection = "ConnnectionString2")] IAsyncCollector<string> queue2Collector,
    ILogger log)
{
    var outputBindings = new OutputBindings();
    outputBindings.Queue1 = "队列1的异步消息内容";
    outputBindings.Queue2 = "队列2的异步消息内容";

    await queue1Collector.AddAsync(outputBindings.Queue1);
    await queue2Collector.AddAsync(outputBindings.Queue2);
}