从QueueClient.Create迁移至MessagingFactory.CreateQueueClient遇阻求助

我来帮你梳理下怎么从QueueClient.CreateFromConnectionString切换到用MessagingFactory来创建QueueClient，同时实现你要的批处理控制和多连接提升吞吐量的需求～

1. 配置MessagingFactory，控制BatchFlushInterval #

MessagingFactory是创建Service Bus客户端的核心入口，你可以通过它的配置类直接设置BatchFlushInterval，这是实现批处理时间控制的关键：

// 替换成你的Service Bus连接字符串和队列名称
var connectionString = "Endpoint=sb://your-namespace.servicebus.windows.net/;SharedAccessKeyName=...";
var targetQueue = "your-queue-name";

// 构建工厂配置，重点设置BatchFlushInterval
var factoryConfig = new MessagingFactorySettings
{
    // 调整这个值来控制批处理自动刷新的间隔，比如50ms
    BatchFlushInterval = TimeSpan.FromMilliseconds(50),
    // 推荐使用AMQP传输，比NetMessaging更适合高吞吐量场景
    TransportType = TransportType.Amqp,
    // 可选：如果需要更大的批处理容量，可以调整BatchSize
    // BatchSize = 200
};

// 创建MessagingFactory实例
var messagingFactory = MessagingFactory.CreateFromConnectionString(connectionString, factoryConfig);

划重点：BatchFlushInterval的作用是，客户端会等待指定时间，把这段时间内接收到的发送请求攒成一批发送；如果在间隔内消息数量达到了BatchSize（默认100），会立即发送。你可以根据业务的实时性和吞吐量需求平衡调整这两个参数。

2. 从工厂创建QueueClient并复用 #

和静态创建方式不同，现在你需要从MessagingFactory实例创建QueueClient，并且要像之前一样全程复用这个客户端实例，避免频繁创建销毁带来的性能开销：

// 保持和原来一致的ReceiveMode
var queueClient = messagingFactory.CreateQueueClient(targetQueue, ReceiveMode.PeekLock);

// 后续发送/接收消息都复用这个queueClient实例即可

3. 多工厂多连接提升吞吐量 #

如果要通过多连接提升发送能力，注意同一个MessagingFactory下的所有客户端共享底层TCP连接，所以要实现真正的多连接，必须创建多个独立的MessagingFactory实例，每个工厂对应一个独立连接：

// 根据你的业务压力设置工厂数量，比如3-5个，不要超过Service Bus的连接配额
var factoryCount = 4;
var factories = new List<MessagingFactory>();
var queueClients = new List<QueueClient>();

for (int i = 0; i < factoryCount; i++)
{
    var factory = MessagingFactory.CreateFromConnectionString(connectionString, factoryConfig);
    factories.Add(factory);
    queueClients.Add(factory.CreateQueueClient(targetQueue, ReceiveMode.PeekLock));
}

// 发送消息时，可以把任务分发到不同的queueClient并行处理
// 示例：用Task.WhenAll并行发送一批消息
var sendTasks = queueClients.Select(client => 
    client.SendAsync(new BrokeredMessage("test message"))
);
await Task.WhenAll(sendTasks);

注意：应用关闭时一定要记得释放所有资源，避免连接泄漏：

// 先关闭所有QueueClient，再关闭MessagingFactory
foreach (var client in queueClients)
{
    await client.CloseAsync();
}
foreach (var factory in factories)
{
    await factory.CloseAsync();
}

4. 常见踩坑点 #

• 批处理生效前提：默认情况下批处理是开启的，如果之前手动设置过EnableBatchProcessing = false，需要改回true才能让BatchFlushInterval生效。
• 连接配额限制：Service Bus命名空间有连接数配额（比如基础版是100，标准版是1000），不要创建过多工厂，避免触发配额限制。
• 接收模式一致性：确保创建QueueClient时使用的ReceiveMode和原来一致，避免消息处理逻辑出现异常（比如原来用PeekLock，不要改成ReceiveAndDelete）。

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