廬山真面目之三微服務架構Consul版本實現

一、簡介
          在上一篇文章《廬山真面目之二微服務架構NGINX版本實現》中，我們已經探討了如何搭建基於Nginx 閘道器的微服務架構，可能很多人感覺很簡單。沒錯，的確很簡單，因為我的每篇文章只會解決一個問題，這樣更單純、更精準，微服務架構也是這樣演化的。如果我們把所有的東西都放在一篇文章裡，太多了，不利於學習和檢視。我們看完上一篇文章後，知道了基於Nginx閘道器實現的微服務架構是有缺點的，而且這個缺點也是很致命的，它不能做到服務的註冊和發現。我們為了解決這個問題，今天我們引入另外一個概念，服務註冊發現元件：Consul，當然，ETCD、Zookeeper也可以做到，但是他們不再我們討論範圍之內。

　　1、說明
    　　我先說明一下，這個實現的版本只過是測試版本，以後會把相關的技術點都增加上去，我們一步一步的演化而來，如果是大牛，就可以直接跳過，因為這些東西相對於您來說，這個太簡單了。特別說明，這裡的所有程式碼都經過測試，所以大家可以放心使用。

　　2、開發環境
    　　以下就是開發環境，不用多說，都很簡單，一看就知道。
   　　（1）、開發工具：Visual Studio 2019
   　　（2）、開發語言：C#
   　　（3）、開發平臺：Net Core3.1，跨平臺。
   　　（4）、服務註冊：Consul，服務註冊、發現中心

　　3、我們的目標
    　　今天我們要解決的問題是如何做到服務的註冊和發現，其他問題，比如：Consul 本身的叢集的問題暫時就不考慮，我們會一步一步的演變下去。
            

二、Consul註冊、發現服務元件的簡介。
             
           在這裡我們只是做簡單的介紹，不會詳細討論它的所有技術點，沒有那麼大的篇幅，再說這樣做也就跑題了。如果大家想去學習Consul的有關內容，地址我已經貼出來了，大家可以自行惡補。
           Consul是一個服務網格（微服務間的 TCP/IP，負責服務之間的網路呼叫、限流、熔斷和監控）解決方案，它是一個一個分散式的，高度可用的系統，而且開發使用都很簡便。它提供了一個功能齊全的控制平面，主要特點是：服務發現、健康檢查、鍵值儲存、安全服務通訊、多資料中心。
         上面的一幅圖就說明了Consul的工作原理。S-A是使用服務的客戶端，他不用關係有多少個服務，只要它需要的時候，他就會向Consul服務中心發出請求，Consul中心就會把和服務名稱（在Consul中的名稱，也可以說是服務的類別名稱）匹配的、在此註冊的所有服務例項的地址資訊全部返回給S-A客戶端，然後客戶端，可以根據自己的情況，決定呼叫的具體策略，可以輪訓、可以權重、可以隨機，當然其他方式也可以，但是這些工作必須由使用服務的客戶端S-A自行解決。
          S-B-1、S-B-2、S-B-3等是在Consul中心註冊的服務例項，包括服務例項的地址、埠號、ID名稱、服務類別名稱等資訊。這些服務例項，每個服務例項都有自己的ID名稱，多個服務例項可以取一個相同的名稱，其實，這個名稱是用於分類的。Consul中心查詢的時候就是通過這個名稱來查詢的。這些服務例項，在應用程式一開始的時候就開始註冊，並且只註冊一次。
          所有的服務例項都註冊成功了，時間一分一秒的過去，一個小時之後或者一段時候之後服務還存在嗎？我們如何判斷呢？這就涉及到我們要談的第三個方面，健康監測，英文叫：Health Check。Consul中心為我們提供了現成的介面，可以定義針對服務的健康檢查，這個健康檢查是一個完整的策略，包括：如果檢查失敗，多久登出服務；服務檢查的時間間隔；還有呼叫檢查的超時時間等。這樣就能為我們提供一個比較完備的服務註冊、發現和檢測的解決方案。

      總結如下：
          1、服務自動註冊，可以發現新服務。
          2、健康檢測，可以過濾掉線服務。
          3、客戶端要完成服務呼叫邏輯，比較麻煩，沒有Nginx 方便。

