Azure Function+MassTransit中ServiceBusReceivedMessage反序列化异常求助

问题原因 #

1. 隔离进程模型绑定限制：你使用的是.NET Worker（隔离进程）Azure Function，该模型下ServiceBusTrigger默认会尝试将消息体反序列化为参数类型。但ServiceBusReceivedMessage是Azure Service Bus SDK的内部类型，无无参构造函数、不支持JSON反序列化，直接作为参数会触发转换异常。
2. MassTransit集成方式错误：手动编写原生ServiceBusTrigger函数后调用MassTransit的HandleConsumer，违背了MassTransit与Azure Function的集成规范。MassTransit提供了专门的扩展来直接绑定触发器并管理消费者，无需手动处理ServiceBusReceivedMessage。

解决办法 #

方案一：正确集成MassTransit（推荐） #

1. 安装依赖包

Install-Package MassTransit.Azure.Functions.Worker
Install-Package Microsoft.Azure.Functions.Worker.Extensions.ServiceBus

2. 配置MassTransit并注册消费者

在Program.cs中替换原生配置，让MassTransit接管ServiceBus触发器：

using MassTransit;
using Microsoft.Azure.Functions.Worker;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;

var host = new HostBuilder()
    .ConfigureFunctionsWorkerDefaults()
    .ConfigureServices(services =>
    {
        services.AddMassTransitForAzureFunctions(cfg =>
        {
            // 注册你的消费者
            cfg.AddConsumer<TestConsumer>();

            cfg.UsingAzureServiceBus((context, busCfg) =>
            {
                busCfg.Host("你的ServiceBus连接字符串");

                // 绑定主题与订阅
                busCfg.SubscriptionEndpoint(_topic, _sub, e =>
                {
                    e.ConfigureConsumer<TestConsumer>(context);
                });
            });
        });
    })
    .Build();

host.Run();

3. 实现消费者逻辑

删除手动编写的Function1，直接实现消费者类即可：

public class TestConsumer : IConsumer<TestMessage>
{
    public async Task Consume(ConsumeContext<TestMessage> context)
    {
        // 处理消息逻辑
        var testContent = context.Message.Test;
        // ...
    }
}

方案二：使用原生ServiceBusTrigger（不推荐与MassTransit混用） #

若坚持使用原生触发器，需调整参数绑定逻辑，且不要与MassTransit的消费者逻辑混用：

[Function("Function1")]
public async Task Run(
    [ServiceBusTrigger(_topic, _sub, Connection = "ServiceBusConnection")] 
    ServiceBusReceivedMessage message,
    ServiceBusMessageActions messageAction,
    FunctionContext context)
{
    // 手动反序列化消息体
    var testMessage = JsonSerializer.Deserialize<TestMessage>(message.Body);
    
    // 处理消息逻辑
    // ...

    // 手动完成消息
    await messageAction.CompleteMessageAsync(message);
}

关键注意事项 #

• 结合MassTransit时，必须使用AddMassTransitForAzureFunctions扩展，它会自动处理触发器绑定与消费者调度，无需手动编写触发器函数。
• 禁止同时使用原生ServiceBusTrigger和MassTransit消费者逻辑，两者消息处理机制冲突，会引发序列化或调度异常。

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