The effect is that it will either populate the Stream using Commits that it found in the persistence, or if none are found it will do nothing and return the new Stream.

However, you shouldn't have to ask yourself this question. A Command should be validated before you send it. Use your read models to validate the command before you send it.

Also, the Command together with Aggregate root state should be enough information to perform your decision in the domain. This basically means that you have to be certain of the domain state before you send your commands in order to avoid exceptions in the domain. And you can use the the read model for that.

Update as a response to Mauros comment:

You are having a concurrency issue. You might be able to solve it by using the method used in occasionally connected systems which is merging. What you can do is to store the Stream revision in the read model so that you know which revision of the AR you have acted upon. Then when the command is handled you know if you were acting upon an old state of the AR.

If the AR revision is higher than than the one the command brings you can either discard the command as a failure (pessimistic concurrency), or you can try to merge the changes.

This can be done by looking at the events produced from the revision in the command up until the current state. Then invoke the behavior the command was supposed to do and look at the events created by that behavior and compare the two event collections. If there aren't any conflicting events, you can commit the newly created events to the store. If there are conflicts, you can throw a concurrency exception.

I think that is your best bet to solve this type of concurrency issues.

Search for Event Merging for more info.

回复收藏 0 原文

强辩 2025-01-07 21:09:31

我猜您实际上指的是 JOliver 的 CommonDomain 项目中的 IRepository.GetById() ？

当您使用不在事件存储中的聚合根 ID 调用 GetById 时，存储库将为您提供一个新的聚合对象，其中 .Version == 0 且 .Id == Guid.Empty。我刚刚创建了自己的派生存储库，它检测该条件并返回 null：

public override TAggregate GetById<TAggregate>(Guid id, int versionToLoad)
{
    var aggregate = base.GetById<TAggregate>(id, versionToLoad);
    return aggregate.Version > 0 ? aggregate : null;
}

这可能是错误的方法（请参阅 Mikael 的答案），但到目前为止它对我来说工作得很好。

I guess you're actually referring to IRepository.GetById() in JOliver's CommonDomain project?

When you call GetById with an aggregate root id that isn't in the event store, the repository will give you a new aggregate object with .Version == 0 and .Id == Guid.Empty. I just created my own derived repository that detects that condition and returns null instead:

public override TAggregate GetById<TAggregate>(Guid id, int versionToLoad)
{
    var aggregate = base.GetById<TAggregate>(id, versionToLoad);
    return aggregate.Version > 0 ? aggregate : null;
}

That might be the wrong way to go about it (see Mikael's answer) but it's working fine for me so far.

回复收藏 0 原文

~没有更多了~