使用 ServiceBusMessageBatch 和在 TransactionScope 中发送多条消息有什么区别？

Question

使用Azure.Messaging.ServiceBus。

我想在一个事务中向 Azure 服务总线发送多条消息。我同意每笔交易 100 条消息的限制。

这两种方法的优缺点是什么？

交易范围
TransactionScope 中的多个单消息发送操作。

public async Task SendMessages(IEnumerable<ServiceBusMessage> messages, CancellationToken cancellationToken)
{
    using var transaction = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled);

    var tasks = messages.Select(m => _serviceBusSender.SendMessageAsync(m, cancellationToken));
    await Task.WhenAll(tasks);

    transaction.Complete();
}

ServiceBusMessageBatch
单个发送操作，发送一个ServiceBusMessageBatch。

public async Task SendMessages(IEnumerable<ServiceBusMessage> messages, CancellationToken cancellationToken)
{
    var batch = await _serviceBusSender.CreateMessageBatchAsync(cancellationToken);

    foreach (var message in messages)
    {
        if (!batch.TryAddMessage(message))
            throw new Exception("...");
    }

    await _serviceBusSender.SendMessagesAsync(batch, cancellationToken);
}

Answer 1

批处理是一种在不超过总大小限制的情况下向代理发送多条消息的方法，因为在批处理构建期间，API 不会添加会导致批处理大小超过允许的最大值的消息。这就是批处理的用途，为了安全起见，确保您在分派时不会出现消息大小异常。

TransactionScope 确保同一事务中发送的消息在成功时全部发送，或者在其中一条消息失败时恢复。

对于批量，只需对代理进行一次调用即可。有多个对具有事务范围的代理的并发调用，例如发送操作的数量。

批处理的好处：对代理的单次调用不会因为太多消息组合在一起并超过最大大小而失败。当您准备发送多条消息时，这非常方便。

事务作用域的好处是，当您需要分派消息但在同一实例中无法将它们全部提供，或者需要以“即发即弃”模式发送但仍希望确保这些消息以原子方式发送时。