使用通知在 NServiceBus 可恢复性失败时发送消息

问题描述

当消息用完重试次数并移至错误队列时，如何发送消息（或发布事件）？

当一个请求进入我的系统时，我会创建一个 Saga 来跟踪它。 Saga 向处理程序发送命令以执行异步工作。如果处理程序失败，我想将该命令移动到错误队列（默认行为）并向 Saga 发送消息以提醒最初请求工作的客户端。

我尝试自定义可恢复性行为以使用 Saga 作为错误队列，它会发送回命令但不会将其放入错误队列：

recoverability.CustomPolicy((config,context) =>
{
    // invocation of default recoverability policy
    var action = DefaultRecoverabilityPolicy.Invoke(config,context);

    if (action is MovetoError)
    {
        return RecoverabilityAction.MovetoError("SagaEndpoint");
    }

    return action;
});

我尝试的另一件事是使用 Behavior 挂钩到管道中，但似乎没有一种方法可以覆盖“移动到错误队列”步骤。我可以创建一个 IIncomingLogicalMessageContext 并尝试/捕获 await next();，但是每次重试都会触发，而不仅仅是最后一次。我还尝试了 IoUtgoingLogicalMessageContext，但是当消息移动到错误队列时它不会被调用。如果我错过了什么，那可能是一个解决方案。

我也知道我可以在 Saga 中使用超时来猜测 Handler 何时失败。但如果失败很快，我宁愿不等待超时，或者如果工作花费的时间比预期的要长，我宁愿不等待超时。

我发现 this older question 听起来像是在问同样的事情，但答案不完整并且使用旧的 EventHandler Notifications 而不是新的 Task-based Notifications。如果有办法从通知回调中访问 IMessageSession 或 IEndpointInstance，我认为这也适用于我。

解决方法

没有一种“简单”的方法可以做到这一点，因为在可恢复性发生的那一刻，与传入消息相关的任何事务（这对于每种传输都不同）都是有疑问的，因此您实际上无法做任何事情其他在当时正在发生的事情的范围内。

一旦您启动端点，您就可以将 IEndpointInstance 强制转换为 IMessageSession（与 Stop 方法之类的东西相同），然后将其分配到您的“错误队列通知程序”将能够找到它。那么您对 ​​IMessageSession 执行的任何操作基本上都是一个单独的上下文，与传入消息的处理断开连接。

只要明白，如果消息由于队列的潜在问题而无法处理，则不会正确报告。这就是为什么大多数人会在这些回调中对报告/诊断服务进行某种调用。