Azure Servicebus队列在接收有序消息时延迟

Question

使用启用会话（消息排序）的Azure ServiceBus队列，我的会话需要持续几分钟到几个小时。

为此，我将QueueClient配置如下：

_options = new SessionHandlerOptions(ExceptionReceivedHandler)
{
    AutoComplete = false,
    MaxConcurrentSessions = 50,
    MessageWaitTimeout = TimeSpan.FromSeconds(30),
};

并按如下方式开始接收消息：

_queueClient.RegisterSessionHandler(ProcessSessionMessagesAsync, _options);

在几次（1到6次之间）成功（几乎是瞬时的）消息接收回调之后——无论是对于新会话还是现有会话，接收处理程序都会停止触发。使用ServiceBusExplorer，我可以看到位于servicebus队列上的消息。有趣的是，它们都有一个DeliveryCount=1。过了一段时间（这在几秒钟到几分钟之间变化——但不是MessageWaitTimeout的倍数），我又开始接收消息了。如果我重新启动接收器，那么我有时会收到所有剩余消息的突发，有时不会更多。

我尝试了MessageWaitTimeout的各种值，虽然较低的值似乎可以减少问题，但延迟仍然存在。

有趣的是，如果我在收到每条消息后完成会话，问题仍然存在。

有没有人经历过这样的事情？这种行为是如此的不一致。。。

FWIW，我的messageReceivedHander看起来像这样：

async Task ProcessSessionMessagesAsync(IMessageSession session, Message message, CancellationToken token)
{
    try
    {
        var myEvent = Serializer.Deserialize(message.Body);
        await _receiveCallback(Subscription, myEvent);
        await session.CompleteAsync(message.SystemProperties.LockToken);

        // Drop the session after every message (**makes no difference**)
        await session.CloseAsync();
    }
    catch (Exception ex)
    {
        await session.AbandonAsync(message.SystemProperties.LockToken);
    }
}

Answer 1

只是一些建议：

>

等待会话。CloseAsync（）

由于您刚刚注册了一个处理程序，因此请使您的应用程序处于活动状态，以确保所有任务都将完成。例如：您可以在控制台之后结束应用程序。Readline（）。

我使用QueueClient运行官方示例：BasicSessionSendReceiveUsingQueueClient，它工作正常。你可以试一试。

Answer 2

事实上我是个白痴。

_receiveCallback（）实际上是对外部服务（请求宾）的调用，它在负载下限制了我的消息，并导致了我正在经历的行为。当我把它掐灭时，我看到了一致的（快速的）行为。