DDD~领域事件中使用分布式事务
對于一個聚合來說,它可能會被附加很多事件,這里我們叫它領(lǐng)域事務(wù),因為一個聚會我們可以把它理解成一個領(lǐng)域,一個業(yè)務(wù)。對于領(lǐng)域事件不清楚的同學(xué)可以看看我的這篇文章《DDD~領(lǐng)域事件與事件總線》,里面有詳細的說明,今天主要說一下領(lǐng)域里的事務(wù),即領(lǐng)域事件的數(shù)據(jù)處理和主邏輯里的數(shù)據(jù)處理在同一事務(wù)里完成。
知識準備
SQL2005環(huán)境使用TransactionScopeNoMsdtc事務(wù),它是占占開發(fā)的,原理是將一批操作包裹到一個SqlConnection里,由開發(fā)者維護接連的關(guān)閉,這也是使用時要特別注意的地方,因為如果不關(guān)閉連接,SQL鏈接池會益出。
SQL2008環(huán)境使用微軟自己的分布式事務(wù)實現(xiàn)TransactionScope,它對于同一個上下文來說,是不會被提升為分布式事務(wù)的,這一點對SQL2005要強很多。
代碼實踐
/// <summary>/// 添加WebSystem表時,所需要的事件對象/// </summary> [Serializable]public class WebSystemCreateEvent : EventBase{/// <summary>/// 數(shù)據(jù)上下文,它與架構(gòu)無關(guān),可以是Linq2Sql,EF,ADO.NET/// </summary>public IUnitOfWork UnitOfWork { get; set; }/// <summary>/// 對象主鍵/// </summary>public int ID { get; set; }} [HttpPost]public ActionResult WebSystem(FormCollection form){//訂閱領(lǐng)域事件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);//發(fā)布領(lǐng)域事務(wù)EventBus.Instance.Publish(new WebSystemCreateEvent{ID = entity.WebSystemID,UnitOfWork = UnitOfWork,});trans.Complete();}return RedirectToAction("WebSystemList");SQL截圖
TransactionScopeNoMsdtc截圖
TransactionScope截圖
本地WWW網(wǎng)站服務(wù)器的MSDTC為禁用狀態(tài)
本文轉(zhuǎn)自博客園張占嶺(倉儲大叔)的博客,原文鏈接:DDD~領(lǐng)域事件中使用分布式事務(wù),如需轉(zhuǎn)載請自行聯(lián)系原博主。
總結(jié)
以上是生活随笔為你收集整理的DDD~领域事件中使用分布式事务的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: vue本地下载文件,解决ie浏览器本地下
- 下一篇: [ECMAScript] 说说你对cla