平行模型

範例：運送時間查詢 (C#)

我以我為 事件溯源 開發的運送、貨物和港口的簡單範例為基礎。因此，您應該在深入探討這個範例之前熟悉該範例。網域邏輯程式碼幾乎相同。

圖 1：運送範例的網域物件。

由於 平行模型 的許多複雜性在於處理暫時的 平行模型 和活動資料庫，因此我在這個範例中引入了資料庫。我使用熱門的 NHibernate 物件關聯對應器對應到資料庫。我不會詳細說明對應的細節，這並不是很令人感興趣。相反，我將專注於它是如何由 儲存庫 包裝，以及如何在儲存庫和 平行模型 的儲存庫之間進行交換。

與基本範例一樣，網域模型的所有變更都由事件處理。當船隻抵達港口時，這將由抵達事件記錄下來。

class ArrivalEvent...

  string _port;
  int _ship;  
  internal ArrivalEvent (DateTime occurred, string port, int ship) : base (occurred) {
    this._port = port;
    this._ship = ship;
  } 
  internal Port Port {get {return Port.Find(_port);}}
  internal Ship Ship {get {return Ship.Find(_ship);}}
  
  internal override void Process() {
    Ship.HandleArrival(this);
  }

與基本範例不同的是，在這種情況下，港口和船隻由簡單值表示為識別碼 - 在這種情況下，對應於資料庫中的主鍵，儘管任何鍵都可以。但是，屬性使用實際網域物件。為了確保我們始終取得正確的網域物件，我們使用在網域物件類別上定義的尋找器方法從資料庫中提取它們。

class Port...

  public static Port Find(string s) {
    return (Port) Registry.DB.Find(typeof (Port), s);
  }

尋找器方法反過來委派給 儲存庫。在我們的基本案例中，這個儲存庫是一個由 NHibernate 對應的網域物件的資料庫。因此，儲存庫程式碼使用 NHibernate API 從資料庫（或 NHibernate 的快取）中提取物件。

class DB...

  public object Find(Type type, object key) {
    return _hibernateSession.Load(type, key);
  }

NHibernate，就像大多數基於 資料對應器 的資料來源一樣，使用 工作單元 來追蹤它所操作的物件。因此，您永遠不會告訴物件將其自身儲存到資料庫中，而是提交 工作單元，它會找出哪些物件在記憶體中發生變更，以及如何將它們寫出。

對於這個範例，我將在事件處理器中執行這個交易包裝，其處理器現在如下所示。

類別 EventProcessor...

  public void Process(DomainEvent e) {
    Registry.DB.BeginTransaction();
    try {
      e.Process();
      InsertToLog(e);
      Registry.DB.Commit();
    } catch (Exception ex) {
      Registry.DB.Rollback();
      LogFailedEvent(e, ex);
    }
  }

這絕不是包裝 工作單元 的最佳位置，這取決於應用程式的性質。但這對我的範例來說已經足夠，也提出了問題 - 我們如何輕鬆切換持久性儲存庫來處理暫時性查詢？

讓我們透過測試案例來了解這一點

類別 Tester...

  [Test] 
  public void TemporalQueryForShipsLocation() {
    eProc.Process(new ArrivalEvent(new DateTime(2005,11,2), la, kr));
    eProc.Process(new DepartureEvent(new DateTime(2005,11,5), la, kr ));
    eProc.Process(new ArrivalEvent(new DateTime(2005,11,6), sfo, kr));
    Assert.AreEqual(sfo, Ship.Find(kr).Port.Code);
    eProc.SetToEnd(new DateTime(2005,11,2));
    Assert.AreEqual(la, Ship.Find(kr).Port.Code);
  }

這裡的關鍵方法是 SetToEnd，它會變更我們的儲存庫以使用記憶體內儲存庫，並重新處理事件記錄，以便事件播放到當天最後一個事件。這會為 11 月 2 日建立我們的 平行模型。

類別 EventProcessor...

  IList log;
  public void SetToEnd(DateTime date) {
    SynchronizeLog();
    IRepository temporalRepository = new MemoryDB();
    Registry.enableAlternateRepository(temporalRepository);
    foreach (DomainEvent e in log) {
      if (e.Occurred > date) return;
      e.Process();
    }
  }

為了執行暫時性查詢，處理器會完全從資料庫中分離。在這種情況下，處理器會保留自己的事件記錄副本。在離開資料庫之前，它會將其記錄與持久性記錄同步，以便完整記錄寫入資料庫的所有事件。

一旦記錄同步，我們就會建立一個全新的記憶體內儲存庫。這可以由嵌入式記憶體內資料庫支援，這將允許您繼續使用 SQL。它也可以是手寫的，只滿足儲存庫介面。由於這是一個簡單的範例，所以我只使用了一堆雜湊表。

類別 MemoryDB...

  public object Find(Type type, object key) {
    object result = this[type][key];
    if (null == result) 
      throw new ApplicationException ("unable to find: " + key.ToString());
    return result;
  }
  private IDictionary store = new Hashtable();
  private IDictionary this[Type index] {get {return (IDictionary)store[index];}}

記憶體內儲存庫需要初始化為在處理任何事件之前資料庫中的相同初始狀態 - 在這種情況下，持有港口和船舶的參考資料。

類別 MemoryDB...

  public void Initialize() {
    store[typeof(Ship)] = new Hashtable();
    store[typeof(Cargo)] = new Hashtable();
    store[typeof(Port)] = new Hashtable();
    Insert(new Port("SFO", "San Francisco", "US"));
    Insert(new Port("LAX", "Los Angeles", "US"));
    Insert(new Port("YVR", "Vancouver", "CA"));
    Insert (new Port("XXX", "out to sea", "XX"));
    Insert(new Ship("King Roy", 1));
  }

透過暫時儲存庫設定，我們會告訴註冊表開始使用它，而不是真正的儲存庫。

類別 Registry...

  internal static void enableAlternateRepository(IRepository arg) {
    instance._repository = arg;
    arg.Initialize();
  }

現在，網域模型中對註冊表的任何呼叫都會使用記憶體中註冊表。由於此設計將 NHibernate 放置在常規資料庫儲存庫中，這表示我們完全不使用 Hibernate 來執行 平行模型。物件會顯示在記憶體中，並由儲存庫儲存在那裡。

一旦設定記憶體內儲存庫，我們就會依序從記錄中處理在目標日期或之前發生的所有事件。完成後，我們就會有記憶體內儲存庫代表在請求日結束時的全球狀態。我們現在對網域物件執行的任何查詢都會反映該日期。

要回到正確的資料庫，我們只需將暫時的記憶體內儲存庫換成常規儲存庫連線即可。

類別 Registry...

  internal static void restoreBaseRepository() {
    instance._repository = instance._baseRepository;
  }

範例：與基本模型比較 (C#)

在許多 平行模型 用法中，我們一次只處理一個模型。一般的處理，包括更新，都是使用基礎模型完成的，而我們建立 平行模型 來處理歷史和假設查詢。在任何時候，我們只有一個 平行模型 在使用中。這個方案相對簡單，並避免了許多科幻小說情節中困擾平行宇宙身分的疑問。

然而，有時將兩者混合是有意義的。如果您還記得運送範例中的蹩腳笑話，您就會知道書籍發行商對加拿大有多大的恐懼，以及文字被「eh」污染的風險。讓我們想像一下，我們時不時會得到特別討厭的「eh」傳染病。停靠在有這種傳染病的港口的船隻中的任何貨物都應標記為高風險。當然，我們不會在當天發現這些事情，所以我們必須找出那天在港口裡的是什麼。

以下是一個用來表達這個問題的測試案例。

類別 Tester...

  [Test]
  public void HighRiskDayFlagsAllCargo() {
    eProc.Process(new RegisterCargoEvent(new DateTime(2005,1,1), "UML Distilled", "UML", "LAX" ));
    eProc.Process(new RegisterCargoEvent(new DateTime(2005,1,1), "Planning XP", "PXP", "LAX" ));
    eProc.Process(new RegisterCargoEvent(new DateTime(2005,1,1), "Analysis Patterns", "AP", "LAX" ));
    eProc.Process(new RegisterCargoEvent(new DateTime(2005,1,1), "P of EAA", "eaa", "LAX" ));
    eProc.Process(new ArrivalEvent(new DateTime(2005,11,2), la, kr));
    eProc.Process(new LoadEvent(new DateTime(2005,5,11),"PXP", 1));
    eProc.Process(new LoadEvent(new DateTime(2005,5,11),"AP", 1));
    eProc.Process(new ArrivalEvent(new DateTime(2005,11,9), yvr, kr));
    eProc.Process(new ArrivalEvent(new DateTime(2005,11,12), la, kr));
    eProc.Process(new ContagionEvent(new DateTime(2005,11,10), yvr));
    Assert.IsTrue(Cargo.Find("PXP").IsHighRisk, "PXP should be high risk");
    Assert.IsTrue(Cargo.Find("AP").IsHighRisk, "AP should be high risk");
    Assert.IsFalse(Cargo.Find("UML").IsHighRisk, "UML should NOT be high risk");
    Assert.IsFalse(Cargo.Find("eaa").IsHighRisk, "UML should NOT be high risk");
    Assert.IsFalse(Cargo.Find(refact).IsHighRisk, "UML should NOT be high risk");
  }

我用一個新事件來描述傳染病。

class ContagionEvent...

  internal class ContagionEvent : DomainEvent
  {
    string _portID;
    public ContagionEvent(DateTime occurred, string port) : base(occurred) {
      this._portID = port;
    }
    Port Port {get {return Port.Find(_portID);}}

internal override void Process() {
  Registry.EventProcessor.SetToEnd(Occurred);
  ArrayList infectedCargos = new ArrayList();
  foreach (Ship s in Port.Ships) infectedCargos.AddRange(s.Cargos);
  Registry.restoreBaseRepository();
  foreach (Cargo c in infectedCargos) {
    Cargo actualCargo = Cargo.Find(c.RegistrationCode);
    actualCargo.IsHighRisk = true;
  }
}

您會注意到，在這種情況下，我實際上在事件的處理方法中獲得了相當多的行為。這樣做的原因是我決定讓網域模型忽略 平行模型。因此，事件必須為傳染病的日期建立暫時的 平行模型，執行查詢以找出受影響的貨物，將世界還原為基礎模型，並傳遞更新。網域模型仍然在每個 平行模型 中執行邏輯，儘管它不多。

另一種我將認真考慮的做法是，建立新的事件來將貨物標記為高風險。在這種情況下，傳染病事件將在暫時的 平行模型 中找到受影響的貨物，然後建立一個事件來將這些貨物標記為高風險。這個第二個事件將在基礎狀態中執行。在我寫這篇文章時，我承認不確定我比較喜歡哪一種方法。