如何基于业务逻辑通过MassTransit向RabbitMQ不同队列发送消息

1. 直接通过SendEndpoint指定队列名称 #

这是动态选择队列场景下最灵活的实现方式，通过ISendEndpointProvider获取目标队列的发送端点后即可发送消息。

示例代码（.NET环境）：

public class OrderService
{
    private readonly ISendEndpointProvider _sendEndpointProvider;

    public OrderService(ISendEndpointProvider sendEndpointProvider)
    {
        _sendEndpointProvider = sendEndpointProvider;
    }

    public async Task ProcessOrder(Order order)
    {
        // 根据业务逻辑动态确定目标队列
        string targetQueue = order.IsPriority ? "priority-order-queue" : "regular-order-queue";

        // 获取指定队列的发送端点（注意前缀`queue:`是MassTransit识别RabbitMQ队列的标准格式）
        var sendEndpoint = await _sendEndpointProvider.GetSendEndpoint(new Uri($"queue:{targetQueue}"));

        // 发送消息到目标队列
        await sendEndpoint.Send(order);
    }
}

2. 结合消息类型配置实现路由 #

如果业务逻辑和消息类型强关联，可以在MassTransit启动配置阶段，为不同消息类型绑定固定队列，业务层只需发送对应类型的消息即可。

配置示例：

services.AddMassTransit(x =>
{
    x.SetKebabCaseEndpointNameFormatter();

    x.UsingRabbitMq((context, cfg) =>
    {
        cfg.Host("localhost", "/", h =>
        {
            h.Username("guest");
            h.Password("guest");
        });

        // 为特定消息类型绑定指定队列
        cfg.Message<PriorityOrder>(m => m.SetEntityName("priority-order-queue"));
        cfg.Message<RegularOrder>(m => m.SetEntityName("regular-order-queue"));

        cfg.ConfigureEndpoints(context);
    });
});

业务层代码：

public async Task ProcessOrder(Order order, IPublishEndpoint publishEndpoint)
{
    if (order.IsPriority)
        await publishEndpoint.Publish(new PriorityOrder(order));
    else
        await publishEndpoint.Publish(new RegularOrder(order));
}

3. 通过IBus直接指定队列发送 #

若不想依赖ISendEndpointProvider，也可直接通过IBus的Send方法传入队列地址：

public async Task SendToTargetQueue(IBus bus, object message, string queueName)
{
    await bus.Send(new Uri($"queue:{queueName}"), message);
}

注意事项 #

• 确保目标队列已存在，或开启MassTransit自动创建队列的配置（默认开启）。
• 队列名称需符合RabbitMQ命名规范，避免特殊字符。
• 动态队列名称建议从配置文件读取，避免硬编码。

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