向Azure Service Bus发送消息列表的性能问题及优化咨询

针对你当前发送速率不达标的问题，结合代码和场景，给出以下具体优化措施：

1. 消除冗余的JSON序列化操作 #

你的代码中先反序列化x.MessageContent再重新序列化，完全是多余的CPU开销——既然x.MessageContent已经是序列化好的JSON字符串，直接用它构造BinaryData即可：

var serviceBusMessages = messageList.Select(x => new ServiceBusMessage
{
    MessageId = Guid.NewGuid().ToString(),
    Body = BinaryData.FromString(x.MessageContent), // 直接复用原JSON字符串
    ContentType = "application/json",
    ApplicationProperties =
    {
        { "EventId", x.EventId }
    }
}).ToList();

这一步能节省大量CPU时间，对小消息场景的吞吐量提升非常明显。

2. 复用ServiceBusSender实例 #

每次发送都创建ServiceBusSender会带来连接建立的开销，ServiceBusSender是线程安全的，应该全局复用（比如作为单例注入，或在应用生命周期内只创建一次）：

// 全局初始化（示例：在服务构造函数中创建）
private readonly ServiceBusSender _sender;

public MessageSenderService(ServiceBusClient serviceBusClient, string topicName)
{
    _sender = serviceBusClient.CreateSender(topicName);
}

// 发送时直接复用已创建的sender
await _sender.SendMessages(serviceBusMessages);

3. 拆分批量并并行发送 #

Azure Service Bus单批消息限制为1MB或1000条消息（取先触发的限制），由于你的消息体积小，可以将消息列表拆分为多个1000条的批次，然后用Task.WhenAll并行发送多个批次：

int batchSize = 1000;
// .NET 6+用Chunk拆分，低版本可手动实现分批逻辑
var sendTasks = messageList.Chunk(batchSize)
                           .Select(batch => 
                               _sender.SendMessages(batch.Select(x => new ServiceBusMessage
                               {
                                   MessageId = Guid.NewGuid().ToString(),
                                   Body = BinaryData.FromString(x.MessageContent),
                                   ContentType = "application/json",
                                   ApplicationProperties = { { "EventId", x.EventId } }
                               }).ToList()));

await Task.WhenAll(sendTasks);

注意并行度建议控制在10以内，避免触发Service Bus的限流机制。

4. 优化数据库读取逻辑 #

如果GetMessagesFromDb()是性能瓶颈：

• 改用异步读取（GetMessagesFromDbAsync()），避免阻塞发送线程
• 增大单次读取的消息数量，减少数据库查询次数
• 采用数据库批量读取API（比如SQL Server的OFFSET/FETCH或批量复制）

5. 启用主题分区 #

如果你的Service Bus主题尚未启用分区，开启分区后Service Bus会在多个消息容器间并行处理消息，大幅提升吞吐量。可以在Azure Portal的主题设置中开启“分区”选项。

6. 调整ServiceBusClient配置 #

在创建ServiceBusClient时，优化传输和连接参数：

var clientOptions = new ServiceBusClientOptions
{
    TransportType = ServiceBusTransportType.AmqpTcp, // 比AmqpWebSockets传输更快
    ConnectionIdleTimeout = TimeSpan.FromMinutes(5), // 延长连接空闲超时，减少重连开销
    RetryOptions = new ServiceBusRetryOptions
    {
        Mode = ServiceBusRetryMode.Exponential,
        MaxRetries = 3, // 合理设置重试次数，避免失败拖慢整体速率
        Delay = TimeSpan.FromMilliseconds(100)
    }
};

var serviceBusClient = new ServiceBusClient(connectionString, clientOptions);

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