DDD~領域事件中使用分布式事務 - lori－IT工程師數位筆記本

文章出處

對于一個聚合來說，它可能會被附加很多事件，這里我們叫它領域事務，因為一個聚會我們可以把它理解成一個領域，一個業務。對于領域事件不清楚的同學可以看看我的這篇文章《DDD~領域事件與事件總線》，里面有詳細的說明，今天主要說一下領域里的事務，即領域事件的數據處理和主邏輯里的數據處理在同一事務里完成。

知識準備

ＳＱＬ２００５環境使用TransactionScopeNoMsdtc事務，它是占占開發的，原理是將一批操作包裹到一個SqlConnection里，由開發者維護接連的關閉，這也是使用時要特別注意的地方，因為如果不關閉連接，ＳＱＬ鏈接池會益出。

ＳＱＬ２００８環境使用微軟自己的分布式事務實現TransactionScope，它對于同一個上下文來說，是不會被提升為分布式事務的，這一點對ＳＱＬ２００５要強很多。

代碼實踐

　　/// <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");
        }