廬山真面目之四微服務架構Consul和Ocelot簡單版本實現
廬山真面目之四微服務架構Consul和Ocelot簡單版本實現html
1、簡介
在上一篇文章《廬山真面目之三微服務架構Consul簡單版本實現》中，咱們已經探討了如何搭建基於Consul組件的微服務架構，可能不少人感受很簡單。沒錯，的確很簡單，由於個人每篇文章只會解決一個問題，這樣更單純、更精準。若是咱們把全部的東西都放在一篇文章裏，太多了，不利於學習和查看。咱們經過上一篇文章可知，在客戶端訪問 Consul 組件管理的業務服務實例是多麼的麻煩，須要本身寫代碼實現。項目少，無所謂，只要項目一大，或者項目多了，規模大了，都會對管理和維護帶來很大的挑戰，畢竟，人喜歡操做簡單的東西，想擡槓的免開尊口，主要是不必。今天咱們就解決客戶端手寫調用策略的問題。
1、說明
我先說明一下，這個實現的版本只過是測試版本，之後會把相關的技術點都增長上去，咱們一步一步的演化而來，若是是大牛，就能夠直接跳過，由於這些東西相對於您來講，這個太簡單了。特別說明，這裏的全部代碼都通過測試，因此你們能夠放心使用。
2、開發環境
如下就是開發環境，不用多說，都很簡單，一看就知道。
（1）、開發工具：Visual Studio 2019
（2）、開發語言：C#
（3）、開發平臺：Net Core3.1，跨平臺。
（4）、服務註冊：Consul，服務註冊、發現中心
（5）、網關服務：Ocelot 開源組件，負載均衡，服務治理。
（6）、操做系統：Windows 10，64bit。
3、咱們的目標
今天咱們要解決的問題是如何作到服務實例調用策略不準要手寫，而且還能實現負載均衡，其餘問題，好比：Consul 自己的集羣的問題暫時就不考慮，咱們會一步一步的演變下去。
git
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
github
3、Ocelot服務組件簡介。
今天要給你們介紹的Ocelot是一個基於 .net core的開源WebAPI服務網關項目，它的功能很是強大，包括了路由、請求聚合、服務發現、認證鑑權、限流、負載均衡等功能。而這些功能均可以直接經過修改json配置文件便可使用，很是方便。Ocelot是系統中對外暴露的一個請求入口，全部外部接口都必須經過這個網關才能向下遊API發出請求，就如地鐵中的安檢系統，全部人都必須通過安檢才能乘坐地鐵。
固然了，我今天確定也不會對Ocelot服務組件進行詳細的討論，它有官網和詳細的文檔，若是想看它的源碼也是沒有問題的，由於它是開源的。若是你們想去學習的話，能夠直接點擊我貼出的鏈接。
web
官網：https://threemammals.com/ocelot
json
文檔：https://ocelot.readthedocs.io/en/latest
windows
Git：https://github.com/ThreeMammals/Ocelot
api
4、微服務架構Consul和Ocelot版本實現
上一篇文章咱們解決了業務服務實例的發現和註冊問題，固然也有健康檢查，能夠作到服務實例的動態伸縮。很是給力，也很是興奮，由於咱們又打敗了一個問題，作技術的人員都懂我說的意思。兵來將擋水來土掩，今天咱們要解決手寫代碼去實現服務實例的調用策略。廢話少說，咱們開始吧。
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.cs的代碼瀏覽器
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 18 /// <summary> 19 /// 初始化該類型的新實例。 20 /// </summary> 21 /// <param name="logger">注入日誌對象。</param> 22 /// <param name="userService">注入用戶服務對象。</param> 23 public HomeController(ILogger<HomeController> logger, IUserService userService) 24 { 25 _logger = logger; 26 _userService = userService; 27 } 28 29 /// <summary> 30 /// 首頁。 31 /// </summary> 32 /// <returns></returns> 33 public IActionResult Index() 34 { 35 #region 經過 Ocelot 網關訪問服務實例。 36 37 string url = "http://localhost:6299/gate/users/all";//這個地址是網關的 38 39 #endregion 40 41 string content = InvokeAPI(url); 42 this.ViewBag.Users = Newtonsoft.Json.JsonConvert.DeserializeObject<IEnumerable<User>>(content); 43 Console.WriteLine($"This is {url} Invoke."); 44 45 #endregion 46 47 return View(); 48 } 49 50 51 /// <summary> 52 /// 封裝 HttpClient 實例，提供 Http 調用。 53 /// </summary> 54 /// <param name="url">http url 的地址。</param> 55 /// <returns>返回結束數據，格式：JSON。</returns> 56 public static string InvokeAPI(string url) 57 { 58 using (HttpClient client = new HttpClient()) 59 { 60 HttpRequestMessage message = new HttpRequestMessage(); 61 message.Method = HttpMethod.Get; 62 message.RequestUri = new Uri(url); 63 var result = client.SendAsync(message).Result; 64 string conent = result.Content.ReadAsStringAsync().Result; 65 return conent; 66 } 67 } 68 } 69 }
【2】、修改Startup.cs代碼，紅色增長的代碼。
安全
1 public void ConfigureServices(IServiceCollection services) 2 { 3 services.AddControllersWithViews(); 4 5 services.AddSingleton<IUserService, UserService>(); 6 }
（2）、PatrickLiu.MicroService.Interfaces（NETCORE 類庫），定義接口。
代碼以下：
網絡
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 類庫），定義實例類型。
代碼以下：
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 類庫），定義服務實現。
代碼以下：
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服務組件，以支持Consul服務。
命令：Install-Package Consul
能夠在項目菜單【依賴項】菜單上點擊右鍵，選擇【管理 NuGet 程序包】來安裝Consul服務。
【2】、HealthController.cs，主要用於Consul服務的健康檢查。
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 }
【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】、增長擴展類型：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】、修改 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 //其餘代碼省略 41 services.AddSingleton<IUserService, UserService>(); 42 } 43 44 /// <summary> 45 /// 配置 HTTP 處理管道。 46 /// </summary> 47 /// <param name="app">應用程序對象。</param> 48 /// <param name="env">環境對象。</param> 49 /// <param name="applicationLifetime">應用程序生命週期的對象。</param> 50 public void Configure(IApplicationBuilder app, IWebHostEnvironment env,IHostApplicationLifetime applicationLifetime) 51 { 52 //其餘代碼省略 53 #region Consul 註冊 54 55 string serviceID = $"Service:{Configuration["ip"]}:{Configuration["port"]}---{Guid.NewGuid()}"; 56 string consuleServiceName = "PatrickLiuService"; 57 58 //註冊服務。 59 Configuration.ConsulRegist(consuleServiceName,serviceID); 60 61 //註銷服務 62 applicationLifetime.ConsulDown(serviceID); 63 64 #endregion 65 } 66 } 67 }
【6】、修改 Program.cs 代碼，紅色標註表明增長的代碼。
1 using System.IO; 2 using Microsoft.AspNetCore.Hosting; 3 using Microsoft.Extensions.Configuration; 4 using Microsoft.Extensions.Hosting; 5 6 namespace PatrickLiu.MicroService.ServiceInstance 7 { 8 public class Program 9 { 10 public static void Main(string[] args) 11 { 12 new ConfigurationBuilder() 13 .SetBasePath(Directory.GetCurrentDirectory()) 14 .AddCommandLine(args)//支持命令行 15 .Build(); 16 17 CreateHostBuilder(args).Build().Run(); 18 } 19 20 public static IHostBuilder CreateHostBuilder(string[] args) => 21 Host.CreateDefaultBuilder(args) 22 .ConfigureWebHostDefaults(webBuilder => 23 { 24 webBuilder.UseStartup<Startup>(); 25 }); 26 } 27 }
（6）、PatrickLiu.MicroService.Gateway（ASPNETCORE WEBAPI）,網關服務。
【1】、安裝Ocelot組件包。
在【程序包管理器控制檯】執行命令
命令：Install-Package Ocelot
固然也能夠在項目下的【依賴項】上點右鍵，點擊【管理NuGet程序包】菜單，在【瀏覽】項先安裝，輸入Ocelot，在右側安裝則能夠。
【2】、安裝Ocelot.Provider.Consul組件包。
在【程序包管理器控制檯】執行命令。
命令：Intall-Package Ocelot.Provider.Consul
固然也能夠在項目下的【依賴項】上點右鍵，點擊【管理NuGet程序包】菜單，在【瀏覽】項先安裝，輸入Ocelot.Provider.Consul，在右側安裝則能夠。
【3】、配置Startup.cs文件。
【4】、增長JSON配置文件，文件名：configuration.json。
【5】、修改 Program.cs 文件，使用上面增長的JSON配置文件。
【6】、啓動網關實例。
命令：dotnet PatrickLiu.MicroService.Gateway.dll –urls=http://*:6299 –port=6299
【7】、驗證是否啓動成功。
網關地址：http://localhost:6299/gate/users/all，能獲取到數據表示一切成功。
截圖以下：
4、編譯項目，發佈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中心的樣子吧。
註冊的服務詳情。
5、客戶端經過網關訪問 Consul服務，最終訪問咱們服務實例。
客戶端咱們本身實現的輪訓策略，每次刷新，端口號都變，效果如圖：
5726端口的數據：
5727端口的數據：
5728端口的數據：
5729端口的數據：
6、咱們的結論。
咱們解決了服務的發現和註冊問題，也解決了客戶端訪問的問題，很不錯，咱們還需繼續努力。實話實說，這樣的架構確定還不能在產品環境裏面使用，由於有太多的問題了。當下就有一個可靠性的問題，若是這個單節點的Consul服務掛掉，怎麼辦？整個系統就會垮掉，咱們爲了增長系統的高可用性，須要對Consul組件進行升級，它須要集羣來提供高可用。這就是咱們下一篇文章要解決的問題，頗有挑戰啊。
5、 結束語 好了，今天就寫到這裏了。完整高樓平地起，咱們經過不斷的努力，不斷的解決遇到的問題，咱們的知識也在劇增，眼界也就更寬廣了。俗話說得好，兵來將擋水來土掩，努力吧，天天進步一點點。
- 1. 廬山真面目之三微服務架構Consul簡單版本實現
- 2. 廬山真面目之二微服務架構NGINX簡單版本實現
- 3. 廬山真面目之五微服務架構Consul集羣、Ocelot網關和Nginx版本實現
- 4. 廬山真面目之六微服務架構Consul集羣、Ocelot網關集羣和Nginx版本實現
- 5. 廬山真面目之二微服務架構NGINX版本實現
- 6. Ocelot+Consul實現微服務架構
- 7. 廬山真面目之十二微服務架構基於Docker搭建Consul集羣、Ocelot網關集羣和IdentityServer版本實現
- 8. 廬山真面目之八微服務架構 NetCore 基於 Dockerfile 文件部署
- 9. 廬山真面目之一微服務的簡介和技術棧
- 10. 不識廬山真面目
- 更多相關文章...
- • 服務端腳本 指南 - 網站建設指南
- • MySQL的版本以及版本號 - MySQL教程
- • Spring Cloud 微服務實戰(三) - 服務註冊與發現
- • TiDB 在摩拜單車在線數據業務的應用和實踐
-
每一个你不满意的现在，都有一个你没有努力的曾经。
- 1. Appium入門
- 2. Spring WebFlux 源碼分析(2)-Netty 服務器啓動服務流程 --TBD
- 3. wxpython入門第六步（高級組件）
- 4. CentOS7.5安裝SVN和可視化管理工具iF.SVNAdmin
- 5. jedis 3.0.1中JedisPoolConfig對象缺少setMaxIdle、setMaxWaitMillis等方法，問題記錄
- 6. 一步一圖一代碼，一定要讓你真正徹底明白紅黑樹
- 7. 2018-04-12—（重點）源碼角度分析Handler運行原理
- 8. Spring AOP源碼詳細解析
- 9. Spring Cloud（1）
- 10. python簡單爬去油價信息發送到公衆號
- 1. 廬山真面目之三微服務架構Consul簡單版本實現
- 2. 廬山真面目之二微服務架構NGINX簡單版本實現
- 3. 廬山真面目之五微服務架構Consul集羣、Ocelot網關和Nginx版本實現
- 4. 廬山真面目之六微服務架構Consul集羣、Ocelot網關集羣和Nginx版本實現
- 5. 廬山真面目之二微服務架構NGINX版本實現
- 6. Ocelot+Consul實現微服務架構
- 7. 廬山真面目之十二微服務架構基於Docker搭建Consul集羣、Ocelot網關集羣和IdentityServer版本實現
- 8. 廬山真面目之八微服務架構 NetCore 基於 Dockerfile 文件部署
- 9. 廬山真面目之一微服務的簡介和技術棧
- 10. 不識廬山真面目