Consul+Ocelot+Polly在.NetCore中使用(.NET5)-Consul服务注册，服务发现
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了Consul+Ocelot+Polly在.NetCore中使用(.NET5)-Consul服务注册，服务发现，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含6052字，纯文字阅读大概需要9分钟。
内容图文
环境 .NET5，Consul_v1.10.2
一、简介
在微服务中利用Consul可以实现服务的注册，服务发现，治理，健康检查等。
Web调站点需要调用多个服务，如果没有Consul，可能就是Web中存了全部服务的ip地址，如果其中一个服务更换了地址，web也要跟着修改配置，所以加入了Consul，web直接通过Consul就能一直取到各个服务的最新的地址了。
二、Consul搭建
这里使用Docker安装 ，确保安装了Docker，执行下面命令。
docker run -d -p 8500:8500 --restart=always --name=consul consul:latest agent -server -bootstrap -ui -node=1 -client=‘0.0.0.0‘
如果是windows环境，到官网https://www.consul.io 下载exe文件。然后cmd命令切换到consul.exe目录，执行consul.exe agent -dev 即可启动。
安装完，访问http:ip:8500，看到如下界面则安装成功。
三、服务注册
安装NuGet包 --Consul
appsettings.json增加Consul信息
{
"
Logging
"
: {
"
LogLevel
"
: {
"
Default
": "Information",
"Microsoft": "Warning",
"Microsoft.Hosting.Lifetime": "Information"
}
},
"AllowedHosts": "*",
"urls": "http://*:5200",
"Consul": {
"consulAddress": "http://172.16.2.84:8500",
"serviceName": "api",
"currentIp": "172.16.2.9",
"currentPort": "5200"
}
}
增加ConsulRegister.cs
///
<summary>
///
Consul注册
///
</summary>
public
static
class
ConsulRegister
{
//
服务注册
public
static IApplicationBuilder UseConsul(this IApplicationBuilder app, IConfiguration configuration)
{
// 获取主机生命周期管理接口var lifetime = app.ApplicationServices.GetRequiredService<IHostApplicationLifetime>();
ConsulClient client = new ConsulClient(c =>
{
c.Address = new Uri(configuration["Consul:consulAddress"]);
c.Datacenter = "dc1";
});
string ip = configuration["ip"];
string port = configuration["port"];
string currentIp = configuration["Consul:currentIP"];
string currentPort = configuration["Consul:currentPort"];
ip = string.IsNullOrEmpty(ip) ? currentIp : ip; //当前程序的IP
port = string.IsNullOrEmpty(port) ? currentPort : port; //当前程序的端口string serviceId = $"service:{ip}:{port}";//服务ID，一个服务是唯一的
//服务注册
client.Agent.ServiceRegister(new AgentServiceRegistration()
{
ID = serviceId, //唯一的
Name = configuration["Consul:serviceName"], //组名称-Group
Address = ip, //ip地址
Port = int.Parse(port), //端口
Tags = newstring[] { "api站点" },
Check = new AgentServiceCheck()
{
Interval = TimeSpan.FromSeconds(10),//多久检查一次心跳
HTTP = $"http://{ip}:{port}/Health/Index",
Timeout = TimeSpan.FromSeconds(5),//超时时间
DeregisterCriticalServiceAfter = TimeSpan.FromSeconds(5) //服务停止多久后注销服务 }
}).Wait();
//应用程序终止时,注销服务
lifetime.ApplicationStopping.Register(() =>
{
client.Agent.ServiceDeregister(serviceId).Wait();
});
return app;
}
}
在Startup.cs中 Configure(IApplicationBuilder app, IWebHostEnvironment env)方法后面加上 app.UseConsul(Configuration);
public
void
Configure(IApplicationBuilder app, IWebHostEnvironment env)
{
if
(env.IsDevelopment())
{
app.UseDeveloperExceptionPage();
}
else
{
app.UseExceptionHandler(
"
/Home/Error
"
);
//
The default HSTS value is 30 days. You may want to change this for production scenarios, see
https://aka.ms/aspnetcore-hsts.
app.UseHsts();
}
app.UseHttpsRedirection();
app.UseStaticFiles();
app.UseRouting();
app.UseAuthorization();
app.UseEndpoints(endpoints =>
{
endpoints.MapControllerRoute(
name: "default",
pattern: "{controller=Home}/{action=Index}/{id?}");
});
//Consul注册 app.UseConsul(Configuration);
}
增加健康检查接口
上面Consul注册处有一个Check Http的是心跳健康检查的地址，需要提供一个接口。
新建HealthController.cs
///
<summary>
///
consul健康检查
///
</summary>
public
class
HealthController : Controller
{
public
IActionResult Index()
{
return
Ok();
}
}
这样就配置好了，启动项目时就会把服务注册到Consul，我这里用发布文件同时启动三个做负载。
dotnet ConsulAndOcelot.Demo.ServerB.dll --urls="http://*5201" --ip="172.16.2.9" --port=5201 dotnet ConsulAndOcelot.Demo.ServerB.dll --urls="http://*5202" --ip="172.16.2.9" --port=5202 dotnet ConsulAndOcelot.Demo.ServerB.dll --urls="http://*5203" --ip="172.16.2.9" --port=5203
启动后，再看一下Consul界面，可以发现服务已成功注册到Consul。
四、服务发现
另外建一个.NetCore程序。
安装Nuget包 --Consul
appsettings.json 配置Consul信息
{
"
Logging
"
: {
"
LogLevel
"
: {
"
Default
": "Information",
"Microsoft": "Warning",
"Microsoft.Hosting.Lifetime": "Information"
}
},
"AllowedHosts": "*",
"Consul": {
"consulAddress": "http://172.16.2.84:8500",
"serviceName": "platform",
"apiServiceName": "api"
}
}
新建ConsulHelper.cs类
///
<summary>
///
Consul帮助类
///
</summary>
public
class
ConsulHelper
{
private
IConfiguration _configuration;
public
ConsulHelper(IConfiguration configuration)
{
_configuration = configuration;
}
///<summary>/// 根据服务名称获取服务地址
///</summary>///<param name="serviceName"></param>///<returns></returns>publicstring GetDomainByServiceName(string serviceName)
{
string domain = string.Empty;
//Consul客户端using (ConsulClient client = new ConsulClient(c =>
{
c.Address = new Uri(_configuration["Consul:consulAddress"]);
c.Datacenter = "dc1";
})
)
{
//根据服务名获取健康的服务var queryResult = client.Health.Service(serviceName, string.Empty, true);
var len = queryResult.Result.Response.Length;
//平均策略-多个负载中随机获取一个var node = queryResult.Result.Response[new Random().Next(len)];
domain = $"http://{node.Service.Address}:{node.Service.Port}";
}
return domain;
}
///<summary>/// 获取api域名
///</summary>///<returns></returns>publicstring GetApiDomain()
{
return GetDomainByServiceName(_configuration["Consul:apiServiceName"]);
}
}
把ConsulHelper注入到IOC容器，Startup.cs中。ConfigureServices(IServiceCollection services)方法加上
public
void
ConfigureServices(IServiceCollection services)
{
services.AddControllersWithViews();
services.AddTransient<ConsulHelper>();
}
验证
public
class
HomeController : Controller
{
private
readonly ILogger<HomeController> _logger;
privatereadonly ConsulHelper _consulHelper;
public HomeController(ILogger<HomeController> logger, ConsulHelper consulHelper)
{
_logger = logger;
_consulHelper = consulHelper;
}
public IActionResult Index()
{
///获取api服务地址var domain = _consulHelper.GetApiDomain();
ViewBag.domain = domain;
return View();
}
}
执行结果，通过Consul获得了服务地址，刷新后会随获取到三个负载中的一个。
Consul只负责服务发现，没有自带负载均衡策略。用上面的平均策略就可以了，如果想要做成轮询策略的也可以，不过会增加一些开销，可以给每组服务定义一个
静态自增变量index=0，然后获取的时候，index%服务数取余，然后index++,这样就是0%3=0，1%3=1，2%3=2，3%3=0一直循环，获取List[index]服务，index>10000的时候重置为0，这样就能循环的调用了。Conul后面配合Ocelot网关使用，Ocelot中会自带几种负载策略。
原文：https://www.cnblogs.com/wei325/p/15303859.html
内容总结
以上是互联网集市为您收集整理的Consul+Ocelot+Polly在.NetCore中使用(.NET5)-Consul服务注册，服务发现全部内容，希望文章能够帮你解决Consul+Ocelot+Polly在.NetCore中使用(.NET5)-Consul服务注册，服务发现所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。