Rebus（RabbitMQ）消息发布性能异常求助：1000条耗时9秒

看到你用Rebus发布1000条消息花了9秒（约110条/秒），这个性能确实有点拉胯，咱们来一步步优化它。

首先得明白，你现在的代码是循环里逐条await发送，每条消息都要单独和RabbitMQ做一次交互，网络往返、信道开销加起来就拖慢了整体速度。下面是几个立竿见影的优化方法：

1. 用批量发送替代逐条发送 #

Rebus专门提供了SendMany方法，能把多条消息打包成一个请求发送，直接减少网络交互次数，这是提升吞吐量最有效的办法之一。修改后的代码大概是这样：

var watch = System.Diagnostics.Stopwatch.StartNew();
// 一次性生成所有要发送的命令
var commands = Enumerable.Range(0, 1000)
    .Select(_ => new CreateExampleEmptyCommand())
    .ToList();

// 批量发送
await _bus.SendMany(commands);

watch.Stop();
var elapsedMs = watch.ElapsedMilliseconds;
Debug.WriteLine($"duration: {elapsedMs}");

这个改动通常能把吞吐量提升好几倍，甚至几十倍，取决于消息大小和网络情况。

2. 开启Rebus的自动批量发布功能 #

如果你的场景没办法一次性收集所有要发送的消息（比如消息是零散产生的），可以在Rebus配置里开启自动批量发布，它会自动把短时间内的多个Send操作合并成批量：

Configure.With(yourActivator)
    .Transport(t => 
        t.UseRabbitMq("your-rabbitmq-connection-string", "your-input-queue")
          .EnableBatchPublish()) // 开启自动批量
    // 其他配置（比如序列化、错误处理等）
    .Start();

开启后，你不用改原来的逐条Send代码，Rebus会在后台帮你合并请求，同样能减少网络开销。

3. 合理并行发送（控制并发数） #

如果必须逐条发送，也可以把串行await改成并行执行，但要注意控制并发数，别把RabbitMQ压垮。比如用Task.WhenAll结合信号量来限制并发：

var watch = System.Diagnostics.Stopwatch.StartNew();
// 限制同时发送50条消息，根据你的RabbitMQ配置调整这个数
var semaphore = new SemaphoreSlim(50);

var tasks = Enumerable.Range(0, 1000)
    .Select(async i => {
        await semaphore.WaitAsync();
        try {
            var command = new CreateExampleEmptyCommand();
            Debug.WriteLine($"Sending command: {i}");
            await _bus.Send(command);
        } finally {
            semaphore.Release();
        }
    });

await Task.WhenAll(tasks);

watch.Stop();
var elapsedMs = watch.ElapsedMilliseconds;
Debug.WriteLine($"duration: {elapsedMs}");

这个方法能利用多核CPU和网络带宽，但并发数别设太高，不然会导致RabbitMQ的信道或连接过载，反而降速。

4. 调整RabbitMQ的基础配置 #

除了Rebus的代码优化，RabbitMQ本身的配置也会影响性能：

• 关闭不必要的持久化：如果你的消息不需要持久化（比如允许丢失），发送时可以标记为非持久化，减少磁盘IO开销：

  await _bus.Send(command, options => options.MakeNonPersistent());
  

• 检查服务器资源：确保RabbitMQ所在服务器的CPU、内存、磁盘IO足够，磁盘慢是持久化消息性能差的常见原因。
• 调整RabbitMQ参数：比如增大channel_max（允许更多信道）、frame_max（允许更大的消息帧），这些参数可以在RabbitMQ的配置文件里修改。

总结一下，优先尝试批量发送（SendMany或自动批量），这是投入产出比最高的优化，然后再根据实际场景调整并发和RabbitMQ配置，应该能把吞吐量提升到每秒几千条甚至更高。

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