3

我们正在实现一个使用 NServiceBus 调用其他服务的 saga。我不太清楚 NServiceBus 如何处理传奇中的异常。

在 saga 内部，我们有一个处理程序，该处理程序调用一个外部服务，只有在原始消息处理程序成功完成后才应该调用该服务。是否可以这样做：

public void Handle(IFooMessage message) 
{
    var message = Bus.CreateInstance<ExternalService.IBarMessage>();
    Bus.Send(message);

    // something bad happens here, exception is thrown
}

还是将消息多次发送到 ExternalService？这里有人建议将其更改为：

// handler in the saga
public void Handle(IFooMessage message) 
{
    // Do something
    var message = Bus.CreateInstance<ISendBarMessage>();
    Bus.SendLocal(message);

    // something bad happens, exception is thrown
}

// a service-level handler
public void Handle(ISendBarMessage message) 
{
    var message = Bus.CreateInstance<ExternalService.IBarMessage>();
    Bus.Send(message);
}

我做了一个实验，据我所知，第一种方法似乎很好，但除了http://docs.particular.net/nservicebus/errors/之外我找不到任何文档，它说：

当异常涌入 NServiceBus 基础设施时，它会在事务端点上回滚事务，导致消息返回到队列，并且用户代码尝试发送或发布的任何消息也被撤消。

任何有助于澄清这一点的帮助将不胜感激。

4

1 回答 1

3

只要您在 saga 中进行消息传递而不进行任何 Web 服务调用，那么您就是安全的 - 无需执行 SendLocal。

于 2012-12-03T10:37:26.647 回答