.NET 5 Azure Function中注入MessageReceiver实例报错如何解决？

问题根源 #

.NET 5 对应的是Azure Functions隔离工作进程模型，该模型和 .NET Core 3.1及更早的进程内模型运行机制不同，原生不支持直接在触发器参数中绑定MessageReceiver类型，运行时只会解析消息相关的字符串参数，所以才会出现类型转换报错。

可行实现方案 #

第一步：安装必要NuGet包 #

确保你已经安装了以下包：

• Microsoft.Azure.Functions.Worker.Extensions.ServiceBus 5.0+ 版本
• Azure.Messaging.ServiceBus （新的ServiceBus SDK，替代已过时的Microsoft.Azure.ServiceBus包）

第二步：手动解析接收器实例 #

你可以通过FunctionContext获取触发器的元数据，手动构造ServiceBusReceiver（新SDK中等价于MessageReceiver的类型，功能完全一致）实例：

[Function("MyFunction")]
public async Task Run([ServiceBusTrigger("myqueue", Connection = "sbconn")] MyMessage myMessage, FunctionContext context)
{
    // 从环境变量读取连接字符串
    var connectionString = Environment.GetEnvironmentVariable("sbconn");
    var queueName = "myqueue";
    
    // 构造接收器
    await using var client = new ServiceBusClient(connectionString);
    var receiver = client.CreateReceiver(queueName);
    
    // 后续即可执行死信、放弃消息、延迟消息等操作
    // 示例：死信当前消息
    var messageId = context.BindingContext.BindingData["MessageId"]?.ToString();
    await receiver.DeadLetterMessageAsync(new ServiceBusReceivedMessage(messageId));
}

性能优化方案 #

可以把ServiceBusClient注册为全局单例复用，避免重复创建带来的连接损耗：

1. 在Program.cs中注册服务：

var host = new HostBuilder()
    .ConfigureServices(services =>
    {
        services.AddSingleton<ServiceBusClient>(sp => 
        {
            var connectionString = Environment.GetEnvironmentVariable("sbconn");
            return new ServiceBusClient(connectionString);
        });
    })
    .Build();

host.Run();

2. 函数中直接注入使用：

public class MyFunction
{
    private readonly ServiceBusClient _sbClient;
    
    public MyFunction(ServiceBusClient sbClient)
    {
        _sbClient = sbClient;
    }
    
    [Function("MyFunction")]
    public async Task Run([ServiceBusTrigger("myqueue", Connection = "sbconn")] MyMessage myMessage, FunctionContext context)
    {
        var receiver = _sbClient.CreateReceiver("myqueue");
        // 执行业务逻辑
    }
}

注意：如果必须使用旧版的Microsoft.Azure.ServiceBus.Core.MessageReceiver，你需要降级到.NET Core 3.1的进程内Azure Functions模型，隔离模型仅支持新的Azure.Messaging.ServiceBus SDK下的接收器类型。

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