　　 Consul文件：https://www.consul.io/docs
　　 Consul官網：https://www.consul.io

三、微服務架構Consul版本實現（簡約版）
    　　這個系列是有前後關係的，每篇文章都會解決一個特定的問題，Nginx閘道器的問題是可以解決負載均衡，可以做到服務掉線的檢測，但是沒有辦法做到新增服務的自動發現功能。今天要解決的問題就是如何做到服務的註冊和發現，相關元件的高可用和伸縮性暫時就不考了，還有一點，需要說明，每個專案都很簡單，程式碼也做到儘量的最少，因為我們關注的是微服務的架構，所以業務邏輯就很簡單。廢話少說，我們開始吧。

   　　 1、下載 Consul 服務元件。
          　　官網下載：https://www.consul.io/downloads
                       
          　　Consul下載成功後，放在沒有包含中文的目錄裡面，這是我的個人的習慣。
          　　我的執行目錄：D:\Programs\MicroServices\Consul_1.8.4_windows_amd64
          　　　　
           
   　　 2、配置 Consul 服務元件。
         　　 切換到當前目錄，執行如下命令：Consul agent –dev
          　　　　
          　　我們也可以通過瀏覽器檢視 Consul服務中心是否啟動成功，地址：http://localhost:8500，如果成功，效果如下：
               　　 

    　　3、建立專案，併為專案引入 Consul包。
          　　（1）、PatrickLiu.MicroService.Client（ASPNETCORE MVC）,客戶端專案。
                 　　　　這個專案很簡單，都是建立專案後，幾乎沒有修改任何程式碼，有修改的地方都會貼出來。
　　　　　　　　　　
