[ASP.NET Core 3框架揭秘] 依赖注入[4]:一个Mini版的依赖注入框架

依赖注入[4]:一个迷你版DI框架 - 图1在前面的章节中,我们从纯理论的角度对依赖注入进行了深入论述,我们接下来会对.NET Core依赖注入框架进行单独介绍。为了让读者朋友能够更好地理解.NET Core依赖注入框架的设计与实现,我们按照类似的原理创建了一个简易版本的依赖注入框架,也就是我们在前面多次提及的Cat。

在前面的章节中,我们从纯理论的角度对依赖注入进行了深入论述,我们接下来会对.NET Core依赖注入框架进行单独介绍。为了让读者朋友能够更好地理解.NET Core依赖注入框架的设计与实现,我们按照类似的原理创建了一个简易版本的依赖注入框架,也就是我们在前面多次提及的Cat。

源代码下载

普通服务的注册与消费 泛型服务的注册与消费 多服务实例的提供 服务实例的生命周期

一、编程体验

虽然我们对这个名为Cat的依赖注入框架进行了最大限度的简化,但是与.NET Core框架内部使用的真实依赖注入框架相比,Cat不仅采用了一致的设计,而且几乎具备了后者所有的功能特性。为了让大家对Cat具有一个感官的认识,我们先来演示一下如何利用它来提供我们所需的服务实例。

作为依赖注入容器的Cat对象不仅仅作为服务实例的提供者,它同时还需要维护着服务实例的生命周期。Cat提供了三种生命周期模式,如果要了解它们之间的差异,就必须对多个Cat之间的层次关系有充分的认识。一个代表依赖注入容器的Cat对象用来创建其他的Cat对象,后者视前者为“父容器”,所以多个Cat对象通过其“父子关系”维系一个树形层次化结构。不过这仅仅是一个逻辑结构而已,实际上每个Cat对象只会按照下图所示的方式引用整棵树的根。

3-6_thumb2

在了解了多个Cat对象之间的关系之后,对于三种预定义的生命周期模式就很好理解了。如下所示的Lifetime枚举代表着三种生命周期模式,其中Transient代表容器针对每次服务请求都会创建一个新的服务实例,而Self则是将提供服务实例保存在当前容器中,它代表针对某个容器范围内的单例模式,Root则是将每个容器提供的服务实例统一存放到根容器中,所以该模式能够在多个“同根”容器范围内确保提供的服务是单例的。

  1. public enum Lifetime
  2. {
  3. Root,
  4. Self,
  5. Transient
  6. }

代表依赖注入容器的Cat对象之所以能够为我们提供所需服务实例,其根本前提是相应的服务注册在此之前已经添加到容器之中。服务总是针对服务类型(接口、抽象类或者具体类型)进行注册,Cat通过定义的扩展方法提供了如下三种注册方式。除了直接提供服务实例的形式外(默认采用Root模式),我们在注册服务的时候必须指定一个具体的生命周期模式。

  • 指定具体的实现类型。

  • 提供一个服务实例。

  • 指定一个创建服务实例的工厂。

我们定义了如下的接口和对应的实现类型来演示针对Cat的服务注册。其中Foo、Bar、Baz和Gux分别实现了对应的接口IFoo、IBar、IBaz和IGux,其中Gux类型上标注了一个MapToAttribute特性注册了与对应接口IGux之间的映射。为了反映Cat对服务实例生命周期的控制,我们让它们派生于同一个基类Base。Base实现了IDisposable接口,我们在其构造函数和实现的Dispose方法中输出相应的文本以确定对应的实例何时被创建和释放。我们还定义了一个泛型的接口IFoobar<T1, T2>和对应的实现类Foobar<T1, T2>来演示Cat针对泛型服务实例的提供。

  1. public interface IFoo {}
  2. public interface IBar {}
  3. public interface IBaz {}
  4. public interface IGux {}
  5. public interface IFoobar<T1, T2> {}
  6. public class Base : IDisposable
  7. {
  8. public Base() => Console.WriteLine($"Instance of {GetType().Name} is created.");
  9. public void Dispose() => Console.WriteLine($"Instance of {GetType().Name} is disposed.");
  10. }
  11.  
  12. public class Foo : Base, IFoo{ }
  13. public class Bar : Base, IBar{ }
  14. public class Baz : Base, IBaz{ }
  15. [MapTo(typeof(IGux), Lifetime.Root)]
  16. public class Gux : Base, IGux { }
  17. public class Foobar<T1, T2>: IFoobar<T1,T2>
  18. {
  19. public IFoo Foo { get; }
  20. public IBar Bar { get; }
  21. public Foobar(IFoo foo, IBar bar)
  22. {
  23. Foo = foo;
  24. Bar = bar;
  25. }
  26. }

