AutoFac IoC、DDD 和存储库间依赖关系

Question

我有两种 POCO 类型，A 和 B。我为每种类型都有一个存储库，Rep>和 Rep>，两者都实现了 IRep>和 IRep>由 IoC 容器（本例中为 AutoFac）提供服务。

存储库有多种类型 - 从数据库（或其他）按需加载、延迟加载的内存集合、缓存的 Web 服务结果等。调用者无法分辨出区别。两个代表>和代表>恰好是内存中的集合，因为 A 和 B 变化不大并且存在很长时间。

B 的属性之一是 A。我现在要做的是，当向 B 询问其 A 时，B 会得到 IRep> 。找到它的 A 并返回它。它每次都会这样做 - 对 B 的 A 的每个请求都涉及 IRep>.Find()。好处是 B 永远不会保留 A 的，并且每个请求都会考虑 Rep 的状态。缺点是需要大量 IoC/IRep> 操作。搅动。

我正在考虑使用 Lazy>此处的模式，以便 B 询问 IRep>一次并保留它所得到的。但是如果 A 从其存储库中删除会发生什么？

我正在为 Rep> 寻找一种干净的方法当它发生变化时通知任何感兴趣的人。在我的例子中，某个B的A可能会被删除，所以我想Rep>当删除或添加某些内容等时引发事件。Rep>可能会订阅此事件来清理任何引用现在已消失的 A 的 B，等等。如何连接它？

理想情况下，实例化 Rep> 时不会发生任何变化。它不应该知道谁在听，并且 A 可能会整天被操纵而不会启动代表。

但是当代表>诞生后，它需要一种订阅 Rep> 事件的方法。可能没有代表>还活着，但肯定会有一次 B 被要求提供 A，所以似乎可以启动一个 Rep>。

从本质上讲，当 Rep> 时，被实例化后，它希望将自己注册到 Rep> 中；用于事件通知。我不想污染 IRep>接口，因为这对于存储库层之外的任何人来说都不重要。而其他类型的存储库可能根本不必担心这一点。

这有什么意义吗？

Answer 1

如果您让 Rep 返回一个可以计算为 A 的“可观察”对象，并且还具有一个在 A 发生变化时引发的可订阅事件，会怎么样？只是一个想法。这样，您就不必让处理程序检查以确保它们的 A 发生了变化；如果他们正在侦听的事件被触发，则它涉及他们的实例而不是任何其他实例。

您可以将其编码如下：

public class Observable<T>:IDisposable
{
   private T instance;
   public T Instance
   {
      get{return instance;}
      set{
         instance = value;
         var handlers = ReferenceChanged;
         if(handlers != null) handlers(this, instance);
   }

   public static implicit operator T(Observable<T> obs)
   {
      return obs.Instance;
    }

   //DO NOT attach anonymous delegates or lambdas to this event, or you'll cause a leak
   public event EventHandler<T> ReferenceChanged;

   public void Dispose()
   {
      var handlers = ReferenceChanged;
      if(handlers != null) handlers(this, null);
      foreach(var handler in handlers) ReferenceChanged -= handler;
   }
}

public class Rep<T>
{
   private Dictionary<T, Observable<T>> observableDictionary = new Dictionary<T, Observable<T>>();

   ...
   public Observable<T> GetObservableFactory(Predicate<T> criteria)
   {
      //criteria should test only uniquely-identifying information
      if(observableDictionary.Keys.Any(criteria))
         return observableDictionary[observableDictionary.Keys.First(criteria)];
      else
      {
         //TODO: get object from source according to criteria and set to variable queryResult
         var observable = new Observable<T>{Instance = queryResult};
         observableDictionary.Add(queryResult, observable);
         return observable;
      }
   }
}

...

var observableA = myRepA.GetObservable(myCriteria);
observableA.ReferenceChanged += DoSomethingWhenReferenceChanges;

现在，如果内部引用发生更改，或者可观察对象被处置（也处置了内部引用），则使用代码将收到通知。为了让可观察对象在 As 的子引用发生变化时也通知消费代码，A 本身必须是可观察的，触发由 Observable 处理的事件，该事件将通过 ReferenceChanged 或更具体的方式“冒泡”它处理程序，例如 InstanceDataChanged（或任何您想要的名称）。