首先谈一下IServiceProvider
IServiceProvider只提供给了一个根据类型获取对象的功能,试想一下IOC总得有一个找到对象,具体如下
public interface IServiceProvider { object GetService(Type serviceType); }
再谈一下ServiceProvider
ServiceProvider实例化了IServiceProvider,也就是实现了GetService,用于获取容器中实际对象,但是它是借助于IServiceProviderEngine(这个接口稍后再介绍),具体如下:
public object GetService(Type serviceType) { return this._engine.GetService(serviceType); }
另外ServiceCollection中有一个方法BuildServiceProvider(存在于类ServiceCollectionContainerBuilderExtensions中),返回值对象类型就是ServiceProvider
/// <summary> /// Extension methods for building a <see cref="T:Microsoft.Extensions.DependencyInjection.ServiceProvider" /> from an <see cref="T:Microsoft.Extensions.DependencyInjection.IServiceCollection" />. /// </summary> public static class ServiceCollectionContainerBuilderExtensions { /// <summary> /// Creates a <see cref="T:Microsoft.Extensions.DependencyInjection.ServiceProvider" /> containing services from the provided <see cref="T:Microsoft.Extensions.DependencyInjection.IServiceCollection" />. /// </summary> /// <param name="services">The <see cref="T:Microsoft.Extensions.DependencyInjection.IServiceCollection" /> containing service descriptors.</param> /// <returns>The <see cref="T:Microsoft.Extensions.DependencyInjection.ServiceProvider" />.</returns> public static ServiceProvider BuildServiceProvider( this IServiceCollection services) { return services.BuildServiceProvider(ServiceProviderOptions.Default); } /// <summary> /// Creates a <see cref="T:Microsoft.Extensions.DependencyInjection.ServiceProvider" /> containing services from the provided <see cref="T:Microsoft.Extensions.DependencyInjection.IServiceCollection" /> /// optionaly enabling scope validation. /// </summary> /// <param name="services">The <see cref="T:Microsoft.Extensions.DependencyInjection.IServiceCollection" /> containing service descriptors.</param> /// <param name="validateScopes"> /// <c>true</c> to perform check verifying that scoped services never gets resolved from root provider; otherwise <c>false</c>. /// </param> /// <returns>The <see cref="T:Microsoft.Extensions.DependencyInjection.ServiceProvider" />.</returns> public static ServiceProvider BuildServiceProvider( this IServiceCollection services, bool validateScopes) { return services.BuildServiceProvider(new ServiceProviderOptions() { ValidateScopes = validateScopes }); } /// <summary> /// Creates a <see cref="T:Microsoft.Extensions.DependencyInjection.ServiceProvider" /> containing services from the provided <see cref="T:Microsoft.Extensions.DependencyInjection.IServiceCollection" /> /// optionaly enabling scope validation. /// </summary> /// <param name="services">The <see cref="T:Microsoft.Extensions.DependencyInjection.IServiceCollection" /> containing service descriptors.</param> /// <param name="options"> /// Configures various service provider behaviors. /// </param> /// <returns>The <see cref="T:Microsoft.Extensions.DependencyInjection.ServiceProvider" />.</returns> public static ServiceProvider BuildServiceProvider( this IServiceCollection services, ServiceProviderOptions options) { if (services == null) throw new ArgumentNullException(nameof (services)); if (options == null) throw new ArgumentNullException(nameof (options)); return new ServiceProvider((IEnumerable<ServiceDescriptor>) services, options); } }
必须要结合一下IServiceProviderEngine、ServiceProviderEngine和ServiceProviderEngineScope对象才能具体知道ServiceProvider是怎么获取IOC容器中的对象了
在使用BuildServiceProvider的时候,最终会调用new ServiceProvider((IEnumerable<ServiceDescriptor>)services,options),然后就是调用如下函数:
internal ServiceProvider( IEnumerable<ServiceDescriptor> serviceDescriptors, ServiceProviderOptions options) { IServiceProviderEngineCallback callback = (IServiceProviderEngineCallback) null; if (options.ValidateScopes) { callback = (IServiceProviderEngineCallback) this; this._callSiteValidator = new CallSiteValidator(); } switch (options.Mode) { case ServiceProviderMode.Dynamic: this._engine = (IServiceProviderEngine) new DynamicServiceProviderEngine(serviceDescriptors, callback); break; case ServiceProviderMode.Runtime: this._engine = (IServiceProviderEngine) new RuntimeServiceProviderEngine(serviceDescriptors, callback); break; case ServiceProviderMode.Expressions: this._engine = (IServiceProviderEngine) new ExpressionsServiceProviderEngine(serviceDescriptors, callback); break; case ServiceProviderMode.ILEmit: this._engine = (IServiceProviderEngine) new ILEmitServiceProviderEngine(serviceDescriptors, callback); break; default: throw new NotSupportedException("Mode"); } }
就是说最终还是根据ServiceProviderMode来判断需要实例化哪种ServiceProviderEngine,现在简单举例DynamicServiceProviderEngine。DynamicServiceProviderEngine最终还是继承ServiceProviderEngine,
所以上面说的GetService其实就是调用了ServiceProviderEngine的GetService
public object GetService(Type serviceType) { return this.GetService(serviceType, this.Root); }
其中this.Root就是实例化的ServiceProviderScope。上面的this.GetService(serviceType,this.Root)会调用如下函数:
internal object GetService( Type serviceType, ServiceProviderEngineScope serviceProviderEngineScope) { if (this._disposed) ThrowHelper.ThrowObjectDisposedException(); Func<ServiceProviderEngineScope, object> orAdd = this.RealizedServices.GetOrAdd(serviceType, this._createServiceAccessor); this._callback?.OnResolve(serviceType, (IServiceScope) serviceProviderEngineScope); ServiceProviderEngineScope providerEngineScope = serviceProviderEngineScope; return orAdd(providerEngineScope); }
最终就是调用Func<ServiceProviderEngineScope, object> orAdd = this.RealizedServices.GetOrAdd(serviceType, this._createServiceAccessor);其中RealizedServices是ConcurrentDictionary<Type, Func<ServiceProviderEngineScope, object>> RealizedServices { get; },this._createServiceAccessor是Func<ServiceProviderEngineScope, object>,通过这个委托根据ServiceProviderEngineScope获取最终的对象,也就是说,如果服务存在的话就从字典中获取,不存在就添加到队列上,并直接返回。另外在实例化ServiceProviderEngine的时候实例化了this._createServiceAccessor = new Func<Type, Func<ServiceProviderEngineScope, object>>(this.CreateServiceAccessor);其中CreateServiceAccessor是一个函数,定义如下:
private Func<ServiceProviderEngineScope, object> CreateServiceAccessor( Type serviceType) { IServiceCallSite callSite = this.CallSiteFactory.CreateCallSite(serviceType, new CallSiteChain()); if (callSite == null) return (Func<ServiceProviderEngineScope, object>) (_ => (object) null); this._callback?.OnCreate(callSite); return this.RealizeService(callSite); }
就DynamicServiceProviderEngine而言,RealizeService的定义如下:
protected override Func<ServiceProviderEngineScope, object> RealizeService( IServiceCallSite callSite) { int callCount = 0; return (Func<ServiceProviderEngineScope, object>) (scope => { if (Interlocked.Increment(ref callCount) == 2) Task.Run<Func<ServiceProviderEngineScope, object>>((Func<Func<ServiceProviderEngineScope, object>>) (() => base.RealizeService(callSite))); return this.RuntimeResolver.Resolve(callSite, scope); }); }
RuntimeResolver是ServiceProviderEngine的一个属性。到此为止,IOC容器的数据就可以获取到了。下篇博客会继续说明this.RuntimeResover.Resolve下的事情。