DDD：如何保證聚合的一致性

聚合一致性

從時間維度考慮，一致性分為“實時一致性”和“最終一致性”。在企業應用中，多數情況都是使用實時一致性。在WEB應用中，為了最大限度的提高系統的吞吐量，經常使用最終一致性，如：博客園的積分和排名計算。

從聚合的維度考慮，一致性分為“內部一致性”和“外部一致性”。內部一致性是指一個聚合實例本身狀態的一致性。外部一致性是指多個聚合實例之間狀態的一致性。

代碼示例

需求

1. 1. 訂單要記錄訂單原始總額。（內部一致性）
   2. 訂單有兩種狀態，未提交和提交，不能修改已提交的訂單。（內部一致性）
   3. 訂單要記錄訂單的總額，總額 = 原始總額 * 折扣，如果客戶是VIP就打8折。（外部一致性）
   4. 客戶信用評級。（最終一致性）

類圖

核心代碼

Order

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace 狀態一致性.Code
{
    public sealed class Order
    {
        private readonly List<OrderItem> _orderItems = new List<OrderItem>();
        private OrderStatus _status = OrderStatus.UnSubmited;
        private Decimal _rawTotal = 0M;
        private Decimal _total = 0M;

        internal Order() { }

        internal void AddOrderItem(OrderItem orderItem)
        {
            this.DoValidation();

            _orderItems.Add(orderItem);

            this.CalculateAndSetRawTotal();
        }

        internal void MarkAsSubmited()
        {
            this.DoValidation();

            _status = OrderStatus.Submited;
        }

        public Guid CustomerId { get; internal set; }

        public Decimal Total
        {
            get
            {
                return _total;
            }
            internal set
            {
                this.DoValidation();

                _total = value;
            }
        }

        public Decimal RawTotal
        {
            get
            {
                return _rawTotal;
            }
        }

        private void CalculateAndSetRawTotal()
        {
            _rawTotal = _orderItems.Sum(x => x.Price);
        }

        private void DoValidation()
        {
            if (_status == OrderStatus.Submited)
            {
                throw new InvalidOperationException("處於提交狀態的訂單不能執行修改操作");
            }
        }
    }
}

OrderItem

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace 狀態一致性.Code
{
    public sealed class OrderItem
    {
        public OrderItem(Decimal price)
        {
            this.Price = price;
        }

        internal Decimal Price { get; private set; }
    }
}

OrderStatus

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace 狀態一致性.Code
{
    public enum OrderStatus
    {
        UnSubmited = 0,
        Submited = 1
    }
}

Customer

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace 狀態一致性.Code
{
    public sealed class Customer
    {
        public Guid CustomerId { get; set; }
        public bool IsVip { get; set; }

        internal void ApplyDiscount(Order order)
        {
            var discount = 1M;
            if (IsVip)
            {
                discount = 0.8M;
            }

            order.Total = order.RawTotal * discount;
        }
    }
}

UnSubmitedService

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace 狀態一致性.Code
{
    public sealed class UnSubmitedService
    {
        public void CreateOrder(Customer customer, IEnumerable<OrderItem> orderItems, bool autoSubmit)
        {
            var order = new Order();
            order.CustomerId = customer.CustomerId;

            foreach (var orderItem in orderItems)
            {
                order.AddOrderItem(orderItem);
            }

            customer.ApplyDiscount(order);

            if (autoSubmit)
            {
                order.MarkAsSubmited();
            }
        }
    }
}

代碼說明

1. OrderItem的成員都實現成了只讀，否則會導致封裝失敗，進而導致內部一致性的失敗。
2. Order實現了內部一致性，而且將API盡可能的聲明為internal或private，這樣就保證UI層不會跨越領域服務（外部一致性）直接調用Order。
3. UnSubmitedService實現了外部一致性。

如果要完整的實現內部一致性，會盡可能多的采用值類型語義的實體和封裝集合模式。

備注

關於最終一致性的理解我還很膚淺，這里就不丟人現眼了。實時一致性可以參考這篇文章：.NET：處理數據庫事務中的並發。