使用MassTransit如何提前自动创建Azure Service Bus错误队列？

方法一：通过MassTransit配置显式创建错误队列 #

MassTransit支持在总线配置阶段直接指定预创建错误队列，无需等待错误触发。你可以在AddMassTransit的配置逻辑中，通过端点配置实现这一点。

示例代码（.NET）：

services.AddMassTransit(x =>
{
    // 注册消费者、消息类型等业务逻辑...

    x.UsingAzureServiceBus((context, cfg) =>
    {
        cfg.Host("你的Azure Service Bus连接字符串");

        // 针对指定消息类型显式创建对应_error队列
        cfg.QueueEndpoint<Fault<你的消息类型>>("业务队列名称_error", e =>
        {
            // 根据需求配置队列属性
            e.AutoDeleteOnIdle = TimeSpan.FromDays(7);
            e.MaxSizeInMegabytes = 1024;
        });

        // 或者使用格式化器自动为所有消费者队列创建错误队列
        cfg.ConfigureEndpoints(context, new KebabCaseEndpointNameFormatter(true));
    });
});

注：Fault<你的消息类型>是MassTransit用于封装错误消息的泛型类型，指定该类型的队列端点会自动匹配业务队列的_error后缀规则。若需覆盖多个业务队列，可针对各消息类型逐一配置。

方法二：用Azure Service Bus管理客户端手动预创建 #

如果不想通过MassTransit代码耦合，可直接使用Azure Service Bus管理客户端，在应用启动时检查并创建错误队列。

示例代码（.NET）：

using Azure.Messaging.ServiceBus.Administration;

var adminClient = new ServiceBusAdministrationClient("你的Azure Service Bus连接字符串");
var errorQueueName = "业务队列名称_error";

if (!await adminClient.QueueExistsAsync(errorQueueName))
{
    await adminClient.CreateQueueAsync(new CreateQueueOptions(errorQueueName)
    {
        AutoDeleteOnIdle = TimeSpan.FromDays(7),
        MaxSizeInMegabytes = 1024,
        // 按需配置死信、分区等其他属性
    });
}

将这段代码放在应用启动初始化逻辑中（比如Program.cs的启动段），即可确保应用启动时完成错误队列的预创建。

方法三：通过Azure Portal或Azure CLI手动创建 #

若偏好无代码操作，可直接在Azure Portal或通过CLI完成预创建：

Azure Portal操作 #

1. 登录Azure Portal，进入目标Service Bus命名空间
2. 左侧菜单选择「队列」，点击「+ 队列」
3. 输入队列名称（如业务队列名称_error），配置好自动删除时间、容量等属性后，点击创建

Azure CLI命令 #

az servicebus queue create --resource-group 你的资源组名 --namespace-name 你的命名空间名 --name 业务队列名称_error --auto-delete-on-idle P7D --max-size 1024

关键注意事项 #

• 错误队列命名必须遵循MassTransit默认规则：业务队列名称 + _error后缀，否则MassTransit无法自动将错误消息路由到该队列。
• 错误队列的属性（如分区、会话支持）需与对应业务队列保持一致，避免兼容性问题。
• 使用KebabCaseEndpointNameFormatter时，第二个参数设为true，会自动为每个消费者队列生成对应的错误队列。

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