批量向ServiceBus队列发送消息时发生错误异常

FaultException during sending messages to ServiceBus queue in a batch(批量向ServiceBus队列发送消息时发生错误异常)

问题描述

我正在尝试成批地向服务总线队列发送几条消息。我正在使用QueueClient的SendBatch方法。

我在此操作过程中收到FaultException：

使用不同的SessionID、PartitionKey或 具有分区的实体不支持MessageID 已启用重复检测。

该异常的消息很简单，我会尝试修复它，但有时会奏效，不会引发任何异常。

所以它有时会抛出异常，有时会起作用。我不更改队列的任何设置，也不更改代码。

您知道为什么会发生这种情况吗？

推荐答案

这可能是因为您的批处理包含将进入不同分区的消息。一个批处理必须只包含一个分区的消息。在我的例子中，我的分区是SessionID，所以我首先按SessionID对我的消息进行分组，然后按这些组进行批处理，效果很好。

var bySessionId = messages.GroupBy(s => s.SessionId);
foreach (var sessionSet in bySessionId)
{
    var msgBatch = sessionSet.Batch(20); //Using .Batch from MoreLinq
    foreach (var b in msgBatch)
    {
        var sbb = await sender.CreateMessageBatchAsync();
        b.ForEach(m => sbb.TryAddMessage(m));

        await sender.SendMessagesAsync(sbb);
    }
}

这篇关于批量向ServiceBus队列发送消息时发生错误异常的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持编程学习网！