手把手教你写DI_3_小白徒手支持 Singleton 和 Scoped 生命周期

在上一节&＃xff1a;手把手教你写DI_2_小白徒手撸构造函数注入

浑身绷带的小白同学&＃xff1a;我们继续开展我们的工作&＃xff0c;大家都知道 Singleton是什么&＃xff0c;就是全局只有一个呗&＃xff0c;我们就先从它开始&＃xff0c;这个多简单&＃xff0c;我们找个字典放这些对象就ok啦

public class ServiceProvider : IServiceProvider
{...private readonly ConcurrentDictionary singletonCache &＃61; new ConcurrentDictionary();public object GetService(Type serviceType){case Lifetime.Singleton:singletonCache.GetOrAdd(serviceType, x &＃61;> {if(defintion is DelegateServiceDefintion defi){return defi.ImplementationFactory(this);}else{ConstructorInfo constructor &＃61; cache.GetOrAdd(serviceType, i &＃61;> {var d &＃61; defintion as TypeServiceDefintion;var implementationType &＃61; serviceType.IsConstructedGenericType ? d.ImplementationType.MakeGenericType(serviceType.GenericTypeArguments): d.ImplementationType;return implementationType.GetConstructors().FirstOrDefault(i &＃61;> i.IsPublic);});ar ps &＃61; constructor.GetParameters();var args &＃61; new object[ps.Length];for (int j &＃61; 0; j }

大神&＃xff1a;我的刀呢&＃xff1f;

小白同学&＃xff1a;我错啦&＃xff01;&＃xff01;&＃xff01;

public class ServiceProvider : IServiceProvider
{...private readonly ConcurrentDictionary singletonCache &＃61; new ConcurrentDictionary();public object GetService(Type serviceType){case Lifetime.Singleton:return singletonCache.GetOrAdd(serviceType, x &＃61;> CreateObj(x));case Lifetime.Scoped:return CreateObj(x);case Lifetime.Transient:return CreateObj(x);....}public object CreateObj(Type serviceType){if(defintion is DelegateServiceDefintion defi){return defi.ImplementationFactory(this);}else{ConstructorInfo constructor &＃61; cache.GetOrAdd(serviceType, i &＃61;> {var d &＃61; defintion as TypeServiceDefintion;var implementationType &＃61; serviceType.IsConstructedGenericType ? d.ImplementationType.MakeGenericType(serviceType.GenericTypeArguments): d.ImplementationType;return implementationType.GetConstructors().FirstOrDefault(i &＃61;> i.IsPublic);});ar ps &＃61; constructor.GetParameters();var args &＃61; new object[ps.Length];for (int j &＃61; 0; j

小白同学&＃xff1a;好了&＃xff0c;我们来说下 Scoped 作用域&＃xff0c;百度百科的解释是这样的: 作用域&＃xff08;scope&＃xff09;&＃xff0c;程序设计概念&＃xff0c;通常来说&＃xff0c;一段程序代码中所用到的名字并不总是有效/可用的&＃xff0c;而限定这个名字的可用性的代码范围就是这个名字的作用域。
作用域的使用提高了程序逻辑的局部性&＃xff0c;增强程序的可靠性&＃xff0c;减少名字冲突。
对于对象而言&＃xff08;其他也是一样的&＃xff09;&＃xff0c;在main函数中&＃xff0c;对象的作用域为他所在的最近的一对花括号内。在后花括号处析构函数被调用&＃xff1b;全局的对象的作用域为声明之后的整个文件&＃xff0c;析构函数在最后被调用。另外&＃xff0c;临时产生的对象在使用完后立即会被析构。

小白同学&＃xff1a;虽然比较奇怪为啥百度百科强调的是名字&＃xff0c;名字不过是我们方便自己对应以及找到变量/内存地址等的手段而已。不过不管啦&＃xff0c;反正DI里面的Scoped概念和这段解释有点点相似&＃xff0c;是为DI提供将对象生命周期控制在自定义的范围内部的一个手段&＃xff0c;比如我们保证http 一次请求的生命周期内&＃xff0c;一些比如context之类的处理&＃xff0c;我们就可以用这样的作用域概念处理&＃xff0c;

小白同学&＃xff1a;作用域由于考虑到不是我们自己控制&＃xff0c;这是有使用者自定的&＃xff0c;所以我们需要提供一些抽象接口让用户可以使用。这里呢&＃xff0c;我们就偷懒啦&＃xff0c;抄袭一下别人的定义

public interface IServiceScopeFactory
{IServiceProvider CreateScopeProvider();
}

小白同学&＃xff1a;我们来实现它

public class ServiceScopeFactory : IServiceScopeFactory
{public IServiceProvider CreateScopeProvider(){return new ServiceProvider();}
}

小白同学&＃xff1a;大家看&＃xff0c;多简单&＃xff0c;完美

大神&＃xff1a;你问过我的青龙偃月刀了吗&＃xff1f;

小白同学&＃xff08;尴尬&＃xff09;&＃xff1a; 哈哈&＃xff0c;怎么可能写完了&＃xff0c;我是开个玩笑&＃xff0c;肯定要把服务定义给过去

public class ServiceScopeFactory : IServiceScopeFactory
{private readonly IServiceDefintions services;public ServiceScopeFactory(IServiceDefintions services){this.services &＃61; services;}public IServiceProvider CreateScopeProvider(){return new ServiceProvider(services);}
}

青龙偃月刀&＃xff1a;你希望你的生命周期也和这个ServiceScopeFactory一样无处安放吗&＃xff1f;

小白同学&＃xff1a;为啥&＃xff1f;我这不是实现了吗&＃xff1f;

青龙偃月刀&＃xff1a;ServiceScopeFactory 用户从哪里拿&＃xff1f;

小白同学&＃xff1a;我放进ServiceDefintions呀&＃xff0c;

var a &＃61; new ServiceDefintions();
a.Add(new DelegateServiceDefintion(typeof(IServiceScopeFactory),typeof(ServiceScopeFactory),Lifetime.Transient, i &＃61;> new ServiceScopeFactory(a)));

青龙偃月刀&＃xff1a;hehe, ServiceProvider 由 IServiceScopeFactory 创建的都是新的吧?

小白同学&＃xff1a;对&＃xff0c;就是这样&＃xff0c;才能保证是新的作用域呀

青龙偃月刀&＃xff1a;hehe, 那新的 ServiceProvider 创建的对象也是新的吧&＃xff1f;

小白同学&＃xff1a;对&＃xff0c;就是这样&＃xff0c;新的作用域创建的对象肯定和旧的作用域创建的对象肯定不一样

青龙偃月刀&＃xff1a;hehe, 那Singleton不是全局唯一吗?

小白同学&＃xff1a;啥&＃xff1f;Singleton和作用域有什么关系&＃xff1f;我不是有字典缓存了吗&＃xff1f;

青龙偃月刀&＃xff1a;我真恨不得自己再把自己磨快点。

青龙偃月刀&＃xff1a;ServiceProvider 是不是可以创建 三种不同生命周期的对象&＃xff1f;

小白同学&＃xff1a;对&＃xff0c;Singleton ,Scoped, Transient

青龙偃月刀&＃xff1a;那新的ServiceProvider创建的Singleton对象呢&＃xff1f;

小白同学&＃xff1a;都是从缓存字典private readonly ConcurrentDictionary singletonCache 里面拿呗

青龙偃月刀&＃xff1a;。。。。。。 这个字典你放哪呢&＃xff1f;

小白同学&＃xff1a;我放ServiceProvider类上啊

青龙偃月刀&＃xff1a;。。。。。。 那每一个新的ServiceProvider是不是都有一个新的缓存字典&＃xff1f;

小白同学&＃xff1a;吃惊.gif&＃xff0c; 不愧是宝刀

小白同学&＃xff1a;我换静态的 static ConcurrentDictionary singletonCache

青龙偃月刀&＃xff1a;那整个程序就只有一份了啊

小白同学&＃xff1a;对呀&＃xff0c;就是只要一份

青龙偃月刀&＃xff1a;那一个程序里面多个DI容器呢?

小白同学&＃xff1a;大吃一惊.gif&＃xff0c;还能这么玩?

青龙偃月刀&＃xff1a;不说其他&＃xff0c;就说你单元测试一个DI容器能测试各种场景&＃xff1f;

小白同学&＃xff1a;尴尬.gif 我目前只写了一个

青龙偃月刀&＃xff1a;...............你改吧

小白同学&＃xff1a;哦

// 小白同学&＃xff1a;在IServiceProvider接口上添加我们需要数据字段
public interface IServiceProvider
{Dictionary Services {get;}ConcurrentDictionary SingletonCache {get;}
}public class ServiceProvider : IServiceProvider
{public Dictionary Services {get;}public ConcurrentDictionary SingletonCache {get;}// 小白同学&＃xff1a;复用对应的缓存public ServiceProvider(IServiceProvider provider){Services &＃61; provider.Services;SingletonCache &＃61; provider.SingletonCache;}
}public class ServiceScopeFactory : IServiceScopeFactory
{private readonly IServiceProvider provider;// 小白同学&＃xff1a;这样我们可以直接取已有的providerpublic ServiceScopeFactory(IServiceProvider provider){this.provider &＃61; provider;}public IServiceProvider CreateScopeProvider(){// 小白同学&＃xff1a;有了存在的provider&＃xff0c;我们就能复用对应的缓存return new ServiceProvider(provider);}
}

小白同学&＃xff1a;我们就可以这样注册ServiceScopeFactory了

var a &＃61; new ServiceDefintions();
a.Add(new DelegateServiceDefintion(typeof(IServiceScopeFactory),typeof(ServiceScopeFactory),Lifetime.Transient, i &＃61;> new ServiceScopeFactory(i)));

青龙偃月刀&＃xff1a;磨刀石呢&＃xff1f;我要磨快点

小白同学&＃xff1a;又咋了&＃xff0c;我写的这么完美&＃xff1f;

青龙偃月刀&＃xff1a;你确定这样符合作用域的概念&＃xff1f;

小白同学&＃xff1a;怎么不符合了&＃xff1f;SingletonCache 都只有一个了&＃xff0c;每个ServiceProvider都是创建新的Scoped生命周期对象

青龙偃月刀&＃xff1a;你看看你是怎么写创建新的Scoped生命周期对象的&＃xff1f;

小白同学&＃xff1a;这样啊

case Lifetime.Scoped:return CreateObj(x);

青龙偃月刀&＃xff1a;一个Scoped生命周期内&＃xff0c;一个ServiceType对应生成对象不该唯一吗&＃xff1f;

小白同学&＃xff1a;为啥啊&＃xff1f;生命周期不是用户自己控制了吗&＃xff1f;

青龙偃月刀&＃xff1a;一个方法的作用域内&＃xff0c;可以声明多个同名对象吗&＃xff1f;

小白同学&＃xff1a;不能呀

青龙偃月刀&＃xff1a;那你允许一个Scoped作用域内&＃xff0c;可以生成相同ServiceType&＃xff0c;实际不同的对象&＃xff1f;

小白同学&＃xff1a;他可以自己回收呗

青龙偃月刀&＃xff1a;你让人家自己回收 &＃xff01;&＃xff01;&＃xff01;&＃xff1f;&＃xff1f;&＃xff1f; 那人家为什么不用Transient&＃xff0c;你这样和Transient有什么区别&＃xff1f;

小白同学&＃xff1a;你说的好有道理&＃xff0c;我竟无言以对

小白同学&＃xff1a;那我加缓存

public class ServiceProvider : IServiceProvider
{private ConcurrentDictionary scopedCache &＃61; new ConcurrentDictionary();public object CreateObj(Type serviceType){case Lifetime.Scoped:return scopedCache.GetOrAdd(serviceType, x &＃61;> CreateObj(x));}
}

小白同学&＃xff1a;怎么样&＃xff1f;完美吧&＃xff1f;

青龙偃月刀&＃xff1a;我劝你好好考虑一下&＃xff0c;我的大刀已经饥渴难耐

小白同学&＃xff1a;哪儿不完美&＃xff1f;明明很beautiful

青龙偃月刀&＃xff1a;再提示一下&＃xff0c;用户是不是会这样用&＃xff1f;

IServiceProvider a &＃61; IServiceScopeFactory.CreateScopeProvider();doSomethings(a);a.Dispose();

小白同学&＃xff1a;对呀&＃xff0c;可以完美应对呀

青龙偃月刀&＃xff1a;。。。。。。。。。你的Dispose做了什么&＃xff1f;

小白同学&＃xff1a;emmmm 什么。。。 都没做&＃xff1f;

青龙偃月刀&＃xff1a;那用户Dispose什么&＃xff1f;

小白同学&＃xff1a;emmmm。。。。。。

小白同学&＃xff1a;好吧&＃xff0c;既然有问题我们再改下

public class ServiceProvider : IServiceProvider
{private void Dispose(){// 小白同学&＃xff1a;Dispose every thingforeach (var item in SingletonCache.Union(scopedCache)){var disposable &＃61; item as IDisposable;disposable?.Dispose();}scopedCache.Clear();SingletonCache.Clear();}
}

青龙偃月刀&＃xff1a;........... 一个子作用域可以把SingletonCache Dispose 了&＃xff1f;难道活到98岁不好吗&＃xff1f;

小白同学&＃xff1a;啊。。。。。活到那么久很好啊。。。。哈&＃xff0c;我知道怎么改

public class ServiceProvider : IServiceProvider
{public IServiceProvider Root { get; }public ServiceProvider(IServiceProvider provider){Services &＃61; provider.Services;SingletonCache &＃61; provider.SingletonCache;Root &＃61; provider.Root;}private void Dispose(){// 小白同学&＃xff1a;only Root can Dispose every thing// others can onlu disposable scopedCachevar disposables &＃61; (Root &＃61;&＃61; this? SingletonCache.Union(scopedCache): scopedCache).Where(x &＃61;> x.Value !&＃61; this);foreach (var scoped in disposables){var disposable &＃61; scoped.Value as IDisposable;disposable?.Dispose();}scopedCache.Clear();if (Root &＃61;&＃61; this) SingletonCache.Clear();}
}

小白同学&＃xff1a;真完美&＃xff01;&＃xff01;&＃xff01;&＃xff01;&＃xff01;

青龙偃月刀&＃xff1a;呵呵&＃xff0c;这样也能算完美&＃xff1f;多少没做&＃xff0c;还有多少问题没搞&＃xff1f;你看人家做成这样子都算差的了 - https://github.com/fs7744/Norns