.Net Core 中選項(xiàng)Options的具體實(shí)現(xiàn)
.NetCore的配置選項(xiàng)建議結(jié)合在一起學(xué)習(xí),不了解.NetCore 配置Configuration的同學(xué)可以看下我的上一篇文章 [.Net Core配置Configuration具體實(shí)現(xiàn)]
由代碼開始
定義一個(gè)用戶配置選項(xiàng)
public class UserOptions
{
private string instanceId;
private static int index = 0;
public UserOptions()
{
instanceId = (++index).ToString("00");
Console.WriteLine($"Create UserOptions Instance:{instanceId}");
}
public string Name { get; set; }
public int Age { get; set; }
public override string ToString() => $"Name:{Name} Age:{Age} Instance:{instanceId} ";
}
public class UserOptions2
{
public string Name { get; set; }
public int Age { get; set; }
public override string ToString() => $" Name:{Name} Age:{Age}";
}
定義json配置文件:myconfig.json
{
"UserOption": {
"Name": "ConfigName-zhangsan",
"Age": 666
}
}
創(chuàng)建ServiceCollection
services = new ServiceCollection();
var configBuilder = new ConfigurationBuilder().AddInMemoryCollection().AddJsonFile("myconfig.json", true, true);
var iconfiguration = configBuilder.Build();
services.AddSingleton<IConfiguration>(iconfiguration);
示例代碼
services.Configure<UserOptions>(x => { x.Name = "張三"; x.Age = new Random().Next(1, 10000); });
services.AddOptions<UserOptions2>().Configure<IConfiguration>((x, config) => { x.Name = config["UserOption:Name"]; x.Age = 100; }); ;
services.PostConfigure<UserOptions>(x => { x.Name = x.Name + "Post"; x.Age = x.Age; });
services.Configure<UserOptions>("default", x => { x.Name = "Default-張三"; x.Age = new Random().Next(1, 10000); });
services.Configure<UserOptions>("config", configuration.GetSection("UserOption"));
using (var provider = services.BuildServiceProvider())
{
using (var scope1 = provider.CreateScope())
{
PrintOptions(scope1, "Scope1");
}
//修改配置文件
Console.WriteLine(string.Empty);
Console.WriteLine("修改配置文件");
var filePath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "myconfig.json");
File.WriteAllText(filePath, "{\"UserOption\": { \"Name\": \"ConfigName-lisi\", \"Age\": 777}}");
//配置文件的change回調(diào)事件需要一定時(shí)間執(zhí)行
Thread.Sleep(300);
Console.WriteLine(string.Empty);
using (var scope2 = provider.CreateScope())
{
PrintOptions(scope2, "Scope2");
}
Console.WriteLine(string.Empty);
using (var scope3 = provider.CreateScope())
{
PrintOptions(scope3, "Scope3");
}
}
static void PrintOptions(IServiceScope scope, string scopeName)
{
var options1 = scope.ServiceProvider.GetService<IOptions<UserOptions>>();
Console.WriteLine($"手動(dòng)注入讀取,IOptions,{scopeName}-----{ options1.Value}");
var options2 = scope.ServiceProvider.GetService<IOptionsSnapshot<UserOptions>>();
Console.WriteLine($"配置文件讀取,IOptionsSnapshot,{scopeName}-----{ options2.Value}");
var options3 = scope.ServiceProvider.GetService<IOptionsSnapshot<UserOptions>>();
Console.WriteLine($"配置文件根據(jù)名稱讀取,IOptionsSnapshot,{scopeName}-----{ options3.Get("config")}");
var options4 = scope.ServiceProvider.GetService<IOptionsMonitor<UserOptions>>();
Console.WriteLine($"配置文件讀取,IOptionsMonitor,{scopeName}-----{ options4.CurrentValue}");
var options5 = scope.ServiceProvider.GetService<IOptionsMonitor<UserOptions>>();
Console.WriteLine($"配置文件根據(jù)名稱讀取,IOptionsMonitor,{scopeName}-----{options5.Get("config")}");
var options6 = scope.ServiceProvider.GetService<IOptions<UserOptions2>>();
Console.WriteLine($"Options2-----{options6.Value}");
}
代碼運(yùn)行結(jié)果
Create UserOptions Instance:01
手動(dòng)注入讀取,IOptions,Scope1----- Name:張三Post Age:6575 Instance:01
Create UserOptions Instance:02
配置文件讀取,IOptionsSnapshot,Scope1----- Name:張三Post Age:835 Instance:02
Create UserOptions Instance:03
配置文件根據(jù)名稱讀取,IOptionsSnapshot,Scope1----- Name:ConfigName-zhangsan Age:666 Instance:03
Create UserOptions Instance:04
配置文件讀取,IOptionsMonitor,Scope1----- Name:張三Post Age:1669 Instance:04
Create UserOptions Instance:05
配置文件根據(jù)名稱讀取,IOptionsMonitor,Scope1----- Name:ConfigName-zhangsan Age:666 Instance:05
Options2----- Name:ConfigName-zhangsan Age:100修改配置文件
Create UserOptions Instance:06手動(dòng)注入讀取,IOptions,Scope2----- Name:張三Post Age:6575 Instance:01
Create UserOptions Instance:07
配置文件讀取,IOptionsSnapshot,Scope2----- Name:張三Post Age:5460 Instance:07
Create UserOptions Instance:08
配置文件根據(jù)名稱讀取,IOptionsSnapshot,Scope2----- Name:ConfigName-lisi Age:777 Instance:08
配置文件讀取,IOptionsMonitor,Scope2----- Name:張三Post Age:1669 Instance:04
配置文件根據(jù)名稱讀取,IOptionsMonitor,Scope2----- Name:ConfigName-lisi Age:777 Instance:06
Options2----- Name:ConfigName-zhangsan Age:100手動(dòng)注入讀取,IOptions,Scope3----- Name:張三Post Age:6575 Instance:01
Create UserOptions Instance:09
配置文件讀取,IOptionsSnapshot,Scope3----- Name:張三Post Age:5038 Instance:09
Create UserOptions Instance:10
配置文件根據(jù)名稱讀取,IOptionsSnapshot,Scope3----- Name:ConfigName-lisi Age:777 Instance:10
配置文件讀取,IOptionsMonitor,Scope3----- Name:張三Post Age:1669 Instance:04
配置文件根據(jù)名稱讀取,IOptionsMonitor,Scope3----- Name:ConfigName-lisi Age:777 Instance:06
Options2----- Name:ConfigName-zhangsan Age:100
通過(guò)運(yùn)行代碼得到的結(jié)論
- Options可通過(guò)手動(dòng)初始化配置項(xiàng)配置(可在配置時(shí)讀取依賴注入的對(duì)象)、或通過(guò)IConfiguration綁定配置
- PostConfiger可在Configer基礎(chǔ)上繼續(xù)配置
- 可通過(guò)IOptionsSnapshot或IOptionsMonitor根據(jù)配置名稱讀取配置項(xiàng),未指定名稱讀取第一個(gè)注入的配置
- IOptions和IOptionsMonitor生命周期為Singleton,IOptionsSnapshot生命周期為Scope
- IOptionsMonitor可監(jiān)聽到配置文件變動(dòng)去動(dòng)態(tài)更新配置項(xiàng)
問(wèn)題
- IOptions,IOptionsSnapshot,IOptionsMonitor 如何/何時(shí)注入、初始化
- Options指定名稱時(shí)內(nèi)部是如何設(shè)置的
- Options如何綁定的IConfiguration
- IOptionsMonitor是如何同步配置文件變動(dòng)的
配合源碼解決疑惑
Configure注入
public static IServiceCollection Configure<TOptions>(this IServiceCollection services, Action<TOptions> configureOptions) where TOptions : class
{
return services.Configure(Microsoft.Extensions.Options.Options.DefaultName, configureOptions);
}
public static IServiceCollection Configure<TOptions>(this IServiceCollection services, string name, Action<TOptions> configureOptions) where TOptions : class
{
services.AddOptions();
services.AddSingleton((IConfigureOptions<TOptions>)new ConfigureNamedOptions<TOptions>(name, configureOptions));
return services;
}
public static IServiceCollection AddOptions(this IServiceCollection services)
{
services.TryAdd(ServiceDescriptor.Singleton(typeof(IOptions<>), typeof(OptionsManager<>)));
services.TryAdd(ServiceDescriptor.Scoped(typeof(IOptionsSnapshot<>), typeof(OptionsManager<>)));
services.TryAdd(ServiceDescriptor.Singleton(typeof(IOptionsMonitor<>), typeof(OptionsMonitor<>)));
services.TryAdd(ServiceDescriptor.Transient(typeof(IOptionsFactory<>), typeof(OptionsFactory<>)));
services.TryAdd(ServiceDescriptor.Singleton(typeof(IOptionsMonitorCache<>), typeof(OptionsCache<>)));
return services;
}
通過(guò)上面的源碼可以發(fā)現(xiàn),Options相關(guān)類是在AddOptions中注入的,具體的配置項(xiàng)在Configure中注入。
如果不指定Configure的Name,也會(huì)有個(gè)默認(rèn)的Name=Microsoft.Extensions.Options.Options.DefaultName
那么我們具體的配置項(xiàng)存到哪里去了呢,在ConfigureNamedOptions這個(gè)類中,在Configer函數(shù)調(diào)用時(shí),只是把相關(guān)的配置委托存了起來(lái):
public ConfigureNamedOptions(string name, Action<TOptions> action)
{
Name = name;
Action = action;
}
OptionsManager
private readonly ConcurrentDictionary<string, Lazy<TOptions>> _cache = new ConcurrentDictionary<string, Lazy<TOptions>>(StringComparer.Ordinal);
public TOptions Value => Get(Options.DefaultName);
public virtual TOptions Get(string name)
{
name = name ?? Options.DefaultName;
return _cache.GetOrAdd(name, () => _factory.Create(name));
}
OptionsManager實(shí)現(xiàn)相對(duì)較簡(jiǎn)單,在查詢時(shí)需要執(zhí)行Name,如果為空就用默認(rèn)的Name,如果緩存沒(méi)有,就用Factory創(chuàng)建一個(gè),否則就讀緩存中的選項(xiàng)。
IOptions和IOptionsSnapshot的實(shí)現(xiàn)類都是OptionsManager,只是生命周期不同。
OptionsFactory
那么OptionsFactory又是如何創(chuàng)建Options的呢?我們看一下他的構(gòu)造函數(shù),構(gòu)造函數(shù)將所有Configure和PostConfigure的初始化委托都通過(guò)構(gòu)造函數(shù)保存在內(nèi)部變量中
public OptionsFactory(IEnumerable<IConfigureOptions<TOptions>> setups, IEnumerable<IPostConfigureOptions<TOptions>> postConfigures)
{
_setups = setups;
_postConfigures = postConfigures;
}
接下來(lái)看Create(有刪改,與本次研究無(wú)關(guān)的代碼沒(méi)有貼出來(lái)):
public TOptions Create(string name)
{
//首先創(chuàng)建對(duì)應(yīng)Options的實(shí)例
TOptions val = Activator.CreateInstance<TOptions>();
//循環(huán)所有的配置項(xiàng),依次執(zhí)行,如果對(duì)同一個(gè)Options配置了多次,最后一次的賦值生效
foreach (IConfigureOptions<TOptions> setup in _setups)
{
var configureNamedOptions = setup as IConfigureNamedOptions<TOptions>;
if (configureNamedOptions != null)
{
//Configure中會(huì)判斷傳入Name的值與本身的Name值是否相同,不同則不執(zhí)行Action
//這解釋了我們一開始的示例中,注入了三個(gè)UserOptions,但是在IOptionsSnapshot.Value中獲取到的是第一個(gè)沒(méi)有名字的
//因?yàn)閂alue會(huì)調(diào)用OptionsManager.Get(Options.DefaultName),進(jìn)而調(diào)用Factory的Create(Options.DefaultName)
configureNamedOptions.Configure(name, val);
}
else if (name == Options.DefaultName)
{
setup.Configure(val);
}
}
//PostConfigure沒(méi)啥可多說(shuō)了,名字判斷邏輯與Configure一樣
foreach (var postConfigure in _postConfigures)
{
postConfigure.PostConfigure(name, val);
}
return val;
}
NamedConfigureFromConfigurationOptions
IConfiguration配置Options的方式略有不同
對(duì)應(yīng)Configure擴(kuò)展方法最終調(diào)用的代碼在Microsoft.Extensions.DependencyInjection.OptionsConfigurationServiceCollectionExtensions這個(gè)類中
public static IServiceCollection Configure<TOptions>(this IServiceCollection services, string name, IConfiguration config, Action<BinderOptions> configureBinder) where TOptions : class
{
services.AddOptions();
services.AddSingleton((IOptionsChangeTokenSource<TOptions>)new ConfigurationChangeTokenSource<TOptions>(name, config));
return services.AddSingleton((IConfigureOptions<TOptions>)new NamedConfigureFromConfigurationOptions<TOptions>(name, config, configureBinder));
}
擴(kuò)展方法里又注入了一個(gè)IOptionsChangeTokenSource,這個(gè)類的作用是提供一個(gè)配置文件變動(dòng)監(jiān)聽的Token
同時(shí)將IConfigureOptions實(shí)現(xiàn)類注冊(cè)成了NamedConfigureFromConfigurationOptions
NamedConfigureFromConfigurationOptions繼承了ConfigureNamedOptions,在構(gòu)造函數(shù)中用IConfiguration.Bind實(shí)現(xiàn)了生成Options的委托
public NamedConfigureFromConfigurationOptions(string name, IConfiguration config, Action<BinderOptions> configureBinder)
: base(name, (Action<TOptions>)delegate(TOptions options)
{
config.Bind(options, configureBinder);
})
所以在Factory的Create函數(shù)中,會(huì)調(diào)用IConfiguration的Bind函數(shù)
由于IOptionsSnapshot生命周期是Scope,在配置文件變動(dòng)后新的Scope中會(huì)獲取最新的Options
ValidateOptions
OptionsBuilder還包含了一個(gè)Validate函數(shù),該函數(shù)要求傳入一個(gè)Func<TOptions,bool>的委托,會(huì)注入一個(gè)單例的ValidateOptions對(duì)象。
在OptionsFactory構(gòu)建Options的時(shí)候會(huì)驗(yàn)證Options的有效性,驗(yàn)證失敗會(huì)拋出OptionsValidationException異常
對(duì)于ValidateOptions和PostConfigureOptions都是構(gòu)建Options實(shí)例時(shí)需要用到的主要模塊,不過(guò)使用和內(nèi)部實(shí)現(xiàn)都較為簡(jiǎn)單,應(yīng)用場(chǎng)景也不是很多,本文就不對(duì)這兩個(gè)類多做介紹了
結(jié)論
在Configure擴(kuò)展函數(shù)中會(huì)首先調(diào)用AddOptions函數(shù)
IOptions,IOptionsSnapshot,IOptionsMonitor都是在AddOptions函數(shù)中注入的
Configure配置的選項(xiàng)配置委托最終會(huì)保存到ConfigureNamedOptions或NamedConfigureFromConfigurationOptions
IOptions和IOptionsSnapshot的實(shí)現(xiàn)類為OptionsManager
OptionsManager通過(guò)OptionsFactory創(chuàng)建Options的實(shí)例,并會(huì)以Name作為鍵存到字典中緩存實(shí)例
OptionsFactory會(huì)通過(guò)反射創(chuàng)建Options的實(shí)例,并調(diào)用ConfigureNamedOptions中的委托給實(shí)例賦值
現(xiàn)在只剩下最后一個(gè)問(wèn)題了,OptionsMonitor是如何動(dòng)態(tài)更新選項(xiàng)的呢?
其實(shí)前面的講解中已經(jīng)提到了一個(gè)關(guān)鍵的接口IOptionsChangeTokenSource,這個(gè)接口提供一個(gè)IChangeToken,通過(guò)ChangeToken監(jiān)聽這個(gè)Token就可以監(jiān)聽到文件的變動(dòng),我們來(lái)看下OptionsMonitor是否是這樣做的吧!
//構(gòu)造函數(shù)
public OptionsMonitor(IOptionsFactory<TOptions> factory, IEnumerable<IOptionsChangeTokenSource<TOptions>> sources, IOptionsMonitorCache<TOptions> cache)
{
_factory = factory;
_sources = sources;
_cache = cache;
//循環(huán)屬于TOptions的所有IChangeToken
foreach (IOptionsChangeTokenSource<TOptions> source in _sources)
{
ChangeToken.OnChange(() => source.GetChangeToken(), delegate(string name)
{
//清除緩存
name = name ?? Options.DefaultName;
_cache.TryRemove(name);
}, source.Name);
}
}
public virtual TOptions Get(string name)
{
name = name ?? Options.DefaultName;
return _cache.GetOrAdd(name, () => _factory.Create(name));
}
果然是這樣的吧!
到此這篇關(guān)于.Net Core 中選項(xiàng)Options的具體實(shí)現(xiàn)的文章就介紹到這了,更多相關(guān).Net Core Options內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
一個(gè)ASP.Net下的WebShell實(shí)例
一個(gè)ASP.Net下的WebShell,主要完成cmd命令。一般的服務(wù)器設(shè)置,asp.net用戶的權(quán)限都比較高。如果asp的webshell無(wú)法執(zhí)行,可能asp.net的可以執(zhí)行。2013-07-07
.net core在服務(wù)器端獲取api傳遞的參數(shù)過(guò)程
這篇文章主要介紹了.net core在服務(wù)器端獲取api傳遞的參數(shù)過(guò)程,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-10-10
asp.net實(shí)現(xiàn)在線音樂(lè)播放器示例
這篇文章主要介紹了asp.net實(shí)現(xiàn)在線音樂(lè)播放器示例,需要的朋友可以參考下2014-02-02
ASP.NET中基于soaphead的webservice安全機(jī)制
常會(huì)用到WebService來(lái)通訊,但WebService發(fā)布后為了能調(diào)用,一般都通過(guò)發(fā)布到IIS后調(diào)用 的。在IIS里可以通過(guò)匿名訪問(wèn),但這樣大家都可能訪問(wèn),不安全,下面提供一種基于soaphead的安全機(jī)制。2016-05-05
asp.net 實(shí)現(xiàn)防迅雷等下載工具盜鏈
利用IHttpHandler接口來(lái)監(jiān)聽對(duì)本網(wǎng)站的資源請(qǐng)求后綴名是否是我們要阻止的文件,如果是再判斷是否有下載權(quán)限。沒(méi)有就給它返回一個(gè)默認(rèn)的無(wú)用的文件。2009-02-02
ASP.NET?Core基于滑動(dòng)窗口實(shí)現(xiàn)限流控制
這篇文章主要介紹了ASP.NET?Core基于滑動(dòng)窗口實(shí)現(xiàn)限流控制,?AspNetCoreRateLimit是目前ASP.NET?Core下最常用的限流解決方案,下面詳細(xì)內(nèi)容,需要的小伙伴可以參考一下2022-03-03

