RabbitMQ C#客户端消费吞吐量不及同环境Python客户端问题咨询

RabbitMQ .NET官方客户端的默认配置是适配小消息高并发场景的，大消息（单条几百KB以上）场景下默认的帧限制、Socket缓冲区、预取策略、消费调度配置会直接把带宽卡在8Mbps左右，和服务端、Python客户端实现无关。

• 首先修改ConnectionFactory的网络和调度参数，替换原有的初始化代码：

var factory = new ConnectionFactory()
{
    HostName = "removed",
    UserName = "removed",
    Password = "removed",
    VirtualHost = "removed",
    // 取消单帧大小限制，默认128KB帧会把400KB消息拆成4段传输，额外增加帧解析开销
    RequestedFrameMax = 0,
    // 调大Socket读写缓冲区，默认仅8KB，是带宽上不去的核心原因之一
    SocketReadBufferSize = 1 * 1024 * 1024,
    SocketWriteBufferSize = 1 * 1024 * 1024,
    // 开启异步消费调度，调整并发数，默认单线程串行调度消费回调
    DispatchConsumersAsync = true,
    ConsumerDispatchConcurrency = 4,
    // 心跳保持默认30秒即可，测试时不要设为0避免连接被中间设备断开
    RequestedHeartbeat = TimeSpan.FromSeconds(30)
};

• 通道创建完成后，第一时间配置QoS预取参数，哪怕开了autoAck也要加这行：

// 预取参数说明：
// 第一个参数prefetchSize设为0：不限制单条消息的大小阈值
// 第二个参数prefetchCount设为10：客户端一次性预取10条消息缓存，减少网络往返等待
// 第三个参数global设为false：配置仅对当前通道生效
channel.BasicQos(0, 10, false);

这是高频踩坑点：.NET客户端哪怕开了自动确认，默认预取数还是1，也就是客户端每次只向服务端拉1条消息，等消费回调执行完才拉下一条，大消息场景下网络往返的等待时间会直接把吞吐砍半。

• 移除消费回调里的同步Console.WriteLine调用，控制台同步IO是阻塞操作，会直接卡住消费线程触发客户端内置的流量控制（停止读取Socket数据），测试吞吐的时候要么去掉日志，要么改成异步队列写日志，不要在回调里做阻塞操作。
• 不要让消费逻辑运行在主线程的同步上下文中，控制台程序要确保Console.ReadLine()等待的时候，消费回调是运行在线程池的IO完成端口上，不要在回调里执行任何阻塞耗时操作。

以上配置调整完成后，400KB单条消息、5Hz生产速率的场景下，C#客户端消费速率可以稳定跑满5Hz，带宽占用和Python客户端一致达到18Mbps，不会再卡在8Mbps的阈值。如果是内网环境，把预取数调到20以上，单客户端消费带宽可以跑到300Mbps以上。

补充说明：如果你用的是6.0+版本的.NET客户端，客户端默认内置了背压流控逻辑，只要消费回调的执行时间超过阈值，就会自动暂停Socket读取，只要把回调里的阻塞操作移走、调大预取数就不会触发这个流控。

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