如何配置消费者错误队列绑定指定路由键？若不可行如何区分错误？

我有如下消费者代码：

public class TestConsumer : IConsumer<TestMessage> {
...
}

通过以下代码配置使用路由键：

cfg.ReceiveEndpoint("test_queue", e=> {
  e.Bind<TestMessage>(x => {
    x.RoutingKey = "test_routing_key"
  });
});

该配置会创建名为test_queue的队列，并将其绑定到交换机，路由键为test_routing_key。当消费者捕获到未处理异常时，会自动创建名为test_queue_error的错误队列，绑定到Fault-TestMessage交换机，但无路由键。

请问：

1. 如何配置该自动生成的错误队列，使其绑定到故障交换机时使用指定的路由键？我在官方文档中未找到相关配置方法。
2. 若该配置不可行，如何区分原交换机下不同消费者抛出的错误？

一、配置错误队列的自定义路由键 #

MassTransit默认的错误队列绑定逻辑未直接暴露路由键配置，但可以通过以下两种方式实现自定义：

方法1：通过ConfigureFault自定义故障消息行为 #

在接收端点配置中，用ConfigureFault方法指定故障消息的路由键，并同步绑定错误队列：

cfg.ReceiveEndpoint("test_queue", e =>
{
    e.Bind<TestMessage>(x => x.RoutingKey = "test_routing_key");
    
    // 自定义故障消息处理逻辑
    e.ConfigureFault<TestMessage>(cfg =>
    {
        // 为故障消息设置路由键
        cfg.Message<Fault<TestMessage>>(m =>
        {
            m.SetRoutingKey("test_routing_key_error");
        });
        // 绑定错误队列到故障交换机时使用该路由键
        cfg.BindFaultQueue("test_queue_error", x =>
        {
            x.RoutingKey = "test_routing_key_error";
        });
    });
});

方法2：添加自定义异常管道过滤器 #

通过自定义过滤器拦截异常，手动发布带指定路由键的故障消息，并完成错误队列的绑定：

public class CustomFaultFilter<T> : IFilter<ConsumeContext<T>> where T : class
{
    public async Task Send(ConsumeContext<T> context, IPipe<ConsumeContext<T>> next)
    {
        try
        {
            await next.Send(context);
        }
        catch (Exception ex)
        {
            // 手动创建并发布带路由键的故障消息
            var faultMessage = context.CreateFaultMessage(ex);
            await context.Publish(faultMessage, x =>
            {
                x.SetRoutingKey("test_routing_key_error");
            });
            
            // 手动声明并绑定错误队列到故障交换机
            var queueName = "test_queue_error";
            var faultExchangeName = $"Fault-{typeof(T).Name}";
            await context.Send(new CreateQueueBinding
            {
                QueueName = queueName,
                ExchangeName = faultExchangeName,
                RoutingKey = "test_routing_key_error"
            });
            
            throw; // 抛出异常让MassTransit继续原有流程
        }
    }

    public void Probe(ProbeContext context) { }
}

// 在消费者配置中注册过滤器
cfg.ReceiveEndpoint("test_queue", e =>
{
    e.Bind<TestMessage>(x => x.RoutingKey = "test_routing_key");
    e.UseFilter(new CustomFaultFilter<TestMessage>());
});

二、无法配置路由键时的错误区分方案 #

如果上述配置方式不适用，可通过以下方式区分不同消费者的错误：

• 自定义错误队列名称：通过ConfigureErrorQueue指定带标识的错误队列名，直接通过队列名区分来源：

  cfg.ReceiveEndpoint("test_queue", e =>
  {
      e.Bind<TestMessage>(x => x.RoutingKey = "test_routing_key");
      e.ConfigureErrorQueue("test_queue_test_routing_key_error");
  });
  

• 添加自定义元数据：在消费者业务逻辑中，为消息添加自定义头部字段，异常发生时这些字段会被包含在故障消息中，后续可通过解析Headers区分来源：

  public class TestConsumer : IConsumer<TestMessage>
  {
      public async Task Consume(ConsumeContext<TestMessage> context)
      {
          // 添加标识用的元数据
          context.Headers.Set("OriginalRoutingKey", "test_routing_key");
          context.Headers.Set("ConsumerName", nameof(TestConsumer));
          
          // 业务逻辑代码...
      }
  }
  

• 使用独立故障交换机：自定义故障消息发布逻辑，将不同路由键的消费者错误发送到专属故障交换机（比如Fault-TestMessage-test_routing_key），从交换机层面隔离错误来源。

内容的提问来源于stack exchange，提问作者שירה זילברמן