NServiceBus SQL Server传输性能优化：批量取100条消息可行吗？

批量获取100条消息的可行性 #

完全可行，只需修改默认SQL查询中的TOP(1)为TOP(100)即可，调整后的SQL如下：

WITH message AS (SELECT TOP(100) * FROM QueueName WITH (UPDLOCK, READPAST, ROWLOCK) ORDER BY [RowVersion] ASC)
DELETE FROM message
OUTPUT deleted.Id, deleted.CorrelationId, deleted.ReplyToAddress,
deleted.Recoverable, CASE WHEN deleted.Expires IS NOT NULL THEN DATEDIFF(ms, GETUTCDATE(), deleted.Expires) END, deleted.Headers, deleted.Body;

注意事项：

• 保留原有的锁提示UPDLOCK, READPAST, ROWLOCK，这能保证多个NServiceBus端点并发获取消息时不会重复消费，同时避免死锁和锁升级问题。
• NServiceBus SQL Server传输本身支持批量提取消息，批量获取后依然会逐条处理消息，单条消息处理失败时，重试、错误队列等机制仍能正常工作，不会影响批量中的其他消息。

其他性能优化方案 #

• 调整并发处理数：在NServiceBus端点配置中设置MaximumConcurrencyLevel，增加同时处理的消息线程数，配合批量提取能大幅提升吞吐量。
• 优化队列表索引：给RowVersion字段创建非聚集索引，因为查询依赖该字段排序，索引能加速TOP查询的执行效率；定期更新表的统计信息，确保SQL Server查询优化器生成最优执行计划。
• 简化过期时间计算：原SQL中的DATEDIFF计算可以提前到消息插入阶段，直接存储剩余有效期值，避免每次提取时的实时计算开销；或者给Expires字段创建索引，减少过期消息过滤的成本。
• 缩短事务时长：确保消息处理逻辑中的事务尽可能短，避免长时间持有队列表的锁，影响其他端点的消息获取效率。
• 队列表分区：如果消息量极大，可按时间维度对队列表进行分区，提升查询和删除操作的性能，同时方便历史消息的清理。
• 优化事务日志：针对高吞吐量场景，将队列数据库设置为简单恢复模式（如果业务允许），或配置定期日志备份，避免事务日志过度增长拖慢性能。

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