對于一個聚合來說,它可能會被附加很多事件,這里我們叫它領域事務,因為一個聚會我們可以把它理解成一個領域,一個業務。對于領域事件不清楚的同學可以看看我的這篇文章《DDD~領域事件與事件總線》,里面有詳細的說明,今天主要說一下領域里的事務,即領域事件的數據處理和主邏輯里的數據處理在同一事務里完成。
知識準備
SQL2005環境使用TransactionScopeNoMsdtc事務,它是占占開發的,原理是將一批操作包裹到一個SqlConnection里,由開發者維護接連的關閉,這也是使用時要特別注意的地方,因為如果不關閉連接,SQL鏈接池會益出。
SQL2008環境使用微軟自己的分布式事務實現TransactionScope,它對于同一個上下文來說,是不會被提升為分布式事務的,這一點對SQL2005要強很多。
代碼實踐
/// <summary>/// 添加WebSystem表時,所需要的事件對象/// </summary> [Serializable]public class WebSystemCreateEvent : EventBase{/// <summary>/// 數據上下文,它與架構無關,可以是Linq2Sql,EF,ADO.NET/// </summary>public IUnitOfWork UnitOfWork { get; set; }/// <summary>/// 對象主鍵/// </summary>public int ID { get; set; }}
[HttpPost]public ActionResult WebSystem(FormCollection form){//訂閱領域事件EventBus.Instance.Subscribe<WebSystemCreateEvent>(i =>{var entity1 = new DbContextRepository<WebSystem>(i.UnitOfWork).Find(i.ID);entity1.WebSystemName = entity1.WebSystemName + "更新了";new DbContextRepository<WebSystem>(i.UnitOfWork).Update(entity1);});IUnitOfWork UnitOfWork = new backgroundEntities1();var db = new DbContextRepository<WebSystem>(UnitOfWork);using (TransactionScope trans = new TransactionScope()){var entity = new WebSystem{Info = form["Info"],Status = Convert.ToInt32(form["Status"]),WebSystemName = form["WebSystemName"]};db.Insert(entity);//發布領域事務EventBus.Instance.Publish(new WebSystemCreateEvent{ID = entity.WebSystemID,UnitOfWork = UnitOfWork,});trans.Complete();}return RedirectToAction("WebSystemList");
SQL截圖
TransactionScopeNoMsdtc截圖
TransactionScope截圖
本地WWW網站服務器的MSDTC為禁用狀態
本文轉自博客園張占嶺(倉儲大叔)的博客,原文鏈接:DDD~領域事件中使用分布式事務,如需轉載請自行聯系原博主。