目录1.服务注册与发现(Service Discovery)2.Consul3.ASP.net core向Consul注册服务实例4.项目演示4.1apiGateway项目4.2Co
如果要实现服务注册与发现,需要一个注册中心,这里主要介绍是Consul。
Consul官网:https://www.consul.io/,它主要功能有:服务注册与发现、健康检查、Key/Value、多数据中心。
如果在windows上部署Consul,在consul.exe目录下执行consul.exe agent -dev
命令行即可。
Asp.Net Core向Consul注册服务实例调用过程如下图所示:
asp.net Core向Consul注册服务实例需要在Gateway项目中引用Consul支持的NuGet软件包,安装命令如下:
Install-Package Ocelot.Provider.Consul
然后将以下内容添加到您的ConfigureServices方法中:
services.AddOcelot().AddConsul();
在Ocelot服务发现项目示例中,通过APIGateway项目GlobalConfiguration选项可以配置服务注册与发现,文件配置具体代码如下:
{
"Routes": [
{
"UseServiceDiscovery": true,
"DownstreamPathTemplate": "/{url}",
"DownstreamScheme": "Http",
"ServiceName": "MyService",
"LoadBalancerOptions": {
"Type": "RoundRobin"
},
"UpstreamPathTemplate": "/{url}",
"UpstreamHttpMethod": [ "Get" ],
"ReRoutesCaseSensitive": false
}
],
"GlobalConfiguration": {
//服务发现配置
"ServiceDiscoveryProvider": {
//注册中心Consul地址
"Host": "192.168.113.128",
//注册中心Consul端口号
"Port": 8500,
"Type": "Consul",
//以毫秒为单位,告诉Ocelot多久调用一次Consul来更改服务配置。
"PollingInterval": 100,
//如果你有在Consul上配置key/value,则在这里输入配置key。
"ConfigurationKey": "MyService_AB"
}
}
}
ServiceDiscoveryProvider选项说明:
ConfigureServices添加Ocelot、Consul注入:
services.AddOcelot().AddConsul();
Configure添加使用Ocelot:
app.UseOcelot().Wait();
服务发现配置如Ocelot服务发现项目示例一样。
先安装Consul的NuGet软件包,安装命令如下:
Install-Package Consul
在该项目添加一个AppExtensions扩展类,用来对服务APIServiceA、APIServiceB项目在Consul注册实例,为了展示效果,具体代码稍作修改如下:
public static class AppExtensions
{
public static IServiceCollection AddConsulConfig(this IServiceCollection services, IConfiguration configuration)
{
services.AddSingleton<IConsulClient, ConsulClient>(p => new ConsulClient(consulConfig =>
{
var address = configuration.GetValue<string>("Consul:Host");
consulConfig.Address = new Uri(address);
}));
return services;
}
public static IApplicationBuilder UseConsul(this IApplicationBuilder app, string host = null, string port = null)
{
//获取consul客户端实例
var consulClient = app.ApplicationServices.GetRequiredService<IConsulClient>();
var logger = app.ApplicationServices.GetRequiredService<ILoggerFactory>().CreateLogger("AppExtensions");
var lifetime = app.ApplicationServices.GetRequiredService<IApplicationLifetime>();
if (!(app.Properties["server.Features"] is FeatureCollection features)) return app;
//var addresses = features.Get<IServerAddressesFeature>();
//var address = addresses.Addresses.FirstOrDefault();
//if (address == null)
//{
// return app;
//}
var address = host + ":" + port;
if (string.IsNullOrWhiteSpace(host) || string.IsNullOrWhiteSpace(port))
{
Console.WriteLine($"host或者port为空!");
return app;
}
Console.WriteLine($"address={address}");
var uri = new Uri(address);
Console.WriteLine($"host={uri.Host},port={uri.Port}");
var reGIStration = new AgentServiceRegistration()
{
ID = $"MyService-{uri.Port}",
Name = "MyService",
Address = $"{uri.Host}",
Port = uri.Port,
Check = new AgentServiceCheck()
{
DeregisterCriticalServiceAfter = TimeSpan.FromSeconds(5),//服务启动多久后注册
Interval = TimeSpan.FromSeconds(10),//健康检查时间间隔
HTTP = $"{address}/HealthCheck",//健康检查地址
Timeout = TimeSpan.FromSeconds(5)//超时时间
}
};
logger.LogInfORMation("Registering with Consul");
logger.LogInformation($"Consul RegistrationID:{registration.ID}");
//注销
consulClient.Agent.ServiceDeregister(registration.ID).ConfigureAwait(true);
//注册
consulClient.Agent.ServiceRegister(registration).ConfigureAwait(true);
//应用程序关闭时候
lifetime.ApplicationStopping.Register(() =>
{
//正在注销
logger.LogInformation("Unregistering from Consul");
consulClient.Agent.ServiceDeregister(registration.ID).ConfigureAwait(true);
});
//每个服务都需要提供一个用于健康检查的接口,该接口不具备业务功能。服务注册时把这个接口的地址也告诉注册中心,注册中心会定时调用这个接口来检测服务是否正常,如果不正常,则将它移除,这样就保证了服务的可用性。
app.Map("/HealthCheck", s =>
{
s.Run(async context =>
{
await context.Response.WriteAsync("ok");
});
});
return app;
}
}
项目添加一个Get方法,对应APIGateway项目的路由上下游配置,具体代码如下:
[Route("api/[controller]")]
[ApiController]
public class ValuesController : ControllerBase
{
// GET api/values
[HttpGet]
public ActionResult<IEnumerable<string>> Get()
{
var port = Request.Host.Port;
return new string[] { "value1", "value2", port.Value.ToString() };
}
}
appsettings.JSON配置加入Consul地址:
"Consul": {
"Host": "http://192.168.113.128:8500"
}
项目添加一个Get方法,对应APIGateway项目的路由上下游配置,具体代码如下:
[Route("api/[controller]")]
[ApiController]
public class ValuesController : ControllerBase
{
// GET api/values
[HttpGet]
public ActionResult<IEnumerable<string>> Get()
{
var port = Request.Host.Port;
return new string[] { "value3", "value4", port.Value.ToString() };
}
}
appsettings.json配置加入Consul地址:
"Consul": {
"Host": "http://192.168.113.128:8500"
}
在APIServiceA、APIServiceB项目的ConfigureServices添加Consul配置:
services.AddConsulConfig(Configuration);
在Configure添加Consul服务注册:
APIServiceA:app.UseConsul("http://172.168.18.73", "9999");
APIServiceB:app.UseConsul("http://172.168.18.73", "9998");
把APIGateway、APIServiceA、APIServiceB三个项目部署到IIS上:
三个项目运行起来后,通过浏览器Consul客户端可以看到MyService节点服务情况:
点击打开MyService节点可以看到注册到Consul的APIServiceA、APIServiceB服务状况:
如果把APIServiceB服务实例站点停掉:
通过Consul客户端会看到APIServiceB服务实例已经被剔除了:
如果输入CTRL+C把集群中某一个Consul服务关闭,那么集群会重新选举一个新的leader,负责处理所有服务实例的查询和事务:
到此这篇关于Asp.net Core使用Ocelot结合Consul实现服务注册和发现的文章就介绍到这了。希望对大家的学习有所帮助,也希望大家多多支持编程网。
--结束END--
本文标题: Asp.Net Core使用Ocelot结合Consul实现服务注册和发现
本文链接: https://www.lsjlt.com/news/145400.html(转载时请注明来源链接)
有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341
下载Word文档到电脑,方便收藏和打印~
2023-05-21
2023-05-21
2023-05-21
2023-05-21
2023-05-20
2023-05-20
2023-05-20
2023-05-20
2023-05-20
2023-05-20
回答
回答
回答
回答
回答
回答
回答
回答
回答
回答
0