在如下所示的代码片段中我们创建了一个Cat对象并采用上面提到的方式针对接口IFoo、IBar和IBaz注册了对应的服务,它们采用的生命周期模式分别为Transient、Self和Root。然后我们还调用了另一个将当前入口程序集作为参数的Register方法,该方法会解析指定程序集中标注了MapToAttribute特性的类型并作相应的服务注册,对于我们演示的程序来,该方法会完成针对IGux/Gux类型的服务注册。接下来我们利用Cat对象创建了它的两个子容器,并调用子容器的GetService<T>方法提供相应的服务实例。

  1. class Program
  2. {
  3. static void Main()
  4. {
  5. var root = new Cat()
  6. .Register<IFoo, Foo>(Lifetime.Transient)
  7. .Register<IBar>(_=> new Bar(), Lifetime.Self)
  8. .Register<IBaz, Baz>(Lifetime.Root)
  9. .Register(Assembly.GetEntryAssembly());
  10. var cat1 = root.CreateChild();
  11. var cat2 = root.CreateChild();
  12.  
  13. void GetServices<TService>(Cat cat)
  14. {
  15. cat.GetService<TService>();
  16. cat.GetService<TService>();
  17. }
  18.  
  19. GetServices<IFoo>(cat1);
  20. GetServices<IBar>(cat1);
  21. GetServices<IBaz>(cat1);
  22. GetServices<IGux>(cat1);
  23. Console.WriteLine();
  24. GetServices<IFoo>(cat2);
  25. GetServices<IBar>(cat2);
  26. GetServices<IBaz>(cat2);
  27. GetServices<IGux>(cat2);
  28. }
  29. }

上面的程序运行之后会在控制台上输出如图3-7所示的结果,输出的内容不仅表明Cat能够根据添加的服务注册提供对应类型的服务实例,还体现了它对生命周期的控制。由于服务IFoo被注册为Transient服务,所以Cat针对该接口的服务提供四次请求都会创建一个全新的Foo对象。IBar服务的生命周期模式为Self,如果我们利用同一个Cat对象来提供对应的服务实例,该Cat对象只会创建一个Bar对象,所以整个过程中会创建两个Bar对象。IBaz和IGux服务采用Root生命周期,所以具有同根的两个Cat对象提供的总是同一个Baz/Gux对象,后者只会被创建一次。

3-7_thumb2

除了提供类似于IFoo、IBar和IBaz这样非泛型的服务实例之外,如果具有针对泛型定义(Generic Definition)的服务注册,Cat同样也能提供泛型服务实例。如下面的代码片段所示,在为创建的Cat对象添加了针对IFoo和IBar接口的服务注册之后,我们调用Register方法注册了针对泛型定义IFoobar<,>的服务注册,具体的实现类型为Foobar<,>。当我们利用Cat对象提供一个类型为IFoobar<IFoo, IBar>的服务实例的时候,它会创建并返回一个Foobar<Foo, Bar>对象。

  1. public class Program
  2. {
  3. public static void Main()
  4. {
  5. var cat = new Cat()
  6. .Register<IFoo, Foo>(Lifetime.Transient)
  7. .Register<IBar, Bar>(Lifetime.Transient)
  8. .Register(typeof(IFoobar<,>), typeof(Foobar<,>), Lifetime.Transient);
  9.  
  10. var foobar = (Foobar<IFoo, IBar>)cat.GetService<IFoobar<IFoo, IBar>>();
  11. Debug.Assert(foobar.Foo is Foo);
  12. Debug.Assert(foobar.Bar is Bar);
  13. }
  14. }