　　　　　　　　　　1）、HomeController型別的程式碼，我只會貼出必須的程式碼。
　　　　　　　　　　　　

  1 using System;
  2 using System.Collections.Generic;
  3 using System.Linq;
  4 using System.Net.Http;
  5 using Consul;
  6 using Microsoft.AspNetCore.Mvc;
  7 using Microsoft.Extensions.Logging;
  8 using PatrickLiu.MicroService.Interfaces;
  9 using PatrickLiu.MicroService.Models;
 10 
 11 namespace PatrickLiu.MicroService.Client.Controllers
 12 {
 13     public class HomeController : Controller
 14     {
 15         private readonly ILogger<HomeController> _logger;
 16         private readonly IUserService _userService;
 17         private static int index;
 18 
 19         /// <summary>
 20         /// 初始化該型別的新例項。
 21         /// </summary>
 22         /// <param name="logger">注入日誌物件。</param>
 23         /// <param name="userService">注入使用者服務物件。</param>
 24         public HomeController(ILogger<HomeController> logger, IUserService userService)
 25         {
 26             _logger = logger;
 27             _userService = userService;
 28         }
 29 
 30         /// <summary>
 31         /// 首頁。
 32         /// </summary>
 33         /// <returns></returns>
 34         public IActionResult Index()
 35         {
 36             #region 分散式架構           
 37 
 38             #region  通過 Consul 服務發現來執行服務例項。
 39 
 40             //發現服務
 41             string url = "http://PatrickLiuService/api/users/all";
 42 
 43             ConsulClient client = new ConsulClient(config =>
 44             {
 45                 config.Address = new Uri("http://localhost:8500/");
 46                 config.Datacenter = "dc1";
 47             });
 48             var response = client.Agent.Services().Result.Response;
 49             foreach (var item in response)
 50             {
 51                 Console.WriteLine("*************************************************************");
 52                 Console.WriteLine(item.Key);
 53                 var service = item.Value;
 54                 Console.WriteLine($"{service.Address}--{service.Port}--{service.Service}");
 55                 Console.WriteLine("*************************************************************");
 56             }
 57             Uri uri = new Uri(url);
 58             string groupName = uri.Host;
 59             AgentService agentService = null;
 60 
 61             var serviceDirectory = response.Where(s => s.Value.Service.Equals(groupName, StringComparison.OrdinalIgnoreCase)).ToArray();
 62             //{//1、 寫死的
 63             //    agentService = serviceDirectory[0].Value;
 64             //}
 65             {
 66                 //2、輪詢
 67                 if (index >= 10000)
 68                 {
 69                     index = 0;
 70                 }
 71                 agentService = serviceDirectory[index++ % serviceDirectory.Length].Value;
 72             }
 73            // {//3、隨機
 74            //     var indexResult = new Random(index++).Next(0, serviceDirectory.Length);
 75            //     agentService = serviceDirectory[indexResult].Value;
 76            //}
 77             url = $"{uri.Scheme}://{agentService.Address}:{agentService.Port}{uri.PathAndQuery}";
 78 
 79             #endregion
 80 
 81             string content = InvokeAPI(url);
 82             this.ViewBag.Users = Newtonsoft.Json.JsonConvert.DeserializeObject<IEnumerable<User>>(content);
 83             Console.WriteLine($"This is {url} Invoke.");
 84             
 85             #endregion
 86 
 87             return View();
 88         }
 89 
 90         /// <summary>
 91         /// 封裝 HttpClient 例項，提供 Http 呼叫。
 92         /// </summary>
 93         /// <param name="url">http url 的地址。</param>
 94         /// <returns>返回結束資料，格式：JSON。</returns>
 95         public static string InvokeAPI(string url)
 96         {
 97             using (HttpClient client = new HttpClient())
 98             {
 99                 HttpRequestMessage message = new HttpRequestMessage();
100                 message.Method = HttpMethod.Get;
101                 message.RequestUri = new Uri(url);
102                 var result = client.SendAsync(message).Result;
103                 string conent = result.Content.ReadAsStringAsync().Result;
104                 return conent;
105             }
106         }
107     }
108 }

　　　　　　　　　　2）、Index.cshtml 檢視的程式碼。

 1 @{
 2     ViewData["Title"] = "Home Page";
 3 }
 4 
 5 <div class="text-center">
 6     <h1 class="display-4">Welcome</h1>
 7     <ul>
 8         @{
 9 
10             foreach (var item in ViewBag.Users)
11             {
12                 <li>@item.ID [email protected]  [email protected] </li>
13             }
14         }
15     </ul>
16     <p>Learn about <a href="https://docs.microsoft.com/aspnet/core">building Web apps with ASP.NET Core</a>.</p>
17 </div>

　　　　　　　　　　3）、為 Startup 型別ConfigurationServices 方法提供帶型別註冊。

1         /// <summary>
2         /// 註冊服務到容器中。
3         /// </summary>
4         /// <param name="services"></param>
5         public void ConfigureServices(IServiceCollection services)
6         {
7             services.AddSingleton<IUserService, UserService>();
8         }    

          　　（2）、PatrickLiu.MicroService.Interfaces（NETCORE 類庫），定義介面。
                 　　　　這個專案很簡單，都是建立專案後，幾乎沒有修改任何程式碼，有修改的地方都會貼出來。
                  　　　　  

