【发布时间】:2018-08-20 10:00:48
【问题描述】:
我正在尝试将一些消息与每个消息的不同调度间隔并行调度到服务总线队列。 我有几条消息链,我正在并行调度这些链,并且这些链中的每条消息也是并行调度的。 但间歇性地,我看到少数链发生 TimeoutException。
并行执行的链数约为 100,每个链有约 100-150 条消息。 服务总线操作的重试已经实现。 已经阅读了所有 TimeoutException 文章,但没有找到解决此问题的具体内容。
这是我的代码:
Task<Guid[]> result = Task.WhenAll(queueTasks);
try
{
var jobIds = await ExecuteWithRetryAsync(async () =>
{
return await result.ConfigureAwait(false);
}).ConfigureAwait(false);
queuedJobIds = jobIds.ToList();
}
catch(TimeoutException ex)
{
_logger.LogError(ex, "Queueing failed.");
}
对此的任何帮助或建议将不胜感激。谢谢。
【问题讨论】:
-
您尝试在一个实例中向队列发送多少消息?
-
大约。 1000 条消息
标签: azureservicebus servicebus azure-servicebus-queues