廬山真面目之三微服務架構Consul簡單版本實現
廬山真面目之三微服務架構 Consul 簡單版本實現html
1、簡介
在上一篇文章《廬山真面目之二微服務架構NGINX簡單版本實現》中，咱們已經探討了如何搭建基於Nginx 網關的微服務架構，可能不少人感受很簡單。沒錯，的確很簡單，由於個人每篇文章只會解決一個問題，這樣更單純、更精準，微服務架構也是這樣演化的。若是咱們把全部的東西都放在一篇文章裏，太多了，不利於學習和查看。咱們看完上一篇文章後，知道了基於Nginx網關實現的微服務架構是有缺點的，並且這個缺點也是很致命的，它不能作到服務的註冊和發現。咱們爲了解決這個問題，今天咱們引入另一個概念，服務註冊發現組件：Consul，固然，ETCD、Zookeeper也能夠作到，可是他們再也不咱們討論範圍以內。
1、說明
我先說明一下，這個實現的版本只過是測試版本，之後會把相關的技術點都增長上去，咱們一步一步的演化而來，若是是大牛，就能夠直接跳過，由於這些東西相對於您來講，這個太簡單了。特別說明，這裏的全部代碼都通過測試，因此你們能夠放心使用。
2、開發環境
如下就是開發環境，不用多說，都很簡單，一看就知道。
（1）、開發工具：Visual Studio 2019
（2）、開發語言：C#
（3）、開發平臺：Net Core3.1，跨平臺。
（4）、服務註冊：Consul，服務註冊、發現中心
（5）、操做系統：Windows 10，64bit
3、咱們的目標
今天咱們要解決的問題是如何作到服務的註冊和發現，其餘問題，好比：Consul 自己的集羣的問題暫時就不考慮，咱們會一步一步的演變下去。
windows
2、Consul註冊、發現服務組件的簡介。
在這裏咱們只是作簡單的介紹，不會詳細討論它的全部技術點，沒有那麼大的篇幅，再說這樣作也就跑題了。若是你們想去學習Consul的有關內容，地址我已經貼出來了，你們能夠自行惡補。
Consul是一個服務網格（微服務間的 TCP/IP，負責服務之間的網絡調用、限流、熔斷和監控）解決方案，它是一個一個分佈式的，高度可用的系統，並且開發使用都很簡便。它提供了一個功能齊全的控制平面，主要特色是：服務發現、健康檢查、鍵值存儲、安全服務通訊、多數據中心。
上面的一幅圖就說明了Consul的工做原理。S-A是使用服務的客戶端，他不用關係有多少個服務，只要它須要的時候，他就會向Consul服務中心發出請求，Consul中心就會把和服務名稱（在Consul中的名稱，也能夠說是服務的類別名稱）匹配的、在此註冊的全部服務實例的地址信息所有返回給S-A客戶端，而後客戶端，能夠根據本身的狀況，決定調用的具體策略，能夠輪訓、能夠權重、能夠隨機，固然其餘方式也能夠，可是這些工做必須由使用服務的客戶端S-A自行解決。
S-B-一、S-B-二、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
api
3、微服務架構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 //{//一、 寫死的 63 // agentService = serviceDirectory[0].Value; 64 //} 65 { 66 //二、輪詢 67 if (index >= 10000) 68 { 69 index = 0; 70 } 71 agentService = serviceDirectory[index++ % serviceDirectory.Length].Value; 72 } 73 // {//三、隨機 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 --@item.Name --@item.Role </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 類型的代碼。
app
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="huangFeiHong@sina.com", Role="Admin", LoginTime=DateTime.Now }, 23 new User {ID=2,Name="洪熙官",Account="HongXiGuan",Password="HongXiGuan54667",Email="HongXiGuan@sina.com", Role="Admin", LoginTime=DateTime.Now.AddDays(-5) }, 24 new User {ID=3,Name="方世玉",Account="FangShiYu",Password="FangShiYu112233",Email="fangShiYu@163.com", Role="Admin", LoginTime=DateTime.Now.AddDays(-30) }, 25 new User {ID=4,Name="苗翠花",Account="MiaoCuiHua",Password="MiaoCuiHua887766",Email="miaoCuiHua@sohu.com", Role="Admin", LoginTime=DateTime.Now.AddDays(-90) }, 26 new User {ID=5,Name="嚴詠春",Account="YanYongChun",Password="YanYongChun09392",Email="yanYongChun@263.com", 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 類型的代碼。dom
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這個組件。
4、 結束語 好了，今天就寫到這裏了。內容挺多了，整理起來也挺麻煩的，可是天天這樣堅持，天天都有進步，生活過的也很充實。經過今天的學習，咱們知道了若是隻是單獨之後Consul實現服務註冊仍是有缺點的，那咱們就繼續改進，既然客戶端那麼麻煩，咱們的解決辦法就是引入另一個概念，Ocelot網關，它能夠解決Consul的問題，又能夠實現負載均衡，努力吧，天天進步一點點。
- 1. 廬山真面目之二微服務架構NGINX簡單版本實現
- 2. 廬山真面目之四微服務架構Consul和Ocelot簡單版本實現
- 3. 廬山真面目之二微服務架構NGINX版本實現
- 4. 廬山真面目之五微服務架構Consul集羣、Ocelot網關和Nginx版本實現
- 5. 廬山真面目之六微服務架構Consul集羣、Ocelot網關集羣和Nginx版本實現
- 6. 廬山真面目之八微服務架構 NetCore 基於 Dockerfile 文件部署
- 7. 三層架構之初識廬山真面目
- 8. 廬山真面目之一微服務的簡介和技術棧
- 9. 廬山真面目之十二微服務架構基於Docker搭建Consul集羣、Ocelot網關集羣和IdentityServer版本實現
- 10. 不識廬山真面目
- 更多相關文章...
- • 服務端腳本 指南 - 網站建設指南
- • MySQL的版本以及版本號 - MySQL教程
- • Spring Cloud 微服務實戰(三) - 服務註冊與發現
- • TiDB 在摩拜單車在線數據業務的應用和實踐
-
每一个你不满意的现在，都有一个你没有努力的曾经。
- 1. 廬山真面目之二微服務架構NGINX簡單版本實現
- 2. 廬山真面目之四微服務架構Consul和Ocelot簡單版本實現
- 3. 廬山真面目之二微服務架構NGINX版本實現
- 4. 廬山真面目之五微服務架構Consul集羣、Ocelot網關和Nginx版本實現
- 5. 廬山真面目之六微服務架構Consul集羣、Ocelot網關集羣和Nginx版本實現
- 6. 廬山真面目之八微服務架構 NetCore 基於 Dockerfile 文件部署
- 7. 三層架構之初識廬山真面目
- 8. 廬山真面目之一微服務的簡介和技術棧
- 9. 廬山真面目之十二微服務架構基於Docker搭建Consul集羣、Ocelot網關集羣和IdentityServer版本實現
- 10. 不識廬山真面目