　　　　　　　　　　IUserService.cs 型別的程式碼。
　　　　　　　　　　　　

 1 using PatrickLiu.MicroService.Models;
 2 using System.Collections.Generic;
 3 
 4 namespace PatrickLiu.MicroService.Interfaces
 5 {
 6     /// <summary>
 7     /// 使用者服務的介面定義。
 8     /// </summary>
 9     public interface IUserService
10     {
11         /// <summary>
12         /// 查詢指定主鍵的使用者例項物件。
13         /// </summary>
14         /// <param name="id">使用者的主鍵。</param>
15         /// <returns>返回查詢到的使用者例項物件。</returns>
16         User FindUser(int id);
17 
18         /// <summary>
19         /// 獲取所有使用者的例項集合。
20         /// </summary>
21         /// <returns>返回所有的使用者例項。</returns>
22         IEnumerable<User> UserAll();
23     }
24 }

          　　（3）、PatrickLiu.MicroService.Models（NETCORE 類庫），定義例項型別。
                 　　　　這個專案很簡單，都是建立專案後，幾乎沒有修改任何程式碼，有修改的地方都會貼出來。                 
                 　　　　  

　　　　　　　　　　User.cs 型別的程式碼。
　　　　　　　　　　　　

 1 using System;
 2 
 3 namespace PatrickLiu.MicroService.Models
 4 {
 5     /// <summary>
 6     /// 使用者模型。
 7     /// </summary>
 8     public class User
 9     {
10         /// <summary>
11         /// 獲取或者設定使用者主鍵。
12         /// </summary>
13         public int ID { get; set; }
14 
15         /// <summary>
16         /// 獲取或者設定使用者姓名。
17         /// </summary>
18         public string Name { get; set; }
19 
20         /// <summary>
21         /// 獲取或者設定使用者賬號名稱。
22         /// </summary>
23         public string Account { get; set; }
24 
25         /// <summary>
26         /// 獲取或者設定使用者密碼。
27         /// </summary>
28         public string Password { get; set; }
29 
30         /// <summary>
31         /// 獲取或者設定使用者的電子郵箱地址。
32         /// </summary>
33         public string Email { get; set; }
34 
35         /// <summary>
36         /// 獲取或者設定使用者角色。
37         /// </summary>
38         public string Role { get; set; }
39 
40         /// <summary>
41         /// 獲取或者設定使用者的登入時間。
42         /// </summary>
43         public DateTime LoginTime { get; set; }
44     }
45 }

          　　（4）、PatrickLiu.MicroService.Services（NETCORE 類庫），定義服務實現。
                 　　　　這個專案很簡單，都是建立專案後，幾乎沒有修改任何程式碼，有修改的地方都會貼出來。
                 　　　　　

