這篇文章將為大家詳細講解有關(guān)ABP框架中領(lǐng)域?qū)拥念I(lǐng)域事件Domain events怎么用，小編覺得挺實用的，因此分享給大家做個參考，希望大家閱讀完這篇文章后可以有所收獲。
在C#中,一個類可以定義其專屬的事件并且其它類可以注冊該事件并監(jiān)聽，當事件被觸發(fā)時可以獲得事件通知。這對于對于桌面應用程序或獨立的Windows Service來說非常有用。但是, 對于Web應用程序來說會有點問題,因為對象是根據(jù)請求(request)被創(chuàng)建并且它們的生命周期都很短暫。我們很難注冊其它類別的事件。同樣地,直接注冊其它類別的事件也造成了類之間的耦合性。
在應用系統(tǒng)中，領(lǐng)域事件被用于解耦并且重用(re-use)商業(yè)邏輯。
事件總線
事件總線為一個單體(singleton)的對象,它由所有其它類所共享,可通過它觸發(fā)和處理事件。要使用這個事件總線,你需要引用它。你可以用兩種方式來實現(xiàn):
獲取默認實例( Getting the default instance)
你可以直接使用EventBus.Default。它是全局事件總線并且可以如下方式使用:
EventBus.Default.Trigger(...); //觸發(fā)事件
注入IEventBus事件接口(Injecting IEventBus)
除了直接使用EventBus.Default外,你還可以使用依賴注入(DI)的方式來取得IEventBus的參考。這利于進行單元測試。在這里,我們使用屬性注入的范式:
重慶分公司
重慶分公司
public class TaskAppService : ApplicaService {
public IEventBus EventBus { get; set; }
public TaskAppService() {
EventBus = NullEventBus.Instance;
}
}注入事件總線,采用屬性注入比建構(gòu)子注入更適合。事件是由類所描述并且該事件對象繼承自EventData。假設我們想要觸發(fā)某個事件于某個任務完成后:
public class TaskCompletedEventData : EventData {
public int TaskId { get; set; }
}這個類所包含的屬性都是類在處理事件時所需要的。EventData類定義了EventSource(那個對象觸發(fā)了這個事件)和EventTime(何時觸發(fā))屬性。
定義事件
ABP定義AbpHandledExceptionData事件并且在異常發(fā)生的時候自動地觸發(fā)這個事件。這在你想要取得更多關(guān)于異常的信息時特別有用(即便ABP已自動地紀錄所有的異常)。你可以注冊這個事件并且設定它的觸發(fā)時機是在異常發(fā)生的時候。
ABP也提供在實體變更方面許多的通用事件數(shù)據(jù)類: EntityCreatedEventData, EntityUpdatedEventData和EntityDeletedEventData。它們被定義在Abp.Events.Bus.Entitis命名空間中。當某個實體新增/更新/刪除后,這些事件會由ABP自動地觸發(fā)。如果你有一個Person實體,可以注冊到EntityCreatedEventData,事件會在新的Person實體創(chuàng)建且插入到數(shù)據(jù)庫后被觸發(fā)。這些事件也支持繼承。如果Student類繼承自Person類,并且你注冊到EntityCreatedEventData中,接著你將會在Person或Student新增后收到觸發(fā)。
觸發(fā)事件
觸發(fā)事件的范例如下:
public class TaskAppService : ApplicationService {
public IEventBus EventBus { get; set; }
public TaskAppService() {
EventBus = NullEventBus.Instance;
}
public void CompleteTask(CompleteTaskInput input) {
//TODO: 已完成數(shù)據(jù)庫上的任務
EventBus.Trigger(new TaskCompletedEventData { TaskId = 42 } );
}
}這里有一些觸發(fā)方法的重載:
EventBus.Trigger(new TaskCompletedEventData { TaskId = 42}); EventBus.Trigger(this, new TaskCompletedEventData { TaskId = 42 }); EventBus.Trigger(typeof(TaskCompletedEventData), this, new TaskCompletedEventData { TaskId = 42});
事件處理
要進行事件的處理,你應該要實現(xiàn)IEventHandler接口如下所示:
public class ActivityWriter : IEventHandler, ITransientDependency { public void HandleEvent(TaskCompletedEventData eventData) { WriteActivity("A task is completed by id = " + eventData.TaskId); } }
EventBus已集成到依賴注入系統(tǒng)中。就如同我們在上例中實現(xiàn)ITransientDependency那樣,當TaskCompleted事件觸發(fā),它會創(chuàng)建一個新的ActivityWriter類的實體并且調(diào)用它的HandleEvent方法,并接著釋放它。詳情請見依賴注入(DI)一文。
1.基礎(chǔ)事件的處理(Handling base events)
EventBus支持事件的繼承。舉例來說,你可以創(chuàng)建TaskEventData以及兩個繼承類:TaskCompletedEventData和TaskCreatedEventData:
public class TaskEventData : EventData {
public Task Task { get; set; }
}
public class TaskCreatedEventData : TaskEventData {
public User CreatorUser { get; set; }
}
public class TaskCompletedEventData : TaskEventData {
public User CompletorUser { get; set; }
}然而,你可以實現(xiàn)IEventHandler來處理這兩個事件:
public class ActivityWriter : IEventHandler, ITransientDependency { public void HandleEvent(TaskEventData eventData) { if(eventData is TaskCreatedEventData) { ... }else{ ... } } }
當然,你也可以實現(xiàn)IEventHandler來處理所有的事件,如果你真的想要這樣做的話(譯者注:作者不太建議這種方式)。
2.處理多個事件(Handling multiple events)
在單個處理器(handler)中我們可以可以處理多個事件。此時,你應該針對不同事件實現(xiàn)IEventHandler。范例如下:
public class ActivityWriter : IEventHandler, IEventHandler , ITransientDependency { public void HandleEvent(TaskCompletedEventData eventData) { //TODO: 處理事件 } public void HandleEvent(TaskCreatedEventData eventData) { //TODO: 處理事件 } }
注冊處理器
我們必需注冊處理器(handler)到事件總線中來處理事件。
1.自動型Automatically
ABP掃描所有實現(xiàn)IEventHandler接口的類,并且自動注冊它們到事件總線中。當事件發(fā)生, 它通過依賴注入(DI)來取得處理器(handler)的引用對象并且在事件處理完畢之后將其釋放。這是比較建議的事件總線使用方式于ABP中。
2.手動型(Manually)
也可以通過手動注冊事件的方式,但是會有些問題。在Web應用程序中,事件的注冊應該要在應用程序啟動的時候。當一個Web請求(request)抵達時進行事件的注冊,并且反復這個行為。這可能會導致你的應用程序發(fā)生一些問題,因為注冊的類可以被調(diào)用多次。同樣需要注意的是,手動注冊無法與依賴注入系統(tǒng)一起使用。
ABP提供了多個事件總線注冊方法的重載(overload)。最簡單的一個重載方法是等待委派(delegate)或Lambda。
EventBus.Register(eventData => { WriteActivity("A task is completed by id = " + eventData.TaskId); });
因此,事件:task completed會發(fā)生,而這個Lambda方法會被調(diào)用。第二個重載方法等待的是一個對象,該對象實現(xiàn)了IEventHandler:
Eventbus.Register(new ActivityWriter());
相同的例子,如果ActivityWriter因事件而被調(diào)用。這個方法也有一個非泛型的重載。另一個重載接受兩個泛化的參數(shù):
EventBus.Register
此時,事件總線創(chuàng)建一個新的ActivityWriter于每個事件。當它釋放的時候,它會調(diào)用ActivityWriter.Dispose方法。
最后,你可以注冊一個事件處理器工廠(event handler factory)來負責創(chuàng)建處理器。處理器工廠有兩個方法: GetHandler和ReleaseHandler,范例如下:
public class ActivityWriterFactory : IEventHandlerFactory {
public IEventHandler GetHandler() {
return new ActivityWriter();
}
public void ReleaseHandler(IEventHandler handler) {
//TODO: 釋放ActivityWriter實體(處理器)
}
}ABP也提供了特殊的工廠類,IocHandlerFactory,通過依賴注入系統(tǒng)，IocHandlerFactory可以用來創(chuàng)建或者釋放(dispose)處理器。ABP可以自動化注冊IocHandlerFactory。因此,如果你想要使用依賴注入系統(tǒng),請直接使用自動化注冊的方式。
取消注冊事件
當你手動注冊事件總線,你或許想要在之后取消注冊。最簡單的取消事件注冊的方式即為registration.Dispose()。舉例如下:
//注冊一個事件 Var registration = EventBus.Register(eventData => WriteActivity("A task is completed by id = " + eventData.TaskId)); //取消注冊一個事件 registration.Dispose();
當然,取消注冊可以在任何地方任何時候進行。保存(keep)好注冊的對象并且在你想要取消注冊的時候釋放(dispose)掉它。所有注冊方法的重載(overload)都會返回一個可釋放(disposable)的對象來取消事件的注冊。
事件總線也提供取消注冊方法。使用范例:
//創(chuàng)建一個處理器 var handler = new ActivityWriter(); //注冊一個事件 EventBus.Register(handler); //取消這個事件的注冊 EventBus.Unregister (handler);
它也提供重載的方法給取消注冊的委派和工廠。取消注冊處理器對象必須與之前注冊的對象是同一個。
最后,EventBus提供一個UnregisterAll()方法來取消某個事件所有處理器的注冊,而UnregisterAll()方法則是所有事件的所有處理器。
關(guān)于“ABP框架中領(lǐng)域?qū)拥念I(lǐng)域事件Domain events怎么用”這篇文章就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，使各位可以學到更多知識，如果覺得文章不錯，請把它分享出去讓更多的人看到。
