Tips：本篇已加入系列文章閱讀目錄，可點擊查看更多相關文章，
前言
上一篇【.Net Core微服務入門全紀錄（一）——專案搭建】講到要做到服務的靈活伸縮，那么需要有一種機制來實作它，這個機制就是服務注冊與發現，當然這也并不是必要的，如果你的服務實體很少，并且很穩定，那么就沒有必要使用服務注冊與發現，
服務注冊與發現
- 服務注冊：簡單理解，就是有一個注冊中心，我們的每個服務實體啟動時，都去注冊中心注冊一下，告訴注冊中心我的地址，埠等資訊，同樣的服務實體要洗掉時，去注冊中心洗掉一下，注冊中心負責維護這些服務實體的資訊，
- 服務發現：既然注冊中心維護了各個服務實體的資訊，那么客戶端通過注冊中心就很容易發現服務的變化了，
有了服務注冊與發現，客戶端就不用再去配置各個服務實體的地址，改為從注冊中心統一獲取，
那注冊中心又是怎么保證每個地址的可用狀態呢，假如某個實體掛了怎么辦呢？原則上掛掉的實體不應該被客戶端獲取到，所以就要提到：健康檢查 ，
- 健康檢查：每個服務都需要提供一個用于健康檢查的介面，該介面不具備業務功能，服務注冊時把這個介面的地址也告訴注冊中心，注冊中心會定時呼叫這個介面來檢測服務是否正常，如果不正常，則將它移除，這樣就保證了服務的可用性，
常見注冊中心有 Consul、ZooKeeper、etcd、Eureka，
Consul
Consul官網：https://www.consul.io/
Consul的主要功能有服務注冊與發現、健康檢查、K-V存盤、多資料中心等，
- Consul安裝：很簡單，直接在官網下載解壓即可，
- Consul運行：在consul.exe目錄下打開命令列執行
consul.exe agent -dev - 瀏覽器訪問：http://localhost:8500/
Consul已成功運行，
服務注冊
-
首先Nuget安裝一下Consul：
這個類別庫里封裝了Consul的api操作，方便我們直接使用，當然自己去寫http呼叫Consul的介面也不是不行，，，介面說明：https://www.consul.io/api-docs -
改造一下訂單服務的代碼：
ConsulHelper.cs：
public static class ConsulHelper
{
/// <summary>
/// 服務注冊到consul
/// </summary>
/// <param name="app"></param>
/// <param name="lifetime"></param>
public static IApplicationBuilder RegisterConsul(this IApplicationBuilder app, IConfiguration configuration, IHostApplicationLifetime lifetime)
{
var consulClient = new ConsulClient(c =>
{
//consul地址
c.Address = new Uri(configuration["ConsulSetting:ConsulAddress"]);
});
var registration = new AgentServiceRegistration()
{
ID = Guid.NewGuid().ToString(),//服務實體唯一標識
Name = configuration["ConsulSetting:ServiceName"],//服務名
Address = configuration["ConsulSetting:ServiceIP"], //服務IP
Port = int.Parse(configuration["ConsulSetting:ServicePort"]),//服務埠 因為要運行多個實體，埠不能在appsettings.json里配置，在docker容器運行時傳入
Check = new AgentServiceCheck()
{
DeregisterCriticalServiceAfter = TimeSpan.FromSeconds(5),//服務啟動多久后注冊
Interval = TimeSpan.FromSeconds(10),//健康檢查時間間隔
HTTP = $"http://{configuration["ConsulSetting:ServiceIP"]}:{configuration["ConsulSetting:ServicePort"]}{configuration["ConsulSetting:ServiceHealthCheck"]}",//健康檢查地址
Timeout = TimeSpan.FromSeconds(5)//超時時間
}
};
//服務注冊
consulClient.Agent.ServiceRegister(registration).Wait();
//應用程式終止時，取消注冊
lifetime.ApplicationStopping.Register(() =>
{
consulClient.Agent.ServiceDeregister(registration.ID).Wait();
});
return app;
}
}
appsettings.json：
{
"Logging": {
"LogLevel": {
"Default": "Information",
"Microsoft": "Warning",
"Microsoft.Hosting.Lifetime": "Information"
}
},
"AllowedHosts": "*",
"ConsulSetting": {
"ServiceName": "OrderService",
"ServiceIP": "localhost",
"ServiceHealthCheck": "/healthcheck",
"ConsulAddress": "http://host.docker.internal:8500"//注意，docker容器內部無法使用localhost訪問宿主機器，如果是控制臺啟動的話就用localhost
}
}
Startup.cs：
public class Startup
{
public Startup(IConfiguration configuration)
{
Configuration = configuration;
}
public IConfiguration Configuration { get; }
// This method gets called by the runtime. Use this method to add services to the container.
public void ConfigureServices(IServiceCollection services)
{
services.AddControllers();
}
// This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
public void Configure(IApplicationBuilder app, IWebHostEnvironment env, IHostApplicationLifetime lifetime)
{
if (env.IsDevelopment())
{
app.UseDeveloperExceptionPage();
}
app.UseRouting();
app.UseAuthorization();
app.UseEndpoints(endpoints =>
{
endpoints.MapControllers();
});
//服務注冊
app.RegisterConsul(Configuration, lifetime);
}
}
OrdersController.cs：
[Route("[controller]")]
[ApiController]
public class OrdersController : ControllerBase
{
private readonly ILogger<OrdersController> _logger;
private readonly IConfiguration _configuration;
public OrdersController(ILogger<OrdersController> logger, IConfiguration configuration)
{
_logger = logger;
_configuration = configuration;
}
[HttpGet]
public IActionResult Get()
{
string result = $"【訂單服務】{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}——" +
$"{Request.HttpContext.Connection.LocalIpAddress}:{_configuration["ConsulSetting:ServicePort"]}";
return Ok(result);
}
}
HealthCheckController.cs：
[Route("[controller]")]
[ApiController]
public class HealthCheckController : ControllerBase
{
/// <summary>
/// 健康檢查介面
/// </summary>
/// <returns></returns>
[HttpGet]
public IActionResult Get()
{
return Ok();
}
}
至此就完成了服務注冊，取消注冊，健康檢查等功能的代碼撰寫，
- 同樣的改造一下產品服務，代碼差不多一樣，就不貼了，
運行服務
繼續在docker中運行服務實體，不習慣docker的話用控制臺啟動也行，--ConsulSetting:ServicePort引數就是傳入容器的埠資訊，
docker build -t orderapi:1.0 -f ./Order.API/Dockerfile .
docker run -d -p 9060:80 --name orderservice orderapi:1.0 --ConsulSetting:ServicePort="9060"
docker run -d -p 9061:80 --name orderservice1 orderapi:1.0 --ConsulSetting:ServicePort="9061"
docker run -d -p 9062:80 --name orderservice2 orderapi:1.0 --ConsulSetting:ServicePort="9062"
docker build -t productapi:1.0 -f ./Product.API/Dockerfile .
docker run -d -p 9050:80 --name productservice productapi:1.0 --ConsulSetting:ServicePort="9050"
docker run -d -p 9051:80 --name productservice1 productapi:1.0 --ConsulSetting:ServicePort="9051"
docker run -d -p 9052:80 --name productservice2 productapi:1.0 --ConsulSetting:ServicePort="9052"
至此，6個服務器實體都已運行，并且成功注冊到Consul，
隨便停止2個服務：
可以看到停止的服務已經在Consul中被移除，注意，這個是我們停止程式時主動呼叫Consul移除的，
//應用程式終止時，取消注冊
lifetime.ApplicationStopping.Register(() =>
{
consulClient.Agent.ServiceDeregister(registration.ID).Wait();
});
當然程式發生例外，健康檢查不能正確回應的話，Consul也會移除，有一點區別，
那么注冊，發現，健康檢查功能都完成了，下一步就該考慮客戶端如何拿到這些服務實體的地址了，
代碼放在：https://github.com/xiajingren/NetCoreMicroserviceDemo
未完待續...
轉載請註明出處，本文鏈接：https://www.uj5u.com/net/13562.html
標籤：.NET Core