点击即玩的小游戏网站,wordpress 的客户,接口网站开发,中卫平面设计招聘前言今年4月份的时候#xff0c;和平台组的同事一起调研了一下Nacos#xff0c;也就在那个时候写了.net core版本的非官方版的SDK。虽然公司内部由于某些原因最后没有真正的用起来#xff0c;但很多人还是挺看好的。在和镇汐大大沟通后#xff0c;决定写一篇博客简单介绍一… 前言今年4月份的时候和平台组的同事一起调研了一下Nacos也就在那个时候写了.net core版本的非官方版的SDK。虽然公司内部由于某些原因最后没有真正的用起来但很多人还是挺看好的。在和镇汐大大沟通后决定写一篇博客简单介绍一下。下面这个图就是本文的重点了。Nacos的简介Nacos是一个易于构建云原生应用的动态服务发现、配置管理和服务管理平台它提供了一组简单易用的特性集帮助我们快速实现动态服务发现、服务配置、服务元数据及流量管理。它有下面的关键特性服务发现和服务健康监测动态配置服务动态 DNS 服务服务及其元数据管理...特性还是挺多的也有挺多值的挖掘的地方。有关Nacos的更多信息可以访问下面的地址https://nacos.io/zh-cn/https://github.com/nacos-grouphttps://github.com/alibaba/nacos下面就开始正题了第一步肯定是先把Nacos跑起来。启动Nacos由于是演示所以直接用docker启动了Standalone Mysql模式的。git clone --depth 1 https://github.com/nacos-group/nacos-docker.git
cd nacos-docker
docker-compose -f example/standalone-mysql.yaml up运行docker-compose后会先拉取几个镜像回来然后就看到下面的输出基本就是正常启动了。打开浏览器访问 http://localhost:8848/nacos 就可以看到Nacos控制台的登录界面了。初始的用户名和密码都是 nacos登录进来之后大概是这样的。可以看到运行起来的Nacos版本是1.1.3还有清晰可见的几个大菜单这些都是可以很方便我们去进行管理的。那我们就先来看一下Nacos的配置管理吧。配置管理在上面的特性大图中已经很明确的告诉了我们配置管理的几个重要功能。在配置中有几个比较重要的概念需要先了解一下。tenant 租户信息对应 Nacos 的命名空间字段。dataId 配置ID。group 配置分组。先添加下面这个nuget包然后看一下这个配置要怎么玩。dotnet add package nacos-sdk-csharp-unofficial还有必不可少的就是在Startup里面进行配置。public void ConfigureServices(IServiceCollection services)
{services.AddNacos(configure {configure.DefaultTimeOut 8;configure.ServerAddresses new System.Collections.Generic.Liststring { localhost:8848 };configure.Namespace ;configure.ListenInterval 1000;});services.AddMvc().SetCompatibilityVersion(CompatibilityVersion.Version_2_2);
}这个也算是比较常见的配置了就不多说了还可以通过配置文件来加载配置。这些配置里面其实最主要的就是Nacos的地址。先来看看最简单的获取配置信息。SDK中提供了一个名为INacosConfigClient的Client接口这个接口里面的所有内容都是操作配置相关的。[Route(api/[controller])]
[ApiController]
public class ConfigController : ControllerBase
{private readonly INacosConfigClient _configClient;public ConfigController(INacosConfigClient configClient){_configClient configClient;}[HttpGet()]public async Taskstring Get([FromQuery]string key){var res await _configClient.GetConfigAsync(new GetConfigRequest{DataId key,Group DEFAULT_GROUP,}) ;return string.IsNullOrWhiteSpace(res) ? Not Found : res;}
}上面获取配置的这个获取配置的方法大意就是 读取默认命名空间(public)下面的DEFAULT_GROUP这个配置分组下面的名为key的配置Id的值。如果我们输入的key在Nacos上面没有那个这个方法就会返回 Not Found给调用方如果有那就会返回具体的配置值。由于我们是刚运行起行什么都没有操作所以肯定是没有任何配置信息的。那我们就先添加一个看看效果如何。同样在上面的控制器中加入下面的发布配置的方法同样也是通过INacosConfigClient来添加配置。
[HttpGet(add)]
public async Taskstring Add([FromQuery]string key, [FromQuery]string value)
{var res await _configClient.PublishConfigAsync(new PublishConfigRequest{DataId key,Group DEFAULT_GROUP,Content value});return res.ToString();
}这个时候我们已经添加成功了。\回去控制台也可以看到刚才加的配置已经出来了。再一次访问获取配置信息的接口就已经可以拿到对应的配置内容了。下面通过控制台去修改一下配置的内容。点发布按钮的时候会有一个比较页面让我们对比前后修改了那些内容。这个时候我们通过INacosConfigClient去访问的话发现是获取不到我们刚才更新的内容的。这个是因为从Nacos读取配置成功后会写入配置信息到本地缓存中后面访问的话会优先去读缓存的内容。那么要怎么做到有人修改了配置内容后它能实时生效呢其实很简单只需要添加一下对配置的监听就可以了。这个得益于Nacos允许我们监听配置以便实时感知配置变更。如果配置变更则用获取配置接口获取配置的最新值动态刷新本地缓存。下面是一个简单的示例这里用的是BackgroundService来处理的。public class ListenConfigurationBgTask : BackgroundService
{private readonly ILogger _logger;private readonly INacosConfigClient _configClient;public ListenConfigurationBgTask(ILoggerFactory loggerFactory, INacosConfigClient configClient){_logger loggerFactory.CreateLoggerListenConfigurationBgTask();_configClient configClient;}protected override async Task ExecuteAsync(CancellationToken stoppingToken){await _configClient.AddListenerAsync(new AddListenerRequest{DataId demo1,Callbacks new ListActionstring{x {_logger.LogInformation($ We found something changed!!! {DateTime.Now.ToString(yyyy-MM-dd HH:mm:ss.fff)} [{x}]);},}});}public override async Task StopAsync(CancellationToken cancellationToken){await _configClient.RemoveListenerAsync(new RemoveListenerRequest{DataId demo1,Callbacks new ListAction{() {_logger.LogInformation($ Removed listerner );},}});await base.StopAsync(cancellationToken);}
}这里其实没有什么内容就是在程序启动的时候添加一下监听然后在程序退出的时候同样也退出监听。不要忘记在Startup中加下面的代码这样配置的监听才会生效services.AddHostedServiceListenConfigurationBgTask();当我们添加监听之后修改了配置文件的内容它就可以动态的更新加载了。同样的控制台里面也有监听的记录可以在监听查询里面找到。下面是具体的程序日志输出配置的每一次修改都会有历史记录可以从历史版本里面找到。除了能看历史的记录还可以回滚到指定的版本这是个很有用的功能。在数据库中配置信息的保存是这样的还有一个删除配置的方法这里就不介绍了都是差不多的用法不过正常情况下是不应该删除配置的除非是多余的。关于Nacos配置管理的介绍就先到这里了有兴趣的朋友可以继续去深究。下面我们就来看看Nacos的服务发现。服务发现关于服务注册和发现听的比较多的大概就是consul, eureka, etcd , k8s 等等。思路其实都差不多在服务启动的时候把当前服务的相关信息注册上去然后要调用某个服务的时候就获取这个服务下面的列表然后选一个可用的进行访问。最后就是当服务停止的时候我们要注销当前的服务。目前这个SDK提供了两种形式一种是原始的API一种是对原始API进行了封装可以直接注册和发现相应的下游服务。原始的API在一个名为INacosNamingClient的Client接口中提供这个接口里面的所有内容都是服务发现相关的。不过在这里只介绍封装过后的使用方法当然也可以自己根据原始的API进行封装处理。首先要添加下面这个nuget包。dotnet add package nacos-sdk-csharp-unofficial.AspNetCore先起来一个服务。先在配置文件appsettings.json中添加下面的内容{nacos: {ServerAddresses: [ localhost:8848 ],DefaultTimeOut: 15,Namespace: ,ListenInterval: 1000,ServiceName: BaseService,Weight: 10}
}这个配置主要表达了这个实例的服务名是 BaseService 权重是10 Nacos的地址是 localhost:8848。然后在Startup中把当前实例注册到Nacos。namespace BaseService
{using Microsoft.AspNetCore.Builder;using Microsoft.AspNetCore.Hosting;using Microsoft.AspNetCore.Mvc;using Microsoft.Extensions.Configuration;using Microsoft.Extensions.DependencyInjection;using Nacos.AspNetCore;public class Startup{public Startup(IConfiguration configuration){Configuration configuration;}public IConfiguration Configuration { get; }public void ConfigureServices(IServiceCollection services){services.AddNacosAspNetCore(Configuration);services.AddMvc().SetCompatibilityVersion(CompatibilityVersion.Version_2_2);}public void Configure(IApplicationBuilder app, IHostingEnvironment env){if (env.IsDevelopment()){app.UseDeveloperExceptionPage();}app.UseMvc();app.UseNacosAspNetCore();}}
}这里只需要简单的配置这两个地方就可以完成服务的注册功能了下面就启动这个程序。可以看到在启动程序的时候当前实例就会向Nacos发送心跳心跳的里面包含了IP和端口等信息。回到控制台我们可以看到这个服务现在已经有一个实例了。再启动一个同服务名的实例这里只对接口返回的内容做了一下调整其他都是一样的这个时候点进服务的详情里面可以看到更加具体的信息。服务现在是已经注册上来了下面我们就再来一个服务去调用上面这个注册好的服务。Startup中的内容都是差不多的不同的是如果确定服务不被内部其它应用调用的话可以不注册到Nacos上面。public class Startup
{public Startup(IConfiguration configuration){Configuration configuration;}public IConfiguration Configuration { get; }public void ConfigureServices(IServiceCollection services){services.AddHttpClient();services.AddNacosAspNetCore(Configuration);services.AddMvc().SetCompatibilityVersion(CompatibilityVersion.Version_2_2);}public void Configure(IApplicationBuilder app, IHostingEnvironment env){if (env.IsDevelopment()){app.UseDeveloperExceptionPage();}app.UseMvc();}
}然后就是发现服务了。INacosServerManager里面提供了一个只根据服务名来获取健康的实例的地址信息。不足的地方就是忽略了命名空间和集群这些参数会考虑在后面的版本中加上吧。这里获取到的地址信息是随机取出来的最简单的轮训算法。。获取到一次所有的实例地址信息后会缓存10秒钟这10秒钟里面就会直接从缓存中的地址信息取一个。[Route(api/[controller])]
[ApiController]
public class ValuesController : ControllerBase
{private readonly INacosServerManager _serverManager;private readonly IHttpClientFactory _clientFactory;public ValuesController(INacosServerManager serverManager, IHttpClientFactory clientFactory){_serverManager serverManager;_clientFactory clientFactory;}[HttpGet]public async Taskstring GetAsync(){var result await GetResultAsync();if (string.IsNullOrWhiteSpace(result)){result ERROR!!!;}return result;}private async Taskstring GetResultAsync(){var baseUrl await _serverManager.GetServerAsync(BaseService);if (string.IsNullOrWhiteSpace(baseUrl)){return ;}var url ${baseUrl}/api/values;var client _clientFactory.CreateClient();var result await client.GetAsync(url);return await result.Content.ReadAsStringAsync();}
}效果就来看动图了。在两个实例的健康状态都是true的时候会随机调用一个实例。当把其中一个实例停掉的时候这个实例的健康状态就会被标识为false这个时候就不会调用到这个false的实例。当把这个实例重新运行之后又恢复到随机调用的情况。Nacos的服务发现除了上面介绍的还有系统开关数据指标集群信息等功能有待去深入挖掘。写在最后Nacos使用起来不算复杂算是比较容易上手的用的公司也挺多的了。还有个把 steeltoe 和Nacos结合起来的项目 skynet-cloudhttps://github.com/magicsgxie/skynet-cloud 也可以看看。文中的示例代码可以戳这里 NacosDemo https://github.com/catcherwong-archive/2019/tree/master/09/NacosDemoSDK的地址 nacos-sdk-csharphttps://github.com/catcherwong/nacos-sdk-csharp希望感兴趣的大佬给个星星也十分希望有大佬来一起维护这个项目和提些建议。因为是第一次写SDK类的东西参考了其他平台提供.NET的SDK然后结合Nacos的Open API写的有可能会有不少遗漏和bug还请各位大佬多多包涵。