当我们在进行服务注册的时候,可以为同一个类型添加多个服务注册。虽然添加的所有服务注册均是有效的,不过由于扩展方法GetService<TService>总是返回一个唯一的服务实例,我们对该方法采用了“后来居上”的策略,即总是采用最近添加的服务注册来创建服务实例。如果我们调用另一个扩展方法GetServices<TService>,它将利用返回根据所有服务注册提供的服务实例。

如下面的代码片段所示,我们为创建的Cat对象添加了三个针对Base类型的服务注册,对应的实现类型分别为Foo、Bar和Baz。我们最后将Base作为泛型参数调用了GetServices<Base>方法,该方法会返回包含三个Base对象的集合,集合元素的类型分别为Foo、Bar和Baz。

  1. public class Program
  2. {
  3. public static void Main()
  4. {
  5. var services = new Cat()
  6. .Register<Base, Foo>(Lifetime.Transient)
  7. .Register<Base, Bar>(Lifetime.Transient)
  8. .Register<Base, Baz>(Lifetime.Transient)
  9. .GetServices<Base>();
  10. Debug.Assert(services.OfType<Foo>().Any());
  11. Debug.Assert(services.OfType<Bar>().Any());
  12. Debug.Assert(services.OfType<Baz>().Any());
  13. }
  14. }

如果提供的服务实例实现了IDisposable接口,我们应该在适当的时候调用其Dispose方法释放该服务实例。由于服务实例的生命周期完全由作为依赖注入容器的Cat对象来管理,那么通过调用Dispose方法来释放服务实例自然也应该由它来负责。Cat针对提供服务实例的释放策略取决于采用的生命周期模式,具体的策略如下:

  • Transient和Self:所有实现了IDisposable接口的服务实例会被当前Cat对象保存起来,当Cat对象自身的Dispose方法被调用的时候,这些服务实例的Dispose方法会随之被调用。
  • Root:由于服务实例保存在作为根容器的Cat对象上,所以当这个Cat对象的Dispose方法被调用的时候,这些服务实例的Dispose方法会随之被调用。

上述的释放策略可以通过如下的演示实例来印证。我们在如下的代码片段中创建了一个Cat对象,并添加了相应的服务注册。我们接下来调用了CreateChild方法创建代表子容器的Cat对象,并用它提供了四个注册服务对应的实例。

  1. class Program
  2. {
  3. static void Main()
  4. {
  5. using (var root = new Cat()
  6. .Register<IFoo, Foo>(Lifetime.Transient)
  7. .Register<IBar>(_ => new Bar(), Lifetime.Self)
  8. .Register<IBaz, Baz>(Lifetime.Root)
  9. .Register(Assembly.GetEntryAssembly()))
  10. {
  11. using (var cat = root.CreateChild())
  12. {
  13. cat.GetService<IFoo>();
  14. cat.GetService<IBar>();
  15. cat.GetService<IBaz>();
  16. cat.GetService<IGux>();
  17. Console.WriteLine("Child cat is disposed.");
  18. }
  19. Console.WriteLine("Root cat is disposed.");
  20. }
  21. }
  22. }

由于两个Cat对象的创建都是在using块中进行的,所以它们的Dispose方法都会在using块结束的地方被调用。为了确定方法被调用的时机,我们特意在控制台上打印了相应的文字。该程序运行之后会在控制台上输出如下图所示的结果,我们可以看到当作为子容器的Cat对象的Dispose方法被调用的时候,由它提供的两个生命周期模式分别为Transient和Self的两个服务实例(Foo和Bar)被正常释放了。至于生命周期模式为Root的服务实例Baz和Gux,它的Dispose方法会延迟到作为根容器的Cat对象的Dispose方法被调用的时候。

