領域驅動設計系列 (五)：事件驅動之異步事件

前言

上一篇講了事件，以及為什么要使用事件，主要是為了解耦，但是有同學就問了，同步如果訂閱事件的人太多，比如13億人都關心上頭條的事，那么RaiseEvent得等13億人都處理完，那得多久呀，從此再也不敢發事件了。
舉個例子，你在網上下單，下完單要通知庫房，甚至要通知供應商補貨，如果都是同步的話，消費者還不等急死呀，實際上你在電商網站上下個單， 一般你很快就能到訂單頁面，那個頁面告訴你：“兄弟，訂單已經創建成功，訂單號是xxxxx-xxxxx-xxxx-xxxx,你的訂單已經提交到庫房” 等。然后你就很快了的下另一單了。好吧，
提問的同學，說好的妹子呢？

實現思路

我們先回顧一下同步事件驅動的代碼

發出事件

   public void Head()
    {
        var NewsPaper = new NewsPaper("南都娛樂");
        NewsPaper.WriteToHeader("汪峰");

        RaiseEvent(new HeadedEvent {Name = "汪峰"});
    }

	private void RaiseEvent(HeadedEvent headedEvent)
    {
        EventBus.Publish<HeadedEvent>(new HeadedEvent { Name = "汪峰" });
    }

訂閱事件

public interface IEventHandler<TEvent> where TEvent : Event
{
    void Handle(TEvent e);
}

public class HeadedEvent:Event
{
    public string Name { get; set; }
}

public class GuoJiZhangMotherEventHandler : IEventHandler<HeadedEvent>
{
    public void Handle(HeadedEvent e)
    {
         Console.WriteLine(e.Name+", Are you kidding me?");
    }
}

public class PiMingEventHandler:IEventHandler<HeadedEvent>
{
    public void Handle(HeadedEvent e)
    {
        Console.WriteLine(e.Name+", Guo Ji Zhang is your last wife?");
    }
}

我們可以看到正真的事件協調者是EventBus, 之前的代碼如下是同步的。

public class EventBus
{
    public static void Publish<T>(T concreteEvent) where T: Event
    {
        var handlers = _container.ResolveAll<IEventHandler<T>>();
        foreach (var handle in handlers)
        {
            handle.Handle(concreteEvent);
        }
    }
}

為了提高性能，我們可以先來第一步改進

 public void Publish<T>(T @event) where T : Event
 {
    var handlers = _eventHandlerFactory.GetHandlers<T>();

    handlers.AsParallel().ForAll((h)=> h.Handle(@event));
   
 }

我們可以看到，現在並行處理可以大大加快速度，但是有兩個問題，第一個問題就是沒有處理異常，所以讓我們加上異常。

 public void Publish<T>(T @event) where T : Event
    {
        var handlers = _eventHandlerFactory.GetHandlers<T>();

        handlers.AsParallel().ForAll((h)=> HandleEvent<T>(h,@event));
       
    }

    private void HandleEvent<T>(IEventHandler<T> handle, T @event) where T : Event
    {
        try
        {
            handle.Handle(@event);

        }
        catch (Exception e)
        {
            
           // Log the exception, as the caller don't care this
        }
    }
}

第二個問題，就是我們雖然用了並行加快了速度，但是還沒有正真實現異步，整個程序還是等所有Handler處理完才返回。

   public void Publish<T>(T @event) where T : Event
    {
        var handlers = _eventHandlerFactory.GetHandlers<T>();

        handlers.Select(h => Task.Factory.StartNew(() => HandleEvent<T>(h, @event)));
       
    }

這段代碼執行完，盡然發現Handler沒有執行，好吧，原因是IQueryable的延遲執行，所以我們需要調用一下ToList

public void Publish<T>(T @event) where T : Event
    {
        var handlers = _eventHandlerFactory.GetHandlers<T>();

        handlers.Select(h => Task.Factory.StartNew(() => HandleEvent<T>(h, @event))).ToArray();
       
    }

好了，我們就這樣輕易的實現了一個AsyncEventBus, 是不是感謝.Net的強大?

總結

這里還只是一個系統內部的Async, 如果涉及到系統之間的交互，這個就不行了，而且如果異步處理有錯誤，我們就會有信息丟失，所以需要更健壯的異步事件處理系統，這個后面再講，但是一般的系統我們只需要把出錯的事件記錄下來，然后再看要不要處理就可以。

另外，異步要處理的東西很多，比如處理完畢后，如何通知用戶，還是讓用戶刷新？ 我個人建議，一般情況下都不要用異步，只有在真的需要的時候再用。