📣读完这篇文章里你能收获到

• .NET Core快速接入Consul代码Demo
• 了解配置中心的概念

一、概念篇

1 什么是配置中心？

• 配置是用来动态修改程序执行的一种行为的机制

2 为什么要使用配置中心？

• 安全性：配置跟随源代码保存在代码库中，容易造成配置泄漏。
• 时效性：修改配置，需要重启服务才能生效。
• 局限性：无法支持动态调整：例如日志开关、功能开关。

3 配置中心选择对比

3.1 Apollo

• Java开发 ----- 运维成本比高
• Apollo分为MySQL，Config Service，Admin Service，Portal四个模块，MySQL存储Apollo元数据和用户配置数据; Config Service提供配置的读取、推送等功能，客户端请求都是落到Config Service上; Admin Service提供配置的修改、发布等功能，Portal操作的服务就是Admin Service; Portal提供给用户配置管理界面;功能强大，社区活跃，但较为复杂，部署组件较多，运维成本比高

3.2 Consul

• go开发
• 依赖：不依赖其他组件
• 应用内/外：属于外部应用，侵入性小
• ACP原则：遵循CP原则（一致性+分离容忍） 服务注册稍慢，由于其一致性导致了在Leader挂掉时重新选举期间真个consul不可用。
• 版本迭代：目前仍然进行版本迭代
• 集成支持：支持SpringCloud K8S集成
• 访问协议：HTTP/DNS
• 雪崩保护：不支持雪崩保护
• 自动注销实例：不支持

3.3 Nacos

• 依赖：mysql
• 应用内/外：属于外部应用，侵入性小
• ACP原则：通知遵循CP原则（一致性+分离容忍） 和AP原则（可用性+分离容忍）
• 版本迭代：目前仍然进行版本迭代，最近的提交是几天前
• 集成支持：支持Dubbo 、SpringCloud、K8S集成
• 访问协议：HTTP/动态DNS/UDP
• 雪崩保护：支持雪崩保护
• Spring cloud config java开发 ----- Net支持比较差
• 自动注销实例：支持
• 界面：国产服务，中文界面，符合国人习惯
• 上手：极易，中文文档，案例，社区活跃

Consul实际上是和Nacos比较相似的产品，虽然Consul目前的主要发展方向放在了Service Mesh，但是Consul最初支持的服务发现和配置管理，也是Nacos的两大功能。虽然Nacos在Consul之后以与之相似的部署架构开源，但这并不意味着Nacos在功能和架构上也模仿Consul，Nacos的架构和功能是由阿里巴巴内部十年的运行演进经验得来，所以二者的比较也一定会让大家更加了解他们的定位和演进方向是完全不一样的。

二、.Net项目接入

1 Nuget包引用

• 在项目中Nuget下载Winton.Extensions.Configuration.Consul

2 配置文件中配置Consul地址

"Consul_Url": "http://127.0.0.1:8500",

        

          
        
        
        

          

          AI 代码解读
        
      
      

3 Program文件修改

public static IHostBuilder CreateHostBuilder(string[] args) =>
            Host.CreateDefaultBuilder(args)
                .ConfigureWebHostDefaults(webBuilder =>
                {
                    webBuilder.UseStartup<Startup>();
                    webBuilder.ConfigureAppConfiguration((hostingContext, config) =>
                    {

                        // 加载默认配置信息到Configuration
                       hostingContext.Configuration = config.Build();
                        // 加载consul配置中心配置
                        string consul_url = hostingContext.Configuration["Consul_Url"];
                        Console.WriteLine($"consul_url:{consul_url}");
                        // 动态加载环境信息，主要在于动态获取服务名称和环境名称
                        var env = hostingContext.HostingEnvironment;
                        config.AddConsul(
                                     $"{env.ApplicationName}/appsettings.{env.EnvironmentName}.json",
                                    options =>
                                    {
                                        options.ConsulConfigurationOptions = cco => { cco.Address = new Uri(consul_url); }; // 1、consul地址
                                        options.Optional = true; // 2、配置选项
                                        options.ReloadOnChange = true; // 3、配置文件更新后重新加载
                                        options.OnLoadException = exceptionContext => { exceptionContext.Ignore = true; }; // 4、忽略异常
                                    }
                                    );
                            config.AddConsul(
                                     $"{env.ApplicationName}/other.json",
                                    options =>
                                    {
                                        options.ConsulConfigurationOptions = cco => { cco.Address = new Uri(consul_url); }; // 1、consul地址
                                        options.Optional = true; // 2、配置选项
                                        options.ReloadOnChange = true; // 3、配置文件更新后重新加载
                                        options.OnLoadException = exceptionContext => { exceptionContext.Ignore = true; }; // 4、忽略异常
                                    }
                                    );
                        
                            hostingContext.Configuration = config.Build(); // 5、consul中加载的配置信息加载到Configuration对象，然后通过Configuration 对象加载项目中
                    });
                });

        

          
        
        
        

          

          AI 代码解读
        
      
      

4 动态加载配置信息

app.UseEndpoints(endpoints =>
            {
                endpoints.MapGet("/", async context =>
                {
                    await context.Response.WriteAsync(Configuration["Name"]);
                });
            });    

        

          
        
        
        

          

          AI 代码解读