本文介绍了批量向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队列发送消息时发生错误异常的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持编程学习网！
本站部分内容来源互联网,如果有图片或者内容侵犯您的权益请联系我们删除！