masstransit - 如何触发自动状态机中使用的活动的补偿流程的执行？

Question

我的活动在执行过程中不时抛出异常，因此我实现了 Faulted 方法Activity<TInstance>来处理它，丢弃了在方法中所做的更改Execute。我认为在 Automatonymous 中存在一些布线，使得在Execute方法抛出异常时执行 Faulted 方法，然后为已经执行的活动调用 Faulted 方法。事实证明，没有这样的事情，因为我的错误方法永远不会执行。

我应该在 try/catch 块中调用那些自己吗？我可以产生BehaviorExceptionContextProxy基于BehaviorContext和抛出的异常。我唯一Behavior可以通过的下一个是插入到 that方法中Activity的Execute那个，但从逻辑上讲，这意味着我在错误的方向上进行补偿，因为下一个Behavior实际上是在这个成功后执行的，所以我会补偿太多。

我还尝试使用Catch状态机中的 ，它确实处理了异常，但是，当我只有现在时，我找不到任何方法来开始为失败的活动执行补偿流ExceptionActivityBinder。

有什么好的方法可以触发活动的补偿流程吗？

标签： masstransitsagaautomatonymous

Answer 1

状态机中的活动（使用 Automatonymous）与 Courier 中的活动有很大不同。不幸的是，它们都具有相同的名称，这可能会造成混淆。

当一个活动抛出异常时，Faulted会调用该行为中下一个活动的方法。如果该方法是常规活动方法（例如 .Then、.Publish 等），则会跳过它，因为Faulted这些活动的方法只是调用行为中的下一个活动。

Catch但是，活动可用于捕获异常并执行救援行为（这是一系列活动）。

无论哪种方式，都不会调用在 Execute 方法中引发异常的活动的 Faulted 方法。所以是的，您应该使用 try/catch，但允许异常从 Execute 方法流出，以便行为正确处理它。