　　　　　　　　　　UserService.cs 型別的程式碼。
　　　　　　　　　　　　

 1 using PatrickLiu.MicroService.Interfaces;
 2 using PatrickLiu.MicroService.Models;
 3 using System;
 4 using System.Collections.Generic;
 5 using System.Linq;
 6 
 7 namespace PatrickLiu.MicroService.Services
 8 {
 9     /// <summary>
10     /// 實現使用者服務介面的實現型別。
11     /// </summary>
12     public class UserService : IUserService
13     {
14         private IList<User> dataList;
15 
16         /// <summary>
17         /// 初始化型別的例項
18         /// </summary>
19         public UserService()
20         {
21             dataList = new List<User>()
22             { new User {ID=1,Name="黃飛鴻",Account="HuangFeiHong",Password="HuangFeiHong123456",Email="[email protected]", Role="Admin", LoginTime=DateTime.Now },
23             new User {ID=2,Name="洪熙官",Account="HongXiGuan",Password="HongXiGuan54667",Email="[email protected]", Role="Admin", LoginTime=DateTime.Now.AddDays(-5) },
24             new User {ID=3,Name="方世玉",Account="FangShiYu",Password="FangShiYu112233",Email="[email protected]", Role="Admin", LoginTime=DateTime.Now.AddDays(-30) },
25             new User {ID=4,Name="苗翠花",Account="MiaoCuiHua",Password="MiaoCuiHua887766",Email="[email protected]", Role="Admin", LoginTime=DateTime.Now.AddDays(-90) },
26             new User {ID=5,Name="嚴詠春",Account="YanYongChun",Password="YanYongChun09392",Email="[email protected]", Role="Admin", LoginTime=DateTime.Now.AddMinutes(-50) }};
27         }
28 
29         /// <summary>
30         /// 查詢指定主鍵的使用者例項物件。
31         /// </summary>
32         /// <param name="id">使用者的主鍵。</param>
33         /// <returns>返回查詢到的使用者例項物件。</returns>
34         public User FindUser(int id)
35         {
36             return dataList.FirstOrDefault(user => user.ID == id);
37         }
38 
39         /// <summary>
40         /// 獲取所有使用者的例項集合。
41         /// </summary>
42         /// <returns>返回所有的使用者例項。</returns>
43         public IEnumerable<User> UserAll()
44         {
45             return dataList;
46         }
47     }
48 }

          　　（5）、PatrickLiu.MicroService.ServiceInstance（ASPNETCORE WEBAPI）,介面服務。
                 　　　　這個專案很簡單，都是建立專案後，幾乎沒有修改任何程式碼，有修改的地方都會貼出來。
　　　　　　　　　
                　　 1）、我們要在這個專案裡面使用Consul服務，所以，我們通過Nuget安裝。也可以執行命令安裝：Install-Package Consul。
                     　　　　Install-Package Consul

                 　　2）、我們在Startup類裡面的Configure方法裡增加以下程式碼：
                     　　　　Startup.cs 型別的程式碼。

 1 using Consul;
 2 using Microsoft.AspNetCore.Builder;
 3 using Microsoft.AspNetCore.Hosting;
 4 using Microsoft.Extensions.Configuration;
 5 using Microsoft.Extensions.DependencyInjection;
 6 using Microsoft.Extensions.Hosting;
 7 using PatrickLiu.MicroService.Interfaces;
 8 using PatrickLiu.MicroService.ServiceInstance.Utilities;
 9 using PatrickLiu.MicroService.Services;
10 using System;
11 using System.Security.Policy;
12 
13 namespace PatrickLiu.MicroService.ServiceInstance
14 {
15     /// <summary>
16     /// 應用程式啟動配置
17     /// </summary>
18     public class Startup
19     {
20         /// <summary>
21         /// 建構函式注入配置物件
22         /// </summary>
23         /// <param name="configuration">配置例項</param>
24         public Startup(IConfiguration configuration)
25         {
26             Configuration = configuration;
27         }
28 
29         /// <summary>
30         /// 獲取配置例項。
31         /// </summary>
32         public IConfiguration Configuration { get; }
33 
34         /// <summary>
35         /// 配置注入物件。
36         /// </summary>
37         /// <param name="services"></param>
38         public void ConfigureServices(IServiceCollection services)
39         {
40             services.AddControllers();
41            //需要增加的
42             services.AddSingleton<IUserService, UserService>();
43         }
44 
45         /// <summary>
46         /// 配置 HTTP 處理管道。
47         /// </summary>
48         /// <param name="app">應用程式物件。</param>
49         /// <param name="env">環境物件。</param>
50         /// <param name="applicationLifetime">應用程式生命週期的物件。</param>
51         public void Configure(IApplicationBuilder app, IWebHostEnvironment env,IHostApplicationLifetime applicationLifetime)
52         {
53             if (env.IsDevelopment())
54             {
55                 app.UseDeveloperExceptionPage();
56             }
57 
58             //app.UseHttpsRedirection();
59 
60             app.UseRouting();
61 
62             app.UseAuthorization();//授權
63 
64             app.UseEndpoints(endpoints =>
65             {
66                 endpoints.MapControllers();
67             });
68 
69             #region Consul 註冊，需要增加的
70 
71             string serviceID = $"Service:{Configuration["ip"]}:{Configuration["port"]}---{Guid.NewGuid()}";
72             string consuleServiceName = "PatrickLiuService";
73             
74             //註冊服務。
75             Configuration.ConsulRegist(consuleServiceName,serviceID);
76 
77             //登出服務
78             applicationLifetime.ConsulDown(serviceID);
79 
80             #endregion
81         }
82     }
83 }    

