NServiceBus - 聚合根 - Saga - 同步命令

如何解决NServiceBus - 聚合根 - Saga - 同步命令

具有建模为 NServiceBus Saga 的聚合根 User

User.cs

public class User {
   ....
   public string Rename(string name) {
     .// some validation logic
   }
   ...
}

UserSagaData.cs

public class UserSagaData : ContainSagaData
{
  public User User { get; set;}
}

UserSaga.cs

public partial class UserSaga : Saga<RenameUser>
{
   ...
   public async Task Handle(RenameUserimportAttendees,IMessageHandlerContext context)
  {
     Data.User.rename(...
  } 
   ...
}

现在我需要通过 REST API 接受 RenameUser 命令并在 HTTP 响应中提供反馈，因此从 Controller.Action 向消息代理发送 RegisterUser 不是一个选项。我需要同步执行命令，获取反馈并发送http响应。

首先想到的是使用 ISagaPersister，即通过 id 检索 saga，然后调用命令，然后使用 ISagaPersister 将 saga 持久化回数据存储区（它负责处理乐观锁定）。对此有何想法？

这个问题有其他解决方案吗？

解决方法

您希望 RenameUser 命令产生什么类型的反馈？

你不能只返回一个 HTTP OK 并排队重命名命令吗？ （假设您已经对新名称进行了验证，出现问题的可能性应该很小，如果命令最终进入错误队列，可以离线处理？）

如果您真的必须等待响应，一个选项是使用我们的回调包 https://docs.particular.net/nservicebus/messaging/callbacks，在响应到达之前启用您的 REST API 块，这样您仍然可以在幕后使用消息传递。

你怎么看？