如何在Rebus中创建泛型IFailed<T>捕获未处理的二级重试？

完全可以注册一个泛型失败消息处理器，来兜底处理所有没有对应专属IHandleMessages<IFailed<T>>实现的失败命令，同时记录你需要的日志信息，还能解决异常多次冒泡的问题。

实现泛型兜底处理器 #

创建一个泛型类实现IHandleMessages<IFailed<T>>，注入日志组件后在处理方法中记录指定格式的日志，还可以扩展记录消息ID、异常详情等排查信息：

public class GenericFailedMessageHandler<T> : IHandleMessages<IFailed<T>>
{
    private readonly ILogger<GenericFailedMessageHandler<T>> _logger;

    public GenericFailedMessageHandler(ILogger<GenericFailedMessageHandler<T>> logger)
    {
        _logger = logger;
    }

    public async Task Handle(IFailed<T> message)
    {
        var commandTypeName = typeof(T).Name;
        _logger.LogWarning("{CommandType} has failed and we will not attempt second level retries", commandTypeName);
        
        // 可选：添加更多排查信息
        // var lastException = message.Exceptions.Last();
        // _logger.LogWarning("Message ID: {MessageId}, Exception: {ExceptionMsg}", message.MessageId, lastException.Message);
    }
}

注册泛型处理器到Rebus #

在Rebus的配置阶段，将这个泛型处理器注册进去，Rebus会自动为所有未匹配到专属失败处理器的IFailed<T>消息触发它：

Configure.With(yourContainerAdapter)
    .Transport(t => t.UseYourPreferredTransport("connectionDetails", "inputQueue"))
    .Options(o =>
    {
        // 确保已启用二级重试，可根据需求配置重试次数
        o.EnableSecondLevelRetries(maxDeliveryAttempts: 3);
    })
    .Handlers(h =>
    {
        // 注册泛型兜底处理器
        h.Register(typeof(GenericFailedMessageHandler<>));
        // 注册其他业务处理器
        h.Register<SomeCommandHandler>();
        h.Register<AnotherCommandHandler>();
    })
    .Start();

关键说明 #

• 优先级规则：Rebus会优先匹配专属的IHandleMessages<IFailed<SomeCommand>>处理器，只有当没有对应专属实现时，才会触发泛型的兜底处理器，完全符合你的需求。
• 解决异常冒泡：兜底处理器会消费掉失败消息，避免异常继续向上冒泡，终止重试流程。
• 日志扩展：可以根据需要添加更多日志维度，比如失败次数、异常堆栈、消息内容等，方便后续问题排查。

内容的提问来源于stack exchange，提问作者SamIAm