错误处理与重试
使用重试和死信队列处理故障。
错误处理与重试 是 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 反馈 — 无需本地设置。