一個事件匯流排的實現，主要包含三個角色：1、訊息釋出  2、訊息佇列  3、訊息派送

訊息佇列可以有多種選擇，redis,kafka,rocketMQ等，甚至是jdk blockQueue。

但作為一個工業級的設計，我們需要考慮幾點：

1、高效能  2、高可用  3、平滑擴容  4、架構對開發者透明

1、2、3取決於你用什麼訊息佇列，4 取決於你採用哪種設計模式進行解耦

經過對比，這裡採用了kafka作為我們的事件匯流排的關鍵核心部件，下面著重談下設計模式進行解耦：

這裡說的解耦，指的是普通程式設計師使用事件匯流排的時候，他們是不需要關心事件匯流排採用的是什麼訊息伺服器，他們只面向介面程式設計，並不關心細節。同理，這也為事件匯流排日後升級提供了便利，也就是說，日後從kafka更換成更好的訊息伺服器，業務系統是不需要做任何的修改，透明切換。

具體到程式碼層設計，採用觀察者模式作為訊息派發的基礎，最為合適不過。熟悉spring的朋友應該知道，spring其實內建了一套觀察者模式的支援，我們就無需自己重新寫了，但需要定義一些自己的抽象介面去整合一下， 具體介面設計如下：

訊息事件：EventObject <--- AppMsg

事件監聽器：EventListener <--- AppMsgEventListener

事件釋出器：AppEventPublisher

抽象消費者：Consumer

以上就是一個事件匯流排最基礎的雛形，事件匯流排在網際網路系統中舉足輕重，各系統之間的解耦，非同步訊息推送，傳送郵件，簡訊，日誌大規模採集，分散式最終一致性事務等都需要用到。