Azure 服务总线，确定 OnMessage 是否停止处理

Question

使用 Azure ServiceBus 和 OnMessage 调用我正在寻找一种方法来确定 OnMessage 事件泵是否停止从队列中读取。

我们与 OnMessage 的连接配置如下：

protected virtual void DoSubscription(string queueName, Func<QueueRequest, bool> callback)
{
    var client = GetClient(queueName, PollingTimeout);
    var transformCallback = new Action<BrokeredMessage>((message) =>
    {
        try
        {
            var request = message.ToQueueRequest();
            if (callback(request))
            {
                message.Complete();
            }
            else
            {
                message.Abandon();
                Log.Warn("DoSubscription: Message Failed to Process Gracefully: {0}{1}", Environment.NewLine, JsonConvert.SerializeObject(request));
            }
        }
        catch (Exception ex)
        {
            Log.Error("DoSubscription: Message Failed to Process With Exception:", ex);
            message.Abandon();
        }
    });
    var options = new OnMessageOptions
    {
        MaxConcurrentCalls = _config.GetInt("MaxThreadsPerQueue"),
        AutoComplete = false,
        AutoRenewTimeout = new TimeSpan(0,0,1)
    };
    options.ExceptionReceived += OnMessageError;
    client.OnMessage(transformCallback, options);
}

我们遇到的问题是一段时间后没有消息排队，OnMessage 事件泵无法拾取排队的新消息，直到应用程序重新启动。

我知道有一些方法可以使用辅助角色来做到这一点，但是出于监控和管理的目的，我们决定在 Web 应用程序的应用程序启动中实现它。

Answer 1

因此，在与 Microsoft 的 Azure 支持团队通话后，在 OnMessage 或 OnMessageAsync 错误时没有要捕获的事件。由于这些不是阻塞调用，它会启动事件泵和 returns 到执行线程，这会产生一个挑战，以确定 OnMessage* 是否正在执行它的工作。

Microsoft 的建议是：

创建您自己的 QueueClientBase class 实现，它公开您可以处理的 OnClose、On* 方法。但是，在执行此操作时，您必须自己处理邮件信封。
在单独的线程循环中使用 OnReceive，您可以自己捕获错误并立即重试。

不过，我确实探索了一些针对 OnMessage 的防弹措施，并发现了一些减轻我恐惧的事情。

OnMessage 具有令人难以置信的容错能力
- 我在无线关闭的情况下从笔记本电脑上拔下了以太网电缆，这中断了 OnMessage 与服务总线队列的连接。等待 10 分钟后，我重新插入以太网电缆，OnMessage 立即开始处理排队的元素。
On Message 出奇地相当稳定。它已经运行在 global.asax.cs App Start 中，简而言之，连续几天将 Factory IdleTimeout 设置为 24 小时，并且 72 小时内没有重新启动 Web 应用程序。

总而言之，我将暂时继续使用 OnMessage/OnMessageAsync 并密切关注它。如果我看到改变我对 OnMessage 看法的问题，我会更新这个。

旁白 - 如果您使用 OnMessage 在 Azure 网站中永久收听，请确保将 "Always On" 配置选项设置为 "On"。否则，除非 Web 请求进入 OnMessage，否则消息将不再被处理，直到 Web 应用程序被 HTTP 请求重新唤醒。

Azure 服务总线，确定 OnMessage 是否停止处理

Azure Service Bus, determine if OnMessage stops processing

c#

azure

azure-servicebus-queues