如何在Azure函数应用的Service Bus触发器中显式确认消息

先解决绑定错误与依赖问题 #

1. 安装正确的NuGet包 #

确保项目引用最新版的ServiceBus函数扩展包，在.csproj中添加或更新：

<PackageReference Include="Microsoft.Azure.Functions.Worker.Extensions.ServiceBus" Version="5.15.0" />
<PackageReference Include="Microsoft.Azure.Functions.Worker" Version="1.20.0" />

2. 注册ServiceBus服务 #

根据函数运行模式选择对应注册方式：

• Isolated进程模式（.NET 6+推荐）：在Program.cs中添加

var host = new HostBuilder()
    .ConfigureFunctionsWorkerDefaults()
    .AddServiceBus() // 必须注册ServiceBus扩展
    .Build();

host.Run();

• In-Process进程模式：在Startup.cs中添加

public class Startup : FunctionsStartup
{
    public override void Configure(IFunctionsHostBuilder builder)
    {
        builder.AddServiceBus();
    }
}

3. 解决ServiceBusMessageActions找不到的问题 #

在函数文件顶部添加命名空间引用：

using Azure.Messaging.ServiceBus;

批量消息显式确认的正确实现 #

核心逻辑 #

• 批量业务处理成功：确认所有消息，从队列移除
• 数据类错误（如消息格式无效、数据非法）：确认消息（或标记为死信），避免重复处理
• 临时故障（如依赖服务不可用、网络波动）：不做确认操作，让ServiceBus自动重试消息

修正后的代码示例 #

[Function("ProcessUserProfile")]
public async Task Run(
    [ServiceBusTrigger("events.userprofile", Connection = "AzureWebJobsServiceBus", AutoComplete = false)] 
    ServiceBusReceivedMessage[] myQueueItems,
    ServiceBusMessageActions messageActions,
    ILogger log)
{
    try
    {
        bool processingSuccess = await fancyBusiness(myQueueItems);
        
        if (processingSuccess)
        {
            // 批量确认消息，比逐个确认更高效
            await messageActions.CompleteMessagesAsync(myQueueItems);
            log.LogInformation("批量处理成功，已确认所有消息");
        }
        else
        {
            // 数据错误场景：确认消息避免重试，若需留存错误数据可改用DeadLetterMessagesAsync
            await messageActions.CompleteMessagesAsync(myQueueItems);
            log.LogWarning("数据验证失败，已确认消息");
        }
    }
    catch (Exception ex) when (IsTemporaryFailure(ex))
    {
        // 临时故障：不做任何确认，ServiceBus会自动释放锁让消息重试
        log.LogError(ex, "遇到临时故障，消息将被重试");
    }
}

// 自定义判断临时故障的逻辑
private bool IsTemporaryFailure(Exception ex)
{
    // 匹配网络异常、依赖超时等临时错误类型
    return ex is HttpRequestException || ex is TimeoutException;
}

关键注意点 #

• 用ServiceBusMessageActions替代ServiceBusReceiver：这是当前SDK推荐的绑定方式，支持批量操作，避免绑定错误
• 批量确认优先用CompleteMessagesAsync：性能优于逐个调用CompleteMessageAsync
• 临时故障无需额外操作：不调用Abandon，函数正常结束后，ServiceBus会根据LockDuration自动释放锁，消息回到队列
• 数据错误灵活处理：无效数据可直接确认移除，需归档的错误数据可移入死信队列

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