如何使用MassTransit连接两台RabbitMQ服务器

<configuration>
  <configSections>
    <section name="MassTransit" type="MassTransit.Configuration.MassTransitConfigurationSection, MassTransit" />
  </configSections>
  
  <MassTransit>
    <rabbitMq>
      <connections>
        <add host="server1" username="guest" password="guest" />
        <add host="server2" username="guest" password="guest" />
      </connections>
    </rabbitMq>
  </MassTransit>
</configuration>

public class MyMessageConsumer : IConsumer<MyMessage>
{
    public async Task Consume(ConsumeContext<MyMessage> context)
    {
        // 处理接收到的消息
    }
}

public class MyMessage
{
    public string Content { get; set; }
}

// 创建消息生产者
var busControl = Bus.Factory.CreateUsingRabbitMq(cfg =>
{
    cfg.Host(new Uri("rabbitmq://server1"), h =>
    {
        h.Username("guest");
        h.Password("guest");
    });

    cfg.ReceiveEndpoint("my_queue", e =>
    {
        e.Consumer<MyMessageConsumer>();
    });
});

// 发送消息
var sendEndpoint = await busControl.GetSendEndpoint(new Uri("rabbitmq://server2/my_queue"));
await sendEndpoint.Send(new MyMessage { Content = "Hello, World!" });

busControl.Start();