细粒度领域事件
Granular domain events
最初我们使用域事件来处理与外部系统的通信。例如,每次用户更新他的 phone 号码或他的名字时,我们都会引发 PhoneNumberUpdated 和 NameUpdated 事件。然后这些被处理程序捕获并发送到其他系统。
public void SetName(Name name)
{
if (Name == name) return;
(...)
RaiseEvent(new NameUpdated(Id, name));
}
public void SetPhoneNumber(PhoneNumber number, PhoneNumberType type)
{
RaiseEvent(new PhoneNumberUpdated());
}
只要我们不需要 "aggregate" 事件,它就很好用。例如,我们收到一项新要求,要求我们在用户更新其姓名 and/or 他的 phone 号码时发送一封电子邮件。使用当前结构,我们的处理程序将收到多次通知(每个事件发生一次),这将导致发送多封电子邮件。
让我们的事件更通用似乎不是一个好的解决方案。但是,我们如何汇总在一笔交易中引发的多个事件?
谢谢
塞布
我相信您的新要求与您的实际域不同。您的域生成描述所发生事件的事件。另一方面,用户通知是将该事件流投射到电子邮件形式中。就像您将读取模型要求与您的域分开一样,您也应该将其分开。
一个简单的解决方案是将您关心的事件捕获到 table 中,然后按计划每天一次,每次汇总发送一封电子邮件。
最初我们使用域事件来处理与外部系统的通信。例如,每次用户更新他的 phone 号码或他的名字时,我们都会引发 PhoneNumberUpdated 和 NameUpdated 事件。然后这些被处理程序捕获并发送到其他系统。
public void SetName(Name name)
{
if (Name == name) return;
(...)
RaiseEvent(new NameUpdated(Id, name));
}
public void SetPhoneNumber(PhoneNumber number, PhoneNumberType type)
{
RaiseEvent(new PhoneNumberUpdated());
}
只要我们不需要 "aggregate" 事件,它就很好用。例如,我们收到一项新要求,要求我们在用户更新其姓名 and/or 他的 phone 号码时发送一封电子邮件。使用当前结构,我们的处理程序将收到多次通知(每个事件发生一次),这将导致发送多封电子邮件。
让我们的事件更通用似乎不是一个好的解决方案。但是,我们如何汇总在一笔交易中引发的多个事件?
谢谢 塞布
我相信您的新要求与您的实际域不同。您的域生成描述所发生事件的事件。另一方面,用户通知是将该事件流投射到电子邮件形式中。就像您将读取模型要求与您的域分开一样,您也应该将其分开。
一个简单的解决方案是将您关心的事件捕获到 table 中,然后按计划每天一次,每次汇总发送一封电子邮件。