[ASP.NET Core 3框架揭秘] 配置[5]:配置数据与数据源的实时同步

在《配置模型总体设计》介绍配置模型核心对象的时候,我们刻意回避了与配置同步相关的API,现在我们利用一个独立文章来专门讨论这个话题。配置的同步涉及到两个方面:第一,对原始的配置源施监控并在其发生变化之后重新加载配置;第二,配置重新加载之后及时通知应用程序进而使应用能够及时使用最新的配置。要了解配置同步机制的现原理,我们先得了解一下配置数据的流向。

一、配置数据

通过前面的介绍,我们已经对配置模型有了充分的了解,处于核心地位的 IConfigurationBuilder对象借助注册的IConfigurationSource对象提供的IConfigurationProvider对象从相应的配置源中加载数据,而各种针对IConfigurationProvider接口的实现就是为了将形态各异的原始配置数据转换成配置字典。我们在应用程序中使用的配置数据直接来源于IConfigurationBuilder对象创建的IConfiguration对象,那么当我们调用定义在IConfiguration对象上的API获取配置数据时,配置数据究竟具有怎样的流向呢?

我们在前面已经提到过,由ConfigurationBuilder(IConfigurationBuilder接口的默认实现)的Build方法提供的IConfiguration对象是一个ConfigurationRoot对象,它代表着整颗配置树,而组成这棵树的配置节则通过ConfigurationSection对象表示。这棵由ConfigurationRoo对象表示的配置树其实是无状态的,也就说不论是ConfigurationRoot对象还是ConfigurationSection对象,它们并没有利用某个字段存储任何的配置数据。

ConfigurationRoot对象保持着对所有注册IConfigurationSource提供的IConfigurationProvider对象的引用,当我们调用ConfigurationRoot或者ConfigurationSection相应的API提取配置数据时,最终都会直接从这些IConfigurationProvider中提取数据。换句话说,配置数据在整个模型中只以配置字典的形式存储在IConfigurationProvider对象上面。

6-15

应用程序在读取配置时产生的数据流基本体现在上图中。接下来我们从ConfigurationRoot和ConfigurationSection这两个类型的定义来对这个数据流,以及建立在此基础上的配置同步机制作进一步的介绍,不过在这之前我们得先来了解一个名为ConfigurationReloadToken的类型。

二、ConfigurationReloadToken

ConfigurationRoot和ConfigurationSection的GetReloadToken方法返回的IChangeToken对象类型都是ConfigurationReloadToken。不仅如此,对于组成同一棵配置树的所有节点对应的IConfiguration对象(ConfigurationRoot或者ConfigurationSection)来说,它们的GetReload
Token方法返回的其实是同一个ConfigurationReloadToken对象。

还有一点值得强调,IConfiguration接口的GetReloadToken方法返回的IChangeToken,其作用不是在配置源发生变化时向应用程序发送通知,它实际上是通知应用程序:配置源已经发生改变,并且新的数据已经被相应的IConfigurationProvider重新加载进来。由于Configuration
Root和ConfigurationSection对象都不维护任何数据,它们仅仅将我们的API调用转移到IConfigurationProvider对象上,所以应用程序使用原来的IConfiguration对象就可以获取到最新的配置数据。

ConfigurationReloadToken本质上是对一个CancellationTokenSource对象的封装。从如下的代码片段可以看出,ConfigurationReloadToken与CancellationChangeToken具有类似的定义和实现。两者唯一不同之处在于:CancellationChangeToken对象利用创建时提供的CancellationTokenSource对象对外发送通知,而ConfigurationReloadToken对象则通过调用OnReload方法利用内置的CancellationTokenSource对象发送通知。

public class ConfigurationReloadToken : IChangeToken { private CancellationTokenSource _cts = new CancellationTokenSource(); public IDisposable RegisterChangeCallback(Action<object> callback, object state) =>_cts.Token.Register(callback, state); public bool ActiveChangeCallbacks => True; public bool HasChanged =>_cts.IsCancellationRequested; public void OnReload() => _cts.Cancel(); }

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/zyyspg.html