　　　　　　　　3）、UsersController.cs 型別的程式碼。
　　　　　　　　　　　　

  1 using System;
  2 using System.Collections.Generic;
  3 using System.Linq;
  4 using System.Threading;
  5 using Microsoft.AspNetCore.Authorization;
  6 using Microsoft.AspNetCore.Mvc;
  7 using Microsoft.Extensions.Configuration;
  8 using Microsoft.Extensions.Logging;
  9 using PatrickLiu.MicroService.Interfaces;
 10 using PatrickLiu.MicroService.Models;
 11 
 12 namespace PatrickLiu.MicroService.ServiceInstance.Controllers
 13 {
 14     /// <summary>
 15     /// 使用者的 API 型別。
 16     /// </summary>
 17     [Route("api/[controller]")]
 18     [ApiController]    
 19     public class UsersController : ControllerBase
 20     {
 21         #region 私有欄位
 22 
 23         private readonly ILogger<UsersController> _logger;
 24         private readonly IUserService _userService;
 25         private IConfiguration _configuration;
 26 
 27         #endregion
 28 
 29         #region 建構函式
 30 
 31         /// <summary>
 32         /// 初始化該型別的新例項。
 33         /// </summary>
 34         /// <param name="logger">日誌記錄器。</param>
 35         /// <param name="userService">使用者服務介面。</param>
 36         /// <param name="configuration">配置服務。</param>
 37         public UsersController(ILogger<UsersController> logger, IUserService userService, IConfiguration configuration)
 38         {
 39             _logger = logger;
 40             _userService = userService;
 41             _configuration = configuration;
 42         }
 43 
 44         #endregion
 45 
 46         #region 例項方法
 47 
 48         /// <summary>
 49         /// 獲取一條記錄
 50         /// </summary>
 51         /// <param name="id"></param>
 52         /// <returns></returns>
 53         [HttpGet]
 54         [Route("Get")]
 55         public User Get(int id)
 56         {
 57             return _userService.FindUser(id);
 58         }
 59 
 60         /// <summary>
 61         /// 獲取所有記錄。
 62         /// </summary>
 63         /// <returns></returns>
 64         [HttpGet]
 65         [Route("All")]
 66         //[Authorize]
 67         public IEnumerable<User> Get()
 68         {
 69             Console.WriteLine($"This is UsersController {this._configuration["port"]} Invoke");
 70 
 71             return this._userService.UserAll().Select((user => new User
 72             {
 73                 ID = user.ID,
 74                 Name = user.Name,
 75                 Account = user.Account,
 76                 Password = user.Password,
 77                 Email = user.Email,
 78                 Role = $"{this._configuration["ip"]}：{this._configuration["port"]}",
 79                 LoginTime = user.LoginTime
 80             })); ;
 81         }
 82 
 83         /// <summary>
 84         /// 超時處理
 85         /// </summary>
 86         /// <returns></returns>
 87         [HttpGet]
 88         [Route("Timeout")]
 89         public IEnumerable<User> Timeout()
 90         {
 91             Console.WriteLine($"This is Timeout Start");
 92             //超時設定。
 93             Thread.Sleep(3000);
 94 
 95             Console.WriteLine($"This is Timeout End");
 96 
 97             return this._userService.UserAll().Select((user => new User
 98             {
 99                 ID = user.ID,
100                 Name = user.Name,
101                 Account = user.Account,
102                 Password = user.Password,
103                 Email = user.Email,
104                 Role = $"{this._configuration["ip"]}：{this._configuration["port"]}",
105                 LoginTime = user.LoginTime
106             })); ;
107         }
108 
109         #endregion
110     }
111 }

