0Pricing
C# Academy · 课时

错误处理与重试

使用重试和死信队列处理故障。

错误处理与重试 是 CoddyKit 上的免费 C# Academy 课时。 这是第 4 节课,共 4 节。 你可以在下方免费阅读本课时的完整内容 — 然后在浏览器中使用内置代码编辑器和全天候 AI 导师进行实践。 这是 C# Academy 学习路径的一部分,你的进度在网页和 CoddyKit 应用中同步。 C# Academy 课程共包含 4 节课。

失败是正常情况

消费者可能会失败:暂时性的数据库错误、下游超时,或由错误数据引起的程序缺陷。MassTransit 提供分层的工具(重试、再次投递、错误队列),让您可以优雅地处理失败,而不是丢失消息。

立即重试

对于短暂故障,请配置重试,让 MassTransit 在放弃之前快速连续地重新处理消息几次。

cfg.ReceiveEndpoint("orders", e =>
{
    e.UseMessageRetry(r => r.Immediate(3));
    e.ConfigureConsumer<OrderConsumer>(context);
});

间隔与 Exponential 重试

拉开重试间隔有助于应对需要更长恢复时间的情况。您可以使用间隔重试或指数退避,其方式类似于 Polly。

e.UseMessageRetry(r =>
    r.Exponential(5,
        minInterval: TimeSpan.FromSeconds(1),
        maxInterval: TimeSpan.FromMinutes(1),
        intervalDelta: TimeSpan.FromSeconds(2)));

筛选需要重试的错误

只对暂时性异常进行重试;对于验证失败等永久性错误,不要重试。您可以通过处理和忽略规则限定重试范围。

e.UseMessageRetry(r =>
{
    r.Handle<TimeoutException>();
    r.Ignore<ValidationException>();
    r.Immediate(3);
});

重试与再次投递

重试会将消息保留在内存中并快速重新处理。再次投递(延迟重试或第二级重试)则会将消息返回消息代理,稍后再重新投递,从而在等待期间释放消费者。

e.UseDelayedRedelivery(r =>
    r.Intervals(TimeSpan.FromMinutes(5),
                TimeSpan.FromMinutes(15),
                TimeSpan.FromMinutes(30)));

组合使用两个层级

稳健的配置会使用立即重试应对短暂故障,并使用延迟再次投递应对较长时间的中断。请将再次投递配置在重试之外,这样每次再次投递也会获得自己的一组立即重试。

e.UseDelayedRedelivery(r => r.Intervals(
    TimeSpan.FromMinutes(5), TimeSpan.FromMinutes(15)));
e.UseMessageRetry(r => r.Immediate(3));

错误队列

当所有重试和再次投递都耗尽后,MassTransit 会将消息移入错误队列(名为 <queue>_error)。消息会与异常详细信息一起保留,供调查使用,绝不会被静默丢弃。

故障

发生失败时,MassTransit 还会发布一个 Fault<T> 事件。其他服务可以消费故障事件,以发送警报、记录日志或触发补偿。

public class OrderFaultConsumer : IConsumer<Fault<OrderPlaced>>
{
    public Task Consume(ConsumeContext<Fault<OrderPlaced>> context)
    {
        // inspect context.Message.Exceptions
        return Task.CompletedTask;
    }
}

幂等性很重要

由于重试和再次投递可能会导致同一条消息被处理多次,消费者必须具备幂等性:同一条消息被处理两次时,不得重复扣费或重复执行工作。请使用唯一标识符和去重检查。

从错误队列重新处理

修复程序缺陷后,您可以将消息从错误队列移回原始队列,以便重新处理,从而恢复之前失败的工作。

死信与跳过队列

MassTransit 还会使用跳过队列(_skipped)保存没有消费者需要的消息,帮助您在生产环境中发现路由错误或意外的消息类型。

快速检查

测试错误处理和重试。

总结

MassTransit 通过多个层级处理失败:使用重试(立即重试或指数重试,并通过处理/忽略规则限定范围)应对短暂故障,使用再次投递应对较长时间的中断,并使用错误队列保存已耗尽重试次数的消息,同时通过 Fault<T> 事件发送警报。由于消息可能被处理多次,请确保消费者具备幂等性,并在修复程序缺陷后从错误队列重新处理消息。

常见问题解答

「错误处理与重试」课时是免费的吗?

是的 — 「错误处理与重试」的完整文本可在网页上免费阅读。要进行交互式练习(内置代码编辑器和全天候 AI 导师)并解锁 C# Academy 课程的其余内容,请升级到 CoddyKit PRO。 C# Academy 课程共包含 4 节课。

「错误处理与重试」这节课中我会学到什么?

使用重试和死信队列处理故障。 你通过在浏览器中直接运行的动手代码来练习 C# Academy,全天候 AI 导师会在你学习这节课的过程中回答你的问题。

学习 C# Academy 需要有经验吗?

无需任何先前经验。CoddyKit 上的 C# Academy 课程适合初学者到高级学习者,你可以从这里开始或从头开始,按照自己的节奏学习。 这是第 4 节课,共 4 节。

「错误处理与重试」课时需要多长时间?

大多数 CoddyKit 课程大约需要 5–10 分钟。每节课都很精短且互动,所以你能稳步进步,并在网页和应用中从离开的地方继续。

我能在这节 C# Academy 课中编写并运行代码吗?

能。每节 C# Academy 课都包含内置代码编辑器,你可以在浏览器中直接编写并运行真实代码,并获得即时 AI 反馈 — 无需本地设置。

此课程中的所有课时

  1. 消息传递概念
  2. 生成和使用消息
  3. Saga 与工作流
  4. 错误处理与重试
← 返回 C# Academy