.NET中MassTransit+Azure Service Bus首次消息入死信队列问题咨询

核心问题 #

你的实现存在配置错误，导致首次消息进入死信队列的原因是MassTransit被错误地配置为订阅的消费者，但你没有提供对应的处理逻辑。

为什么首次消息会死信，第二次正常？ #

• 你在MassTransit配置中调用了cfg.SubscriptionEndpoint<ImportDataCheckRequested>("test-sub", ...)，这会让应用启动后，MassTransit自动创建一个接收端点来监听test-sub订阅的消息。
• 当第一条消息发送到主题时，MassTransit的接收端点会抢先获取消息，但因为你没有为这个端点配置任何消费者逻辑，消息无法被处理，经过Azure Service Bus的重试机制后，最终被移入死信队列。
• 第二次发送消息时，MassTransit的接收端点可能因之前的处理异常暂时无法正常接收消息，或者Service Bus的负载均衡将消息路由到了Azure Function的监听实例，因此Function能正常接收并处理。

正确的实现方式 #

1. 修正MassTransit配置 #

移除多余的SubscriptionEndpoint配置，因为你不需要MassTransit来消费订阅消息，只需要它负责发布消息到主题即可：

services.AddMassTransit(o =>
{
    o.AddConsumers(Assembly.GetExecutingAssembly());

    o.UsingAzureServiceBus((context, cfg) =>
    {
        cfg.Host(conString);

        // 仅配置消息发布，无需创建订阅端点
        cfg.Publish<ImportDataCheckRequested>();
        
        cfg.ConfigureEndpoints(context);
    });
});

2. 修正Azure Function触发器配置 #

你当前的ServiceBusTrigger参数有误，第一个参数应该是主题名称而非"queue"。MassTransit默认会使用消息类型的完全限定名作为主题名（比如YourAppNamespace.ImportDataCheckRequested），你可以根据实际情况替换：

[Function("Function1")]
public void Run([ServiceBusTrigger("your-topic-name", "test-sub", Connection = "Test")] string myQueueItem)
{
    _logger.LogInformation($"C# ServiceBus topic trigger function processed message: {myQueueItem}");
}

是否需要更换Function触发方式？ #

不需要，ServiceBusTrigger完全适用于监听Azure Service Bus订阅的场景，只要参数配置正确就能正常工作。

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