3-8_thumb2

二、设计与实现

在完成针对Cat的编程体验之后,我们来聊聊这个依赖注入容器的设计原理和具体实现。由于作为依赖注入容器的Cat对象总是利用预先添加的服务注册来提供对应的服务实例,所以服务注册至关重要。如下所示的就是表示服务注册的ServiceRegistry的定义,它具有三个核心属性(ServiceType、Lifetime和Factory),分别代表服务类型、生命周期模式和用来创建服务实例的工厂。最终用来创建服务实例的工厂体现为一个类型为Func<Cat,Type[], object>的委托对象,它的两个输入分别代表当前使用的Cat对象以及提供服务类型的泛型参数,如果提供的服务类型并不是一个泛型类型,这个参数被会指定为一个空的数组。

  1. public class ServiceRegistry
  2. {
  3. public Type ServiceType { get; }
  4. public Lifetime Lifetime { get; }
  5. public Func<Cat,Type[], object> actory { get; }
  6. internal ServiceRegistry Next { get; set; }
  7.  
  8. public ServiceRegistry(Type serviceType, Lifetime lifetime, Func<Cat,Type[], object> factory)
  9. {
  10. ServiceType = serviceType;
  11. Lifetime = lifetime;
  12. Factory = factory;
  13. }
  14.  
  15. internal IEnumerable<ServiceRegistry> AsEnumerable()
  16. {
  17. var list = new List<ServiceRegistry>();
  18. for (var self = this; self!=null; self= self.Next)
  19. {
  20. list.Add(self);
  21. }
  22. return list;
  23. }
  24. }

我们将针对同一个服务类型(ServiceType属性相同)的多个ServiceRegistry组成一个链表,作为相邻节点的两个ServiceRegistry对象通过Next属性关联起来。我们为ServiceRegistry定义了一个AsEnumerable方法使它返回由当前以及后续节点组成的ServiceRegistry集合。如果当前ServiceRegistry为链表头,那么这个方法会返回链表上的所有ServiceRegistry对象。下图体现了服务注册核心三要素和链表结构。

3-9_thumb2

在了解了表示服务注册的ServiceRegistry之后,我们来着重介绍表示依赖注入容器的Cat类型。如下面的代码片段所示,Cat同时实现了IServiceProvider和IDisposable接口,定义在前者中的GetService方法用于提供服务实例。作为根容器的Cat对象通过公共构造函数创建,另一个内部构造函数则用来创建作为子容器的Cat对象,指定的Cat对象将作为父容器。

  1. public class Cat : IServiceProvider, IDisposable
  2. {
  3. internal readonly Cat _root;
  4. internal readonly ConcurrentDictionary<Type, ServiceRegistry> _registries;
  5. private readonly ConcurrentDictionary<Key, object> _services;
  6. private readonly ConcurrentBag<IDisposable> _disposables;
  7. private volatile bool _disposed;
  8.  
  9. public Cat()
  10. {
  11. _registries = new ConcurrentDictionary<Type, ServiceRegistry>();
  12. _root = this;
  13. _services = new ConcurrentDictionary<Key, object>();
  14. _disposables = new ConcurrentBag<IDisposable>();
  15. }
  16.  
  17. internal Cat(Cat parent)
  18. {
  19. _root = parent._root;
  20. _registries = _root._registries;
  21. _services = new ConcurrentDictionary<Key, object>();
  22. _disposables = new ConcurrentBag<IDisposable>();
  23. }
  24.  
  25. private void EnsureNotDisposed()
  26. {
  27. if (_disposed)
  28. {
  29. throw new ObjectDisposedException("Cat");
  30. }
  31. }
  32. ...
  33. }

