DDD~領域事件中使用分布式事務
對于一個聚合來說,它可能會被附加很多事件,這里我們叫它領域事務,因為一個聚會我們可以把它理解成一個領域,一個業務。對于領域事件不清楚的同學可以看看我的這篇文章《DDD~領域事件與事件總線》,里面有詳細的說明,今天主要說一下領域里的事務,即領域事件的數據處理和主邏輯里的數據處理在同一事務里完成。
知識準備
SQL2005環(huan)境使用(yong)TransactionScopeNoMsdtc事務,它是占占開發的,原理是將一(yi)批操(cao)作包裹到一(yi)個SqlConnection里(li),由開發者維護接連(lian)的關閉,這也是使用(yong)時要特(te)別(bie)注意的地方,因為如果不(bu)關閉連(lian)接,SQL鏈接池會益出。
SQL2008環境使用微軟自(zi)己的分(fen)(fen)布(bu)式事(shi)務實現(xian)TransactionScope,它對于同一個上下文來(lai)說(shuo),是不會(hui)被提升為分(fen)(fen)布(bu)式事(shi)務的,這(zhe)一點對SQL2005要強很(hen)多(duo)。
代碼實踐
/// <summary> /// 添加WebSystem表時,所需要(yao)的事件(jian)對象(xiang) /// </summary> [Serializable] public class WebSystemCreateEvent : EventBase { /// <summary> /// 數(shu)據上下文,它與架構(gou)無關(guan),可以是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 + "更新(xin)了"; 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); //發布領(ling)域事(shi)務 EventBus.Instance.Publish(new WebSystemCreateEvent { ID = entity.WebSystemID, UnitOfWork = UnitOfWork, }); trans.Complete(); } return RedirectToAction("WebSystemList"); }
SQL截圖
TransactionScopeNoMsdtc截圖

TransactionScope截(jie)圖

本地WWW網站(zhan)服務(wu)器(qi)的MSDTC為禁用(yong)狀態(tai)