c# - nservicebus + webhooks +Errors +MaxRetries

Question

功能说明

NServiceBus 网关，http://docs.particular.net/nservicebus/gateway/ ，似乎是一种使用 NServiceBus 基础结构实现内部 webhook 的方法。

我们需要进一步推进这一概念，为有权在我们的系统中注册 webhook url 的任何第 3 方订阅者开放一个少数事件。

回顾

我们计划创建两个初始窗口服务

1) WebHookBatchService，可以添加为感兴趣的特定消息的订阅者。

<UnicastBusConfig>
    <MessageEndpointMappings>
           .......
        <add Messages="MyMessages.MyImportantMessage, MyMessages" Endpoint="WebHookBatchService.Queue"/>
           .......
    </MessageEndpointMappings>
</UnicastBusConfig>

2) WebHookProcessService - 实际上处理 1 条由 WebHookBatchService 发送的消息。

一旦在 WebHookBatchService.Queue 上收到消息，我们的 WebHookBatchService 将查找特定租户 + 消息类型的所有订阅者，并 foreach 将单独的消息发送到 WebHookProcessService.Queue 以获取 WebHookProcessService(我们可以创建 nservicebus loadbalancer 的实例以桥接批处理和实际处理器)以实际处理可能使用 http://restsharp.org/ 的真实消息.

问题

目前是否有任何现有的开源项目可以做到这一点？

既然我们无法控制订阅者的持久性，我们应该如何管理错误？

http://wiki.shopify.com/WebHook

A webhook will be deleted if there are 19 consecutive failures for the exact same webhook.

它没有提到 webhook 中的任何延迟。人们对重试逻辑中的标准延迟有什么体验？

这里有一些其他的想法:

提案 0:MaxRetries="1"。每晚清除 WebHookProcessService.ErrorQueue。 (不重试 - 如果第一次失败，保证消息丢失)

提案 1:异常捕获时的 MaxRetries="1"发送包含本应通过 http 传送的消息的 xml 版本的电子邮件。
每晚清除 WebHookProcessService.ErrorQueue。 -- 我看到潜在的垃圾邮件问题。

建议 2:nservicebus MaxRetries 立即重试，没有延迟。所以我需要创建(1 小时 - 24 小时)存储桶队列并使用 RetrySchedulerService，尽管我认为这很难维护并且让订阅者感到困惑，因为当服务端点开始工作时，他们一次以非 DateCreated 有序的方式收到 25 条消息.

挖掘想法...

Answer 1

网关通常用于通过 HTTP 在物理站点之间进行通信。由于您向世界公开了一个端点以接受回调，我认为您可以只使用内置的 WCF 托管并通过防火墙向第 3 方公开您的端点。您的其余设置听起来很适合我。

至于错误，你是对的，NSB 会立即重试，但如果你使用网络回调，这可能会在出现小问题的情况下帮助你解决问题。您将需要确定要如何处理错误队列，我们​​只是构建一个新的端点来处理错误队列，并使用逻辑来确定重试、延迟等。实现此目的的一个好方法是使用 Saga，其中包括超时管理器。这会启用一个工作流，在该工作流中，您可以重试指定次数，尝试另一次通信，记录所有内容，并最终通知可以联系第 3 方的人，让他们知道东西被破坏了。