作为根容器的Cat对象通过_root字段表示。_registries字段返回的ConcurrentDictionary<Type, ServiceRegistry>对象用来存储所有添加的服务注册,该字典对象的Key和Value分别表示服务类型和ServiceRegistry链表,下图体现这一映射关系。由于需要负责完成对提供服务实例的释放工作,所以我们需要将实现了IDisposable接口的服务实例保存在通过_disposables字段表示的集合中。

3-10_thumb2

由当前Cat对象提供的非Transient服务实例保存在由_services字段表示的一个ConcurrentDictionary<Key, object>对象上,该字典对象的键类型为如下所示的Key,它相当于是创建服务实例所使用的ServiceRegistry对象和泛型参数类型数组的组合。

  1. internal class Key : IEquatable<Key>
  2. {
  3. public ServiceRegistry Registry { get; }
  4. public Type[] GenericArguments { get; }
  5.  
  6. public Key(ServiceRegistry registry, Type[] genericArguments)
  7. {
  8. Registry = registry;
  9. GenericArguments = genericArguments;
  10. }
  11.  
  12. public bool Equals(Key other)
  13. {
  14. if (Registry != other.Registry)
  15. {
  16. return false;
  17. }
  18. if (GenericArguments.Length != other.GenericArguments.Length)
  19. {
  20. return false;
  21. }
  22. for (int index = 0; index < GenericArguments.Length; index++)
  23. {
  24. if (GenericArguments[index] != other.GenericArguments[index])
  25. {
  26. return false;
  27. }
  28. }
  29. return true;
  30. }
  31.  
  32. public override int GetHashCode()
  33. {
  34. var hashCode = Registry.GetHashCode();
  35. for (int index = 0; index < GenericArguments.Length; index++)
  36. {
  37. hashCode ^= GenericArguments[index].GetHashCode();
  38. }
  39. return hashCode;
  40. }
  41. public override bool Equals(object obj) => obj is Key key ? Equals(key) : false;
  42. }

虽然我们为Cat定义了若干扩展方法来提供多种不同的服务注册,但是这些方法最终都会调用如下这个Register方法,该方法会将提供的ServiceRegistry添加到_registries字段表示的字典对象中。值得注意的是,不论我们是调用哪个Cat对象的Register方法,指定的ServiceRegistry都会被添加到作为根容器的Cat对象上。

  1. public class Cat : IServiceProvider, IDisposable
  2. {
  3. public Cat Register(ServiceRegistry registry)
  4. {
  5. EnsureNotDisposed();
  6. if (_registries.TryGetValue(registry.ServiceType, out var existing))
  7. {
  8. _registries[registry.ServiceType] = registry;
  9. registry.Next = existing;
  10. }
  11. else
  12. {
  13. _registries[registry.ServiceType] = registry;
  14. }
  15. return this;
  16. }
  17. ...
  18. }

用来提供服务实例的核心操作实现在如下这个GetServiceCore方法中。如下面的代码片段所示,我们在调用该方法的时候需要指定对应的ServiceRegistry对象的服务类型的泛型参数。当该方法被执行的时候,对于Transient的生命周期模式,它会直接利用ServiceRegistry提供的工厂来创建服务实例。如果服务实例的类型实现了IDisposable接口,该对象会被添加到_disposables字段表示的待释放服务实例列表中。对于Root和Self生命周期模式,该方法会先根据提供的ServiceRegistry判断是否对应的服务实例已经存在,存在的服务实例会直接返回。

  1. public class Cat : IServiceProvider, IDisposable
  2. {
  3. private object GetServiceCore(ServiceRegistry registry, Type[] genericArguments)
  4. {
  5. var key = new Key(registry, genericArguments);
  6. var serviceType = registry.ServiceType;
  7.  
  8. switch (registry.Lifetime)
  9. {
  10. case Lifetime.Root: return GetOrCreate(_root._services, _root._disposables);
  11. case Lifetime.Self: return GetOrCreate(_services, _disposables);
  12. default:
  13. {
  14. var service = registry.Factory(this, genericArguments);
  15. if (service is IDisposable disposable && disposable != this)
  16. {
  17. _disposables.Add(disposable);
  18. }
  19. return service;
  20. }
  21. }
  22.  
  23. object GetOrCreate(ConcurrentDictionary<Key, object> services, ConcurrentBag<IDisposable> disposables)
  24. {
  25. if (services.TryGetValue(key, out var service))
  26. {
  27. return service;
  28. }
  29. service = registry.Factory(this, genericArguments);
  30. services[key] = service;
  31. if (service is IDisposable disposable)
  32. {
  33. disposables.Add(disposable);
  34. }
  35. return service;
  36. }
  37. }
  38. }

