标签：
在《设计模式沉思录 》（Pattern Hatching: Design Patterns Applied ，[美]JohnVlissides著）一书的第4章中，围绕事件Message传递的推-拉模型（Push-Pull），谈到了一个最初被称为Multicast，之后被定型为Typed Message的设计模式。
该模式的初衷是希望得到一个可扩展的、类型安全的事件传递机制，并能符合两点要求：
在阅读过程中，由于Event Sourcing中围绕领域事件Domain Event建立的机制，与这一模式非常近似，因此记录如下。
将信息封装在一个对象中，从而使信息的传递能够以一种类型安全的方式进来。客户可以对对象进行扩展，以便向对象中增添信息，同时无需牺牲类型安全性。
强调对事件的封装扩展，而不再强调通知的过程。
不得不提的是，由于Typed Message与Observer两种模式的应用场合、注册与通知的方式等存在诸多相似，因此即便是在GoF的四人组与作者之间，围绕Typed Message模式能否单独作为一种模式存在、它是否只是Observer的一种变体而引发的争论，也持续了相当长的时间，在该书第4章中详细描述了这一过程。这段争论当中，有一句话，我认为是点到了关键：
我认为它不是Observer的变体，原因在于Observer知道它的Subject，而Multicast中的处理程序并不需要知道它们的事件源。
正是由于这个原因，所以在Typed Message模式里，Receiver并不清楚Sender的具体情况。Receiver只关心Sender发出的Message，并且在Receive方法里完成实际的事件处理操作。
细思之下，Event Sourcing中Event、Aggregate、EventHandler之间的关系，与Typed Message模式中的Message、Sender、Receiver何其相似：
所以，对上图作简单修改，即可得到下图：
借用《Exploring CQRS and Event Sourcing》中Conference案例的代码作为参考：
Event的实现，是简单的、带版本Version的、若干Property组成的类。
public class OrderPlaced : VersionedEvent
{
public Guid ConferenceId { get; set; }
public IEnumerable<SeatQuantity> Seats { get; set; }
public DateTime ReservationAutoExpiration { get; set; }
public string AccessCode { get; set; }
}
在聚合Order里，在Order的构造子中触发一个OrderPlaced事件。
public class Order : EventSourced
{
... ...
public Order(Guid id, Guid conferenceId, IEnumerable<OrderItem> items, IPricingService pricingService)
: this(id)
{
... ...
this.Update(new OrderPlaced
{
ConferenceId = conferenceId,
Seats = all,
ReservationAutoExpiration = DateTime.UtcNow.Add(ReservationAutoExpiration),
AccessCode = HandleGenerator.Generate(6)
});
... ...
}
... ...
}
这里定义的接口IEventHandler，对应图中的抽象类EventHandler。（C#支持类的多接口实现，是Typed Message模式应用的关键之一）
public interface IEventHandler<T> : IEventHandler
where T : IEvent
{
void Handle(T @event);
}
在Conference案例中，主要有两种场景下实现的EventHandler。
一类是在Command端，从Event Queue中消费Event，或者Process Manager需要的，相对独立的EventHandler。
public class OrderEventHandler :
IEventHandler<OrderPlaced>,
IEventHandler<SeatUnassigned>
{
... ...
public void Handle(OrderPlaced @event)
{
using (var context = this.contextFactory.Invoke())
{
context.Orders.Add(new Order(@event.ConferenceId, @event.SourceId, @event.AccessCode));
context.SaveChanges();
}
}
... ...
｝
另一类是在Query端，需要更新读模型时，嵌入视图生成器中的EventHandler。
public class PricedOrderViewModelGenerator :
IEventHandler<OrderPlaced>,
IEventHandler<SeatUpdated>
{
.... ....
public void Handle(OrderPlaced @event)
{
using (var context = this.contextFactory.Invoke())
{
var dto = new PricedOrder
{
OrderId = @event.SourceId,
ReservationExpirationDate = @event.ReservationAutoExpiration,
OrderVersion = @event.Version
};
context.Set<PricedOrder>().Add(dto);
try
{
context.SaveChanges();
}
catch (DbUpdateException)
{
Trace.TraceWarning("Ignoring OrderPlaced message.", dto.OrderId, @event.Version);
}
}
}
.... ....
}
[设计模式] Typed Message模式与Event Sourcing
标签：
原文地址：http://www.cnblogs.com/Abbey/p/4888301.html
