回到目錄
對于一個聚合來說,它可能會被附加很多事件,這裡我們叫它領域事務,因為一個聚會我們可以把它了解成一個領域,一個業務。對于領域事件不清楚的同學可以看看我的這篇文章《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為禁用狀态
作者:倉儲大叔,張占嶺,
榮譽:微軟MVP
QQ:853066980
支付寶掃一掃,為大叔打賞!