GetServiceCore方法只有在指定ServiceRegistry对应的服务实例不存在的情况下才会利用提供的工厂来创建服务实例,创建的服务实例会根据生命周期模式保存到作为根容器的Cat对象或者当前Cat对象上。如果提供的服务实例实现了IDisposable接口,在采用Root生命周期模式下会被保存到作为根容器的Cat对象的待释放列表中。如果生命周期模式为Self,它会被添加到当前Cat对象的待释放列表中。

在实现的GetService方法中,Cat会根据指定的服务类型找到对应的ServiceRegistry对象,并最终调用GetServiceCore方法来提供对应的服务实例。GetService方法还会解决一些特殊服务的提供问题,比如若服务类型为Cat或者IServiceProvider,该方法返回的就是它自己。如果服务类型为IEnumerable<T>,GetService方法会根据泛型参数类型T找到所有的ServiceRegistry并利用它们来创建对应的服务实例,最终返回的是由这些服务实例组成的集合。除了这些,针对泛型服务实例的提供也是在这个方法中解决的。

  1. public class Cat : IServiceProvider, IDisposable
  2. {
  3. public object GetService(Type serviceType)
  4. {
  5. EnsureNotDisposed();
  6.  
  7. if (serviceType == typeof(Cat) || serviceType == typeof(IServiceProvider))
  8. {
  9. return this;
  10. }
  11.  
  12. ServiceRegistry registry;
  13. //IEnumerable<T>
  14. if (serviceType.IsGenericType && serviceType.GetGenericTypeDefinition() == typeof(IEnumerable<>))
  15. {
  16. var elementType = serviceType.GetGenericArguments() [0];
  17. if (!_registries.TryGetValue(elementType, out registry))
  18. {
  19. return Array.CreateInstance(elementType, 0);
  20. }
  21.  
  22. var registries = registry.AsEnumerable();
  23. var services = registries.Select(it => GetServiceCore(it, Type.EmptyTypes)).ToArray();
  24. Array array = Array.CreateInstance(elementType, services.Length);
  25. services.CopyTo(array, 0);
  26. return array;
  27. }
  28.  
  29. //Generic
  30. if (serviceType.IsGenericType && !_registries.ContainsKey(serviceType))
  31. {
  32. var definition = serviceType.GetGenericTypeDefinition();
  33. return _registries.TryGetValue(definition, out registry)
  34. ? GetServiceCore(registry, serviceType.GetGenericArguments())
  35. : null;
  36. }
  37.  
  38. //Normal
  39. return _registries.TryGetValue(serviceType, out registry)
  40. ? GetServiceCore(registry, new Type[0])
  41. : null;
  42. }
  43. ...
  44. }

在实现的Dispose方法中,由于所有待释放的服务实例已经保存到_disposables字段表示的集合中,所以我们只需要依次调用它们的Dispose方法即可。在释放了所有服务实例并清空待释放列表后,Dispose还会清空_services字段表示的服务实例列表。

  1. public class Cat : IServiceProvider, IDisposable
  2. {
  3. public void Dispose()
  4. {
  5. _disposed = true;
  6. foreach(var disposable in _disposables)
  7. {
  8. disposable.Dispose();
  9. }
  10. _disposables.Clear();
  11. _services.Clear();
  12. }
  13. ...
  14. }

