Asp.Net?Core使用Ocelot結(jié)合Consul實(shí)現(xiàn)服務(wù)注冊和發(fā)現(xiàn)
1.服務(wù)注冊與發(fā)現(xiàn)（Service Discovery）
- 服務(wù)注冊：我們通過在每個服務(wù)實(shí)例寫入注冊代碼，實(shí)例在啟動的時候會先去注冊中心（例如Consul、ZooKeeper、etcd、Eureka）注冊一下，那么客戶端通過注冊中心可以知道每個服務(wù)實(shí)例的地址，端口號，健康狀態(tài)等等信息，也可以通過注冊中心刪除服務(wù)實(shí)例。這里注冊中心相當(dāng)于是負(fù)責(zé)維護(hù)服務(wù)實(shí)例的管控中心。
- 服務(wù)發(fā)現(xiàn)：服務(wù)實(shí)例在注冊中心注冊之后，客戶端通過注冊中心可以了解這些服務(wù)實(shí)例運(yùn)行狀況。
2.Consul
如果要實(shí)現(xiàn)服務(wù)注冊與發(fā)現(xiàn)，需要一個注冊中心，這里主要介紹是Consul。
Consul官網(wǎng)：https://www.consul.io/，它主要功能有：服務(wù)注冊與發(fā)現(xiàn)、健康檢查、Key/Value、多數(shù)據(jù)中心。
如果在Windows上部署Consul，在consul.exe目錄下執(zhí)行consul.exe agent -dev命令行即可。
3.Asp.Net Core向Consul注冊服務(wù)實(shí)例
Asp.Net Core向Consul注冊服務(wù)實(shí)例調(diào)用過程如下圖所示：
Asp.Net Core向Consul注冊服務(wù)實(shí)例需要在Gateway項(xiàng)目中引用Consul支持的NuGet軟件包，安裝命令如下：
Install-Package Ocelot.Provider.Consul
然后將以下內(nèi)容添加到您的ConfigureServices方法中：
services.AddOcelot().AddConsul();
在Ocelot服務(wù)發(fā)現(xiàn)項(xiàng)目示例中，通過APIGateway項(xiàng)目GlobalConfiguration選項(xiàng)可以配置服務(wù)注冊與發(fā)現(xiàn)，文件配置具體代碼如下：
{
"Routes": [
{
"UseServiceDiscovery": true,
"DownstreamPathTemplate": "/{url}",
"DownstreamScheme": "http",
"ServiceName": "MyService",
"LoadBalancerOptions": {
"Type": "RoundRobin"
},
"UpstreamPathTemplate": "/{url}",
"UpstreamHttpMethod": [ "Get" ],
"ReRoutesCaseSensitive": false
}
],
"GlobalConfiguration": {
//服務(wù)發(fā)現(xiàn)配置
"ServiceDiscoveryProvider": {
//注冊中心Consul地址
"Host": "192.168.113.128",
//注冊中心Consul端口號
"Port": 8500,
"Type": "Consul",
//以毫秒為單位，告訴Ocelot多久調(diào)用一次Consul來更改服務(wù)配置。
"PollingInterval": 100,
//如果你有在Consul上配置key/value，則在這里輸入配置key。
"ConfigurationKey": "MyService_AB"
}
}
}ServiceDiscoveryProvider選項(xiàng)說明：
- Host：注冊中心Consul地址。
- Port：注冊中心Consul端口號。
- Type：注冊中心類型。
- PollingInterval：以毫秒為單位，告訴Ocelot多久調(diào)用一次Consul來更改服務(wù)配置。
- ConfigurationKey：如果你有在Consul上配置key/value，則在這里輸入配置key。
4.項(xiàng)目演示
4.1APIGateway項(xiàng)目
ConfigureServices添加Ocelot、Consul注入：
services.AddOcelot().AddConsul();
Configure添加使用Ocelot：
app.UseOcelot().Wait();
服務(wù)發(fā)現(xiàn)配置如Ocelot服務(wù)發(fā)現(xiàn)項(xiàng)目示例一樣。
4.2Common項(xiàng)目
先安裝Consul的NuGet軟件包，安裝命令如下：
Install-Package Consul
在該項(xiàng)目添加一個AppExtensions擴(kuò)展類，用來對服務(wù)APIServiceA、APIServiceB項(xiàng)目在Consul注冊實(shí)例，為了展示效果，具體代碼稍作修改如下：
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客戶端實(shí)例
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),//服務(wù)啟動多久后注冊
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);
//應(yīng)用程序關(guān)閉時候
lifetime.ApplicationStopping.Register(() =>
{
//正在注銷
logger.LogInformation("Unregistering from Consul");
consulClient.Agent.ServiceDeregister(registration.ID).ConfigureAwait(true);
});
//每個服務(wù)都需要提供一個用于健康檢查的接口，該接口不具備業(yè)務(wù)功能。服務(wù)注冊時把這個接口的地址也告訴注冊中心，注冊中心會定時調(diào)用這個接口來檢測服務(wù)是否正常，如果不正常，則將它移除，這樣就保證了服務(wù)的可用性。
app.Map("/HealthCheck", s =>
{
s.Run(async context =>
{
await context.Response.WriteAsync("ok");
});
});
return app;
}
}4.3APIServiceA項(xiàng)目
項(xiàng)目添加一個Get方法，對應(yīng)APIGateway項(xiàng)目的路由上下游配置，具體代碼如下：
[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"
}4.4APIServiceB項(xiàng)目
項(xiàng)目添加一個Get方法，對應(yīng)APIGateway項(xiàng)目的路由上下游配置，具體代碼如下：
[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"
}4.5項(xiàng)目運(yùn)行
在APIServiceA、APIServiceB項(xiàng)目的ConfigureServices添加Consul配置：
services.AddConsulConfig(Configuration);
在Configure添加Consul服務(wù)注冊：
APIServiceA：app.UseConsul("http://172.168.18.73", "9999");
APIServiceB：app.UseConsul("http://172.168.18.73", "9998");把APIGateway、APIServiceA、APIServiceB三個項(xiàng)目部署到IIS上：
三個項(xiàng)目運(yùn)行起來后，通過瀏覽器Consul客戶端可以看到MyService節(jié)點(diǎn)服務(wù)情況：
點(diǎn)擊打開MyService節(jié)點(diǎn)可以看到注冊到Consul的APIServiceA、APIServiceB服務(wù)狀況：
如果把APIServiceB服務(wù)實(shí)例站點(diǎn)停掉：
通過Consul客戶端會看到APIServiceB服務(wù)實(shí)例已經(jīng)被剔除了：
如果輸入CTRL+C把集群中某一個Consul服務(wù)關(guān)閉，那么集群會重新選舉一個新的leader，負(fù)責(zé)處理所有服務(wù)實(shí)例的查詢和事務(wù)：
到此這篇關(guān)于Asp.Net Core使用Ocelot結(jié)合Consul實(shí)現(xiàn)服務(wù)注冊和發(fā)現(xiàn)的文章就介紹到這了。希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
this connector is disabled錯誤的解決方法
打開editor/filemanager/connectors/aspx/config.ascx修改CheckAuthentication()方法，返回true2008-11-11
這篇文章介紹了語言集成查詢LINQ，文中通過示例代碼介紹的非常詳細(xì)。對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下2022-03-03
這篇文章介紹了WPF使用AForge調(diào)用攝像頭的方法，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2022-01-01
.net生成縮略圖及水印圖片時出現(xiàn)GDI+中發(fā)生一般性錯誤解決方法
這篇文章主要介紹了.net生成縮略圖及水印圖片時出現(xiàn)GDI+中發(fā)生一般性錯誤解決方法 ,需要的朋友可以參考下2014-11-11
今天學(xué)習(xí)一下javascript實(shí)現(xiàn)從父窗口打開一個子窗口，在子窗口處理一些結(jié)果之后，把結(jié)果賦值于父窗口的文本框內(nèi)，接下來介紹實(shí)現(xiàn)方法，感興趣的朋友可以了解下，希望本文對你有所幫助2013-01-01
使用.NET存儲XML數(shù)據(jù)的方法...2007-04-04
想必大家應(yīng)該有給存儲過程找錯誤的經(jīng)歷吧，一遍遍的去讀sql代碼，一句一句的測試,發(fā)現(xiàn)一個小錯誤可能都要用很長的時間,接下來將介紹使用vs2010調(diào)試存儲過程,感興趣的朋友可以不要錯過了啊2013-02-02
這篇文章主要介紹了使用PowerShell .Net獲取電腦中的UUID 的相關(guān)資料,需要的朋友可以參考下2016-06-06
ASP.NET Core 數(shù)據(jù)保護(hù)（Data Protection）中篇
這篇文章主要為大家再一次介紹了ASP.NET Core 數(shù)據(jù)保護(hù)（Data Protection）,具有一定的參考價值，感興趣的小伙伴們可以參考一下2016-09-09
利用ASP.NET MVC+Bootstrap搭建個人博客之praise.js點(diǎn)贊特效插件(二)
這篇文章主要介紹了利用ASP.NET和MVC+Bootstrap搭建個人博客之praise.js點(diǎn)贊特效插件(二)的相關(guān)資料,需要的朋友可以參考下2016-06-06