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

【问题标题】：NServiceBus - Aggregate Root - Saga - Synchronous CommandNServiceBus - 聚合根 - Saga - 同步命令
【发布时间】：2021-07-04 23:43:39
【问题描述】：

有一个聚合根 User 建模为 NServiceBus Saga

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 持久化回数据存储区（负责乐观锁定）。对此有什么想法吗？

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

【问题讨论】：

标签： microservices domain-driven-design nservicebus

【解决方案1】：

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

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

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

你怎么看？

【讨论】：

嗯，RenameUser 是一个示例，旨在演示一个问题，在实际场景中，命令被拒绝的可能性很高，您无法确保它在没有到达命令处理程序服务的情况下通过（这不仅仅是 @ 987654322@，但更多在线 Item has enough timeslots to reserve)
是的，回调看起来像是用异步机制进行的同步通信，它带来了（异步和同步）通信的缺点。一方面，您有时间耦合，另一方面，您需要进行更多的网络调用以将消息传入和传回服务。