.NET 6 Azure Function ServiceBusTrigger如何手动实现消息死信

问题相关信息 #

• 问题场景：对Service Bus消息执行死信处理时找不到匹配的可用类库
• 已尝试调用的类：
  • MessageReceiver
  • ServiceBusReceiver
  • ServiceBusReceivedMessage
• 问题表现：以上类在使用时全部触发运行时错误
• 运行环境：.NET 6.0 版本 Azure Function

报错根因 #

出现运行时错误的核心原因是SDK版本不匹配、类使用方式不符合Azure Function绑定规则：

• 混用了不同世代的Service Bus SDK，旧版Microsoft.Azure.ServiceBus包中的类和新版SDK同名类存在加载冲突
• 手动构造接收客户端实例，脱离了Azure Function运行时的消息绑定上下文，导致锁校验、权限校验不通过

前置依赖配置 #

首先调整NuGet包引用，从根源避免类型冲突：

1. 卸载所有旧版Microsoft.Azure.ServiceBus相关包，该包为已停止更新的旧世代SDK，和.NET 6适配的新绑定存在兼容性问题
2. 安装适配.NET 6环境的稳定版绑定包：Microsoft.Azure.WebJobs.Extensions.ServiceBus 版本号≥5.0.0

正确实现代码（In Process托管模型，.NET 6 Azure Function默认模型） #

不要手动实例化接收客户端，直接通过触发器绑定注入的消息操作类执行死信逻辑，参考代码：

[FunctionName("HandleServiceBusMessage")]
public async Task ProcessMessage(
    [ServiceBusTrigger("目标队列/主题名称", Connection = "ServiceBus连接串配置项名称")]
    ServiceBusReceivedMessage message,
    ServiceBusMessageActions messageActions)
{
    // 自定义业务处理逻辑
    bool needDeadLetter = false;
    string deadLetterReason = string.Empty;
    string deadLetterDescription = string.Empty;

    // 业务校验或异常捕获判断需要死信时，直接调用注入实例的死信方法
    if (needDeadLetter)
    {
        await messageActions.DeadLetterMessageAsync(
            message,
            deadLetterReason: deadLetterReason,
            deadLetterErrorDescription: deadLetterDescription);
        return;
    }

    // 处理完成后无需手动调用完成方法，运行时会根据配置自动完成消息
}

注意事项：

• 死信操作必须在消息锁有效期内执行，超过锁时长后调用会抛出锁丢失异常
• 不要手动new ServiceBusReceiver或使用旧版MessageReceiver类执行操作，绑定注入的ServiceBusMessageActions已经和运行时上下文做了适配，手动构造的实例无法匹配函数的消息绑定状态
• 如果使用.NET 6 Isolated Worker隔离托管模型，仅需将参数类型替换为隔离模型对应的消息操作类，方法调用逻辑完全一致

常见异常排查 #

• 提示类型不存在或类型转换失败：检查是否清理干净旧版SDK的引用，清理后重新生成项目即可解决
• 提示无权限操作消息：检查Service Bus连接串的权限配置，确保配置的访问策略包含消息发送、管理权限
• 提示消息已完成处理：检查是否开启了函数的自动完成配置，自动完成开启时不要在业务逻辑执行完成后再异步调用死信方法

内容的提问来源于stack exchange，提问作者Robert Green MBA