如何解决使用通知在 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
执行的任何操作基本上都是一个单独的上下文,与传入消息的处理断开连接。
只要明白,如果消息由于队列的潜在问题而无法处理,则不会正确报告。这就是为什么大多数人会在这些回调中对报告/诊断服务进行某种调用。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。