溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
今天就跟大家聊聊有關怎么在.NET Core 3.0中創建一個Configuration擴展組件，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結了以下內容，希望大家根據這篇文章可以有所收獲。
開發前的準備初始化Consul
假設你已經安裝并啟動了Consul，我們打開Key/Value功能界面，創建兩組配置選項出來，分別是commonservice和userservice，如下圖所示
配置值采用JSON格式
實現思路
我們知道在Configuration整個的設計框架里，比較重要的類ConfigurationRoot，內部又有一個IConfigurationProvider集合屬性，也就是說我們追加IConfigurationProvider實例最終也會被放到到該集合中，如下圖所示
該項目中，我使用到了一個已經封裝好的Consul(V0.7.2.6)類庫，同時基于.NET Core關于Configuration的設計風格，做如下的框架設計
考慮到我會在該組件內部創建ConsulClient實例，所以對ConsulClient構造函數的一部分參數做了抽象提取，并添加到了IConsulConfigurationSource中，以增強該組件的靈活性。
之前說過，Consul中的配置信息是以JSON格式存儲的，所以此處使用到了Microsoft.Extensions.Configuration.Json.JsonConfigurationFileParser，用以將JSON格式的信息轉換為Configuration的通用格式Key/Value。
核心代碼 IConsulConfigurationSource
/// <summary>
/// ConsulConfigurationSource
/// </summary>
public interface IConsulConfigurationSource : IConfigurationSource
{
/// <summary>
/// CancellationToken
/// </summary>
CancellationToken CancellationToken { get; }
/// <summary>
/// Consul構造函數實例，可自定義傳入
/// </summary>
Action<ConsulClientConfiguration> ConsulClientConfiguration { get; set; }
/// <summary>
/// Consul構造函數實例，可自定義傳入
/// </summary>
Action<HttpClient> ConsulHttpClient { get; set; }
/// <summary>
/// Consul構造函數實例，可自定義傳入
/// </summary>
Action<HttpClientHandler> ConsulHttpClientHandler { get; set; }
/// <summary>
/// 服務名稱
/// </summary>
string ServiceKey { get; }
/// <summary>
/// 可選項
/// </summary>
bool Optional { get; set; }
/// <summary>
/// Consul查詢選項
/// </summary>
QueryOptions QueryOptions { get; set; }
/// <summary>
/// 重新加載延遲時間，單位是毫秒
/// </summary>
int ReloadDelay { get; set; }
/// <summary>
/// 是否在配置改變的時候重新加載
/// </summary>
bool ReloadOnChange { get; set; }
}ConsulConfigurationSource
該類提供了一個構造函數，用于接收ServiceKey和CancellationToken實例
public ConsulConfigurationSource(string serviceKey, CancellationToken cancellationToken)
{
if (string.IsNullOrWhiteSpace(serviceKey))
{
throw new ArgumentNullException(nameof(serviceKey));
}
this.ServiceKey = serviceKey;
this.CancellationToken = cancellationToken;
}其build()方法也比較簡單，主要是初始化ConsulConfigurationParser實例
public IConfigurationProvider Build(IConfigurationBuilder builder)
{
ConsulConfigurationParser consulParser = new ConsulConfigurationParser(this);
return new ConsulConfigurationProvider(this, consulParser);
}ConsulConfigurationParser
該類比較復雜，主要實現Consul配置的獲取、監控以及容錯處理，公共方法源碼如下
/// <summary>
/// 獲取并轉換Consul配置信息
/// </summary>
/// <param name="reloading"></param>
/// <param name="source"></param>
/// <returns></returns>
public async Task<IDictionary<string, string>> GetConfig(bool reloading, IConsulConfigurationSource source)
{
try
{
QueryResult<KVPair> kvPair = await this.GetKvPairs(source.ServiceKey, source.QueryOptions, source.CancellationToken).ConfigureAwait(false);
if ((kvPair?.Response == null) && !source.Optional)
{
if (!reloading)
{
throw new FormatException(Resources.Error_InvalidService(source.ServiceKey));
}
return new Dictionary<string, string>();
}
if (kvPair?.Response == null)
{
throw new FormatException(Resources.Error_ValueNotExist(source.ServiceKey));
}
this.UpdateLastIndex(kvPair);
return JsonConfigurationFileParser.Parse(source.ServiceKey, new MemoryStream(kvPair.Response.Value));
}
catch (Exception exception)
{
throw exception;
}
}
/// <summary>
/// Consul配置信息監控
/// </summary>
/// <param name="key"></param>
/// <param name="cancellationToken"></param>
/// <returns></returns>
public IChangeToken Watch(string key, CancellationToken cancellationToken)
{
Task.Run(() => this.RefreshForChanges(key, cancellationToken), cancellationToken);
return this.reloadToken;
}另外，關于Consul的監控主要利用了QueryResult.LastIndex屬性，該類緩存了該屬性的值，并與實獲取的值進行比較，以判斷是否需要重新加載內存中的緩存配置
ConsulConfigurationProvider
該類除了實現Load方法外，還會根據ReloadOnChange屬性，在構造函數中注冊OnChange事件，用于重新加載配置信息，源碼如下：
public sealed class ConsulConfigurationProvider : ConfigurationProvider
{
private readonly ConsulConfigurationParser configurationParser;
private readonly IConsulConfigurationSource source;
public ConsulConfigurationProvider(IConsulConfigurationSource source, ConsulConfigurationParser configurationParser)
{
this.configurationParser = configurationParser;
this.source = source;
if (source.ReloadOnChange)
{
ChangeToken.OnChange(
() => this.configurationParser.Watch(this.source.ServiceKey, this.source.CancellationToken),
async () =>
{
await this.configurationParser.GetConfig(true, source).ConfigureAwait(false);
Thread.Sleep(source.ReloadDelay);
this.OnReload();
});
}
}
public override void Load()
{
try
{
this.Data = this.configurationParser.GetConfig(false, this.source).ConfigureAwait(false).GetAwaiter().GetResult();
}
catch (AggregateException aggregateException)
{
throw aggregateException.InnerException;
}
}
}調用及運行結果
此處調用在Program中實現
public class Program
{
public static void Main(string[] args)
{
CancellationTokenSource cancellationTokenSource = new CancellationTokenSource();
WebHost.CreateDefaultBuilder(args).ConfigureAppConfiguration(
(hostingContext, builder) =>
{
builder.AddConsul("userservice", cancellationTokenSource.Token, source =>
{
source.ConsulClientConfiguration = cco => cco.Address = new Uri("http://localhost:8500");
source.Optional = true;
source.ReloadOnChange = true;
source.ReloadDelay = 300;
source.QueryOptions = new QueryOptions
{
WaitIndex = 0
};
});
builder.AddConsul("commonservice", cancellationTokenSource.Token, source =>
{
source.ConsulClientConfiguration = cco => cco.Address = new Uri("http://localhost:8500");
source.Optional = true;
source.ReloadOnChange = true;
source.ReloadDelay = 300;
source.QueryOptions = new QueryOptions
{
WaitIndex = 0
};
});
}).UseStartup<Startup>().Build().Run();
}
}看完上述內容，你們對怎么在.NET Core 3.0中創建一個Configuration擴展組件有進一步的了解嗎？如果還想了解更多知識或者相關內容，請關注億速云行業資訊頻道，感謝大家的支持。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
