.NET Core使用MassTransit MultiBus如何访问第二总线实现跨连接消息发布

1. 定义第二总线标记接口 #

MassTransit MultiBus 依赖自定义的总线接口区分不同的总线实例，你需要先定义一个空的标记接口继承IBus：

public interface ISecondBus : IBus
{
}

2. 注册第二总线（仅发布场景简化配置） #

因为你只需要用第二总线发消息，不需要监听接收消息，注册时不需要加AddConsumer，也不需要配置接收端点，只配置第二套RabbitMQ的连接信息即可：

services.AddMassTransit<ISecondBus>(x =>
{
    x.UsingRabbitMq((context, cfg) =>
    {
        // 配置第二套RabbitMQ的主机、虚拟机、登录凭证
        cfg.Host("第二套RabbitMQ主机地址", "/", h =>
        {
            h.Username("你的用户名");
            h.Password("你的密码");
        });
        // 不需要配置ReceiveEndpoint，也不需要注册消费者
    });
});
// 注意：你原来使用的默认总线（非泛型的AddMassTransit注册逻辑）保留即可，不需要修改

3. 控制器中注入并使用第二总线发布消息 #

直接在构造函数注入你定义的ISecondBus接口，调用对应的发布/发送方法即可：

[ApiController]
[Route("api/[controller]")]
public class YourBusinessController : ControllerBase
{
    private readonly ISecondBus _secondBus;

    // 依赖注入自动注入第二总线实例
    public YourBusinessController(ISecondBus secondBus)
    {
        _secondBus = secondBus;
    }

    [HttpPost("process")]
    public async Task<IActionResult> ProcessBusiness()
    {
        // 原有业务逻辑：监听默认总线消息、处理业务
        // ...

        // 通过第二总线发布消息到另一套RabbitMQ
        // 方式1：Publish 发布到对应类型的Exchange
        await _secondBus.Publish(new YourCustomMessage
        {
            // 填充消息属性
        });

        // 方式2：Send 直接发送到指定队列
        // var sendEndpoint = await _secondBus.GetSendEndpoint(new Uri("queue:目标队列名称"));
        // await sendEndpoint.Send(new YourCustomMessage());

        return Ok();
    }
}

疑问澄清 #

消费者确实是用来监听接收传入消息的组件，你仅发布消息的场景完全不需要注册消费者，也不需要手动触发Consume方法，直接调用ISecondBus的Publish/Send方法就能完成消息发送，不需要额外引入冗余逻辑。

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