问题描述
具有建模为 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 块,这样您仍然可以在幕后使用消息传递。
你怎么看?