MassTransit 7.2.2 Saga异常捕获失效问题排查

我之前也踩过类似的坑，你的问题核心是对MassTransit Saga中Catch的作用域理解有误，导致抛出异常后根本没走到你的捕获逻辑。

问题根源 #

你当前的代码结构是把Catch作为一个独立活动放在Then之后，但MassTransit的Saga活动执行是线性的：一旦前面的Then抛出未处理的异常，整个活动链会直接中断，后续的Catch、ThenAsync等活动都不会被执行——这就是你的捕获逻辑完全没触发的原因。

Catch并不是自动捕获前面所有活动的异常，它需要和Try配合使用，形成类似C#原生try/catch的代码块结构，这样Try内部的活动抛出异常时，才会进入Catch处理。

修复后的代码 #

During(Submitted, When(OrderAccepted)
    // 用Try包裹所有可能抛出异常的业务逻辑
    .Try(x => x
        .Then(y => { 
            logger.LogInformation($"Order {y.Instance.OrderId} accepted"); 
            throw new Exception("TEST"); 
        })
        .ThenAsync(c => TakeProductCommand(c))
        .TransitionTo(Accepted)
    )
    // Catch捕获Try块中抛出的所有Exception
    .Catch<Exception>(x => x
        .If(context => context.Data.OrderId == 1002, activityBinder => activityBinder
            .Then(y => { 
                logger.LogInformation($"Order {y.Instance.OrderId} catch exception and pass to Rejected"); 
            })
            .TransitionTo(Rejected)
        )
        // 可选：处理其他OrderId的异常情况
        .Else(activityBinder => activityBinder
            .Then(y => { 
                logger.LogError($"Unexpected exception for Order {y.Instance.OrderId}"); 
            })
            // 可以选择转到错误状态，或者重新抛出异常触发重试
            // .TransitionTo(Failed)
        )
    )
);

关键说明 #

1. Try块的作用：把所有可能抛出异常的业务逻辑（你的Then、ThenAsync、状态转换）都包裹在Try内部，这样异常会被Catch捕获，而不是直接中断整个Saga流程。
2. Catch的作用域：现在Catch专门处理Try块内抛出的异常，你可以通过If/Else针对不同场景做分支处理。
3. 移除多余的return x;：你之前在Catch中手动返回x是不必要的，MassTransit的链式调用已经处理了流程控制，这行代码不会带来任何好处，反而可能让逻辑更混乱。

这样修改后，当Then中抛出异常时，就会进入Catch逻辑，根据OrderId判断是否转到Rejected状态，完全符合你的预期。

内容的提问来源于stack exchange，提问作者Volodymyr V.