Rebus 一级重试。有什么方法可以从以前的交付尝试中获得异常?

Rebus firstlevel retry. Is there any way to get exception from previous delivery attempt?

我知道,rebus 在 IErrorTraker (InMemErrorTracker) 中存储跨消息传递的错误。有什么方法可以将 IErrorTraker 注入处理程序或其他方法来从先前的尝试中获取异常?谢谢!

是的,但是您需要自己做一些工作。

正如您已经正确理解的那样,IErrorTracker 是 Rebus 用于跟踪失败的传递尝试的方式,因此它能够提供有关先前记录的异常的信息,如果消息是已处理。

不过它是 Rebus 的内部文件,因此不会以任何方式公开。不过,您可以通过几种不同的方式将其取出,例如通过 incoming pipeline step put it into the incoming step context:

可以在这里看到执行此操作的方法(以粗略的方式):

Configure.With(activator)
    .Transport(t => (...))
    .Options(o => o.Decorate<IPipeline>(c =>
    {
        var pipeline = c.Get<IPipeline>();
        var errorTracker = c.Get<IErrorTracker>();
        var step = new ExposeErrorTrackerStep(errorTracker);

        return new PipelineStepConcatenator(pipeline)
            .OnReceive(step, PipelineAbsolutePosition.Front);
    }))
    .Start();

更复杂的版本会将丑陋的配置内容放入适当的扩展方法中:

public static void ExposeErrorTracker(this OptionsConfigurer configurer) =>
    configurer.Decorate<IPipeline>(c =>
    {
        var pipeline = c.Get<IPipeline>();
        var errorTracker = c.Get<IErrorTracker>();
        var step = new ExposeErrorTrackerStep(errorTracker);

        return new PipelineStepConcatenator(pipeline)
            .OnReceive(step, PipelineAbsolutePosition.Front);
    });

然后像这样使用它:

Configure.With(activator)
    .Transport(t => (...))
    .Options(o => o.ExposeErrorTracker())
    .Start();

最后,下面是步骤的实现:

[StepDocumentation("Makes Rebus' IErrorTracker available in the incoming step context.")]
class ExposeErrorTrackerStep : IIncomingStep
{
    readonly IErrorTracker _errorTracker;

    public ExposeErrorTrackerStep(IErrorTracker errorTracker) => _errorTracker = errorTracker;

    public Task Process(IncomingStepContext context, Func<Task> next)
    {
        context.Save(_errorTracker);
        return next();
    }
}

如您所见,它简单地将 IErrorTracker 隐藏在传入步骤上下文中,您可以通过 IMessageContext 访问它,它被自动配置为注入处理程序。

完整的工作示例可以在这里看到:https://github.com/rebus-org/Rebus/blob/master/Rebus.Tests/Examples/ExposeInternalService_ErrorTracker.cs