三、扩展方法

为了方便注册服务,我们定义了如下六个Register扩展方法。由于服务注册的添加总是需要调用Cat自身的Register方法来完成,所以这些方法最终都需要创建一个代表服务注册的ServiceRegistry对象。对于一个ServiceRegistry对象来说,它最为核心的元素莫过于表示服务实例创建工厂的Func<Cat,Type[], object>对象,所以上述这六个扩展方法需要解决的就是创建这么一个委托对象。

  1. public static class CatExtensions
  2. {
  3. public static Cat Register(this Cat cat, Type from, Type to, Lifetime lifetime)
  4. {
  5. Func<Cat, Type[], object> factory = (_, arguments) => Create(_, to, arguments);
  6. cat.Register(new ServiceRegistry(from, lifetime, factory));
  7. return cat;
  8. }
  9.  
  10. public static Cat Register<TFrom, TTo>(this Cat cat, Lifetime lifetime) where TTo:TFrom
  11. => cat. Register(typeof(TFrom), typeof(TTo), lifetime);
  12.  
  13. public static Cat Register(this Cat cat, Type serviceType, object instance)
  14. {
  15. Func<Cat, Type[], object> factory = (_, arguments) => instance;
  16. cat.Register(new ServiceRegistry(serviceType, Lifetime.Root, factory));
  17. return cat;
  18. }
  19.  
  20. public static Cat Register<TService>(this Cat cat, TService instance)
  21. {
  22. Func<Cat, Type[], object> factory = (_, arguments) => instance;
  23. cat.Register(new ServiceRegistry(typeof(TService), Lifetime.Root, factory));
  24. return cat;
  25. }
  26.  
  27. public static Cat Register(this Cat cat, Type serviceType,
  28. Func<Cat, object> factory, Lifetime lifetime)
  29. {
  30. cat.Register(new ServiceRegistry(serviceType, lifetime, (_, arguments) => factory(_)));
  31. return cat;
  32. }
  33.  
  34. public static Cat Register<TService>(this Cat cat,
  35. Func<Cat,TService> factory, Lifetime lifetime)
  36. {
  37. cat.Register(new ServiceRegistry(typeof(TService), lifetime, (_,arguments)=>factory(_)));
  38. return cat;
  39. }
  40.  
  41. private static object Create(Cat cat, Type type, Type[] genericArguments)
  42. {
  43. if (genericArguments.Length > 0)
  44. {
  45. type = type.MakeGenericType(genericArguments);
  46. }
  47. var constructors = type.GetConstructors();
  48. if (constructors.Length == 0)
  49. {
  50. throw new InvalidOperationException($"Cannot create the instance of
  51. {type} which does not have a public constructor.");
  52. }
  53. var constructor = constructors.FirstOrDefault(it => it.GetCustomAttributes(false).OfType<InjectionAttribute>().Any());
  54. constructor ??= constructors.First();
  55. var parameters = constructor.GetParameters();
  56. if (parameters.Length == 0)
  57. {
  58. return Activator.CreateInstance(type);
  59. }
  60. var arguments = new object[parameters.Length];
  61. for (int index = 0; index < arguments.Length; index++)
  62. {
  63. arguments[index] = cat.GetService(parameters[index].ParameterType);
  64. }
  65. return constructor.Invoke(arguments);
  66. }
  67. }

由于前两个重载指定的是服务实现类型,所以我们需要调用对应的构造函数来创建服务实例,这一逻辑实现在私有的Create方法中。第三个扩展方法指定的直接就是服务实例,所以我们很容易将提供的参数转换成一个Func<Cat,Type[], object>。

我们刻意简化了构造函数的筛选逻辑。为了解决构造函数的选择问题,我们引入如下这个InjectionAttribute特性。我们将所有公共实例构造函数作为候选的构造函数,并会优先选择标注了该特性的构造函数。当构造函数被选择出来后,我们需要通过分析其参数类型并利用Cat对象来提供具体的参数值,这实际上是一个递归的过程。最终我们将针对构造函数的调用转换成Func<Cat,Type[], object>对象,进而创建出表示服务注册的ServiceRegistry对象。

  1. [AttributeUsage( AttributeTargets.Constructor)]
  2. public class InjectionAttribute: Attribute {}

前面给出的代码片段还提供了HasRegistry和HasRegistry<T>方法来确定指定类型的服务注册是否存在。除此之外,用于提供服务实例的泛型方法GetService<T>和用于提供所有指定类型服务实例的GetServices<TService>方法采用了如下的定义方式。

  1. public static class CatExtensions
  2. {
  3. public static IEnumerable<TService> GetServices<T>(this Cat cat) => cat.GetService<IEnumerable<TService >>();
  4. public static TService GetService<TService >(this Cat cat) => (TService)cat.GetService(typeof(T));
  5. }

上述六个扩展方法帮助我们完成针对单一服务的注册,有时间我们的项目中可能会出现非常多的服务需要注册,如何能够完成针对它们的批量注册会是不错的选择。我们的依赖注入框架提供了针对程序集范围的批量服务注册。为了标识带注册的服务,我们需要在服务实现类型上标注如下这个MapToAttribute类型,并指定服务类型(一般为它实现的接口或者继承的基类)和生命周期。

  1. [AttributeUsage( AttributeTargets.Class, AllowMultiple = true)]
  2. public sealed class MapToAttribute: Attribute
  3. {
  4. public Type ServiceType { get; }
  5. public Lifetime Lifetime { get; }
  6.  
  7. public MapToAttribute(Type serviceType, Lifetime lifetime)
  8. {
  9. ServiceType = serviceType;
  10. Lifetime = lifetime;
  11. }
  12. }

针对程序集范围的批量服务注册实现在Cat的如下这个Register扩展方法中。如下面的代码片段所示,该方法会从指定程序集中获取所有标注了MapToAttribute特性的类型,并提取出服务类型、实现类型和生命周期模型,然后利用它们批量完成所需的服务注册。

  1. public static class CatExtensions
  2. {
  3. public static Cat Register(this Cat cat, Assembly assembly)
  4. {
  5. var typedAttributes = from type in assembly.GetExportedTypes()
  6. let attribute = type.GetCustomAttribute<MapToAttribute>()
  7. where attribute != null
  8. select new { ServiceType = type, Attribute = attribute };
  9. foreach (var typedAttribute in typedAttributes)
  10. {
  11. cat.Register(typedAttribute.Attribute.ServiceType,
  12. typedAttribute.ServiceType, typedAttribute.Attribute.Lifetime);
  13. }
  14. return cat;
  15. }
  16. }

除了上述这七个用来注册服务的Register扩展方法,我们还为Cat类型定义了如下两个扩展方法,其中CreateService<T>方法以泛型参数的形式指定获取服务实例对应注册的类型,CreateServices<T>方法会提供指定服务类型的所有实例,而CreateChild方法则帮助我们创建一个代表子容器的Cat对象。

  1. public static class CatExtensions
  2. {
  3. public static T GetService<T>(this Cat cat) => (T)cat.GetService(typeof(T));
  4. public static IEnumerable<T> GetServices<T>(this Cat cat) => cat.GetService<IEnumerable<T>>();
  5. public static Cat CreateChild(this Cat cat) => new Cat(cat);
  6. }

依赖注入[4]:一个迷你版DI框架 - 图7

作者:蒋金楠微信公众账号:大内老A微博:www.weibo.com/artech如果你想及时得到个人撰写文章以及著作的消息推送,或者想看看个人推荐的技术资料,可以扫描左边二维码(或者长按识别二维码)关注个人公众号)。本文版权归作者和博客园共有,欢迎转载,但未经作者同意必须保留此段声明,且在文章页面明显位置给出原文连接,否则保留追究法律责任的权利。

原文:https://www.cnblogs.com/artech/p/inside-asp-net-core-03-04.html