　　　　　　　　4）、HealthController.cs 型別的程式碼，該程式碼用於健康檢查。　　　　　　　　　　　　

 1 using System;
 2 using Microsoft.AspNetCore.Mvc;
 3 using Microsoft.Extensions.Configuration;
 4 
 5 namespace PatrickLiu.MicroService.ServiceInstance.Controllers
 6 {
 7     /// <summary>
 8     /// 健康檢查的控制器。
 9     /// </summary>
10     [ApiController]
11     [Route("api/[controller]")]
12     public class HealthController : ControllerBase
13     {
14         private IConfiguration _configuration;
15 
16         /// <summary>
17         /// 初始化該型別的新例項。
18         /// </summary>
19         /// <param name="configuration">配置介面。</param>
20         public HealthController(IConfiguration configuration)
21         {
22             _configuration = configuration;
23         }
24 
25         /// <summary>
26         /// 要呼叫的介面。
27         /// </summary>
28         [HttpGet]
29         [Route("Index")]
30         public IActionResult Index()
31         {
32             Console.WriteLine($"This is HealhController {_configuration["port"]} Invoke");
33             return Ok();
34         }
35     }
36 }

    　　4、編寫註冊Consul 的核心程式碼。
          　　我們增加了一個擴充套件類，類的名稱：ConsulExtension.cs，實現程式碼如下：
　　　　　　

 1 using Consul;
 2 using Microsoft.Extensions.Configuration;
 3 using Microsoft.Extensions.Hosting;
 4 using System;
 5 
 6 namespace PatrickLiu.MicroService.ServiceInstance.Utilities
 7 {
 8     /// <summary>
 9     /// Consul 靜態擴充套件類。
10     /// </summary>
11     public static class ConsulExtension
12     {
13         /// <summary>
14         ///型別初始化器，初始化 Consul 網址和資料中心。
15         /// </summary>
16         static ConsulExtension()
17         {
18             Uri = new Uri("http://localhost:8500");
19             DataCenter = "dc1";
20         }
21 
22         /// <summary>
23         /// 獲取或者設定 Consul 的網址。
24         /// </summary>
25         public static Uri Uri { get; set; }
26 
27         /// <summary>
28         /// 獲取或者設定資料中心。
29         /// </summary>
30         public static string DataCenter { get; set; }
31 
32         /// <summary>
33         /// 向 Consul 服務中心註冊服務例項。
34         /// </summary>
35         /// <param name="configuration">配置物件。</param>
36         /// <param name="consulServiceName">在 Consul 服務中心註冊的服務類別名稱，多個例項的 ID 可以屬於一個服務類別名稱。</param>
37         /// <param name="serviceID">服務例項的主鍵值，必須唯一。</param>
38         public static void ConsulRegist(this IConfiguration configuration,string consulServiceName, string serviceID)
39         {
40             if (string.IsNullOrEmpty(consulServiceName) || string.IsNullOrWhiteSpace(consulServiceName))
41             {
42                 throw new ArgumentNullException("consulServiceName is null");
43             }
44             if (string.IsNullOrEmpty(serviceID) || string.IsNullOrWhiteSpace(serviceID))
45             {
46                 throw new ArgumentNullException("serviceID is null.");
47             }
48 
49             using (ConsulClient client = new ConsulClient(config =>
50             {
51                 config.Address = Uri;
52                 config.Datacenter = DataCenter;
53             }))
54             {
55                 string ip = configuration["ip"];
56                 int port = int.Parse(configuration["port"]);
57                 int weight = string.IsNullOrWhiteSpace(configuration["weight"]) ? 1 : int.Parse(configuration["weight"]);
58 
59                 client.Agent.ServiceRegister(new AgentServiceRegistration()
60                 {
61                     ID = serviceID,
62                     Name = consulServiceName,
63                     Address = ip,
64                     Port = port,
65                     Tags = new string[] { weight.ToString() },
66                     Check = new AgentServiceCheck()
67                     {
68                         Interval = TimeSpan.FromSeconds(12),
69                         HTTP = $"http://{ip}:{port}/API/Health/Index",
70                         Timeout = TimeSpan.FromSeconds(5),
71                         DeregisterCriticalServiceAfter = TimeSpan.FromSeconds(20)
72                     }
73                 }).Wait();
74                 Console.WriteLine($"註冊服務：{ip}:{port}--Weight:{weight}");
75             };                       
76         }
77 
78         /// <summary>
79         /// 向 Consul 服務中心登出服務例項。
80         /// </summary>
81         /// <param name="applicationLifetime">配置物件。</param>
82         /// <param name="serviceID">服務例項的主鍵值，必須唯一。</param>
83         public static void ConsulDown(this IHostApplicationLifetime applicationLifetime, string serviceID)
84         {
85             if (string.IsNullOrEmpty(serviceID) || string.IsNullOrWhiteSpace(serviceID))
86             {
87                 throw new ArgumentNullException("serviceID is null");
88             }
89             applicationLifetime.ApplicationStopped.Register(() =>
90             {
91                 using (var consulClient = new ConsulClient(config => { config.Address = Uri; config.Datacenter = DataCenter; }))
92                 {
93                     Console.WriteLine("服務已經退出");
94                     consulClient.Agent.ServiceDeregister(serviceID);
95                 }
96             });
97         }
98     }
99 }

　　     5、編譯專案，釋出4個服務例項，獨立程序承載。
           　　再次提醒大家，在開始啟動這4個服務例項之前，必須啟動Consul服務中心。
          　　（1）、dotnet PatrickLiu.MicroService.ServiceInstance.dll --urls="http://*:5726" --ip="127.0.0.1" --port=5726
　　　　　　　　　　
                                  健康檢查如圖：
                    　　　　　
          　　（2）、dotnet PatrickLiu.MicroService.ServiceInstance.dll --urls="http://*:5727" --ip="127.0.0.1" --port=5727
　　　　　　　　　　
                                   健康檢查如圖：
                      　　　　
          　　（3）、dotnet PatrickLiu.MicroService.ServiceInstance.dll --urls="http://*:5728" --ip="127.0.0.1" --port=5728
　　　　　　　　　　
                                   健康檢查如圖：
　　　　　　　　　　
          　　（4）、dotnet PatrickLiu.MicroService.ServiceInstance.dll --urls="http://*:5729" --ip="127.0.0.1" --port=5729
　　　　　　　　　　
                                   健康檢查如圖：
　　　　　　　　　　
                                以上是我們成功啟動了4個服務例項，並且在Consul 服務中心註冊成功，也可以執行健康檢查，功能基本完善了。讓我們看看4個服務例項在Consul中心的樣子吧。
          　　　　　　　　

　　     6、客戶端訪問 Consul服務，最終訪問我們服務例項。
       　　  
          　　客戶端我們自己實現的輪訓策略，每次重新整理，埠號都變，效果如圖：

              　　5726埠的資料：
                   　　
              　　5727埠的資料：
                   　　
　　               5728埠的資料：
                   　　
         　　     5729埠的資料：
                   　　
　　     7、我們的結論。
          　　我們現在雖然可以自由的發現新服務，也可以發現失敗的服務，實現了服務的自動註冊和發現，但是Consul另外一個問題就是，客戶端使用太麻煩，我們需要自己去決定呼叫服務策略，是輪訓、隨機、權重，還是其他策略，如果專案很小不是問題，如果專案很大，需求變化很快，我們都需要手動去做這些事，就太浪費時間和精力了。有問題，我們就解決問題，解決方案已有，就是使用Ocelot這個元件。
         

四、  結束語
   　　 好了，今天就寫到這裡了。內容挺多了，整理起來也挺麻煩的，但是每天這樣堅持，每天都有進步，生活過的也很充實。通過今天的學習，我們知道了如果只是單獨以後Consul實現服務註冊還是有缺點的，那我們就繼續改進，既然客戶端那麼麻煩，我們的解決辦法就是引入另外一個概念，Ocelot閘道器，它可以解決Consul的問題，又可以實現負載均衡，努力吧，每天進步一點