MassTransit v6.3.1+RabbitMQ v3：请求/响应模式下指定不同RoutingKey

好的，针对你的需求——在API网关用MassTransit请求/响应模式，同时为每个请求指定不同的RoutingKey（基于Topic交换），我来一步步给你拆解解决方案：

一、网关端：自定义请求客户端配置（替换默认Fanout交换） #

默认情况下，AddRequestClient会自动创建Fanout交换，这就是你遇到问题的根源。我们需要手动指定请求客户端使用Topic交换，并且允许动态设置RoutingKey：

1. 调整Startup.cs中的请求客户端注册 #

不要直接用cfg.AddRequestClient<ISimpleRequest>()，而是手动指定交换类型和地址：

cfg.AddRequestClient<ISimpleRequest>(context =>
{
    // 替换成你要使用的Topic交换名称，type=topic明确指定交换类型
    var topicExchangeUri = new Uri($"exchange:api-gateway-requests?type=topic");
    return context.CreateRequestClient<ISimpleRequest>(topicExchangeUri);
});

2. 发送请求时动态设置RoutingKey #

在控制器调用GetResponse的时候，通过重载方法传入配置委托，设置当前请求的RoutingKey：

// 这里可以根据请求参数动态生成RoutingKey，比如从请求路径、参数里取
var dynamicRoutingKey = $"user.{request.UserId}.request"; 

var response = await client.GetResponse<ISimpleResponse>(
    new { Data = "test request" }, 
    context =>
    {
        // 为当前请求设置专属RoutingKey
        context.SendContext.RoutingKey = dynamicRoutingKey;
    });

二、消费端：绑定到Topic交换并配置匹配的RoutingKey #

消费端需要明确绑定到你指定的Topic交换，并且设置对应的RoutingKey（支持通配符，比如user.*.request来匹配所有用户的请求）：

调整Startup.cs中的接收端点配置 #

cfg.ReceiveEndpoint("TestGateway", ep =>
{
    // 绑定到网关使用的Topic交换，指定交换类型和匹配的RoutingKey
    ep.Bind("api-gateway-requests", s =>
    {
        s.ExchangeType = ExchangeType.Topic;
        // 这里可以用具体的键，或者通配符，比如"user.#"匹配所有user开头的RoutingKey
        s.RoutingKey = "user.*.request"; 
    });

    ep.Consumer(() => new SimpleConsumer(context));
});

三、为什么你之前会遇到received 'fanout' but current is 'topic'错误？ #

你手动在RabbitMQ里创建了Topic交换，但默认的请求客户端会自动创建同名的Fanout交换，当MassTransit发现交换类型不匹配时，就会抛出这个错误。现在通过在请求客户端配置里明确指定type=topic，MassTransit会直接使用已有的Topic交换（或者自动创建Topic类型的交换），避免了类型冲突。

额外注意事项 #

• RabbitMQ的交换名称是区分大小写的，确保网关和消费端使用的交换名称完全一致。
• Topic交换的RoutingKey支持*（匹配一个词）和#（匹配零个或多个词）通配符，你可以根据业务需求灵活设置消费端的匹配规则。
• 如果需要针对不同业务场景使用不同的Topic交换，可以为不同的请求类型分别配置请求客户端。

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