1、微服務--為什麼有consul,consul註冊,心跳檢測,服務發現

来源:https://www.cnblogs.com/menglin2010/archive/2019/12/29/12114473.html
-Advertisement-
Play Games

一、為什麼有consul? 在微服務,每1個服務都是集群式的,訂單服務在10台伺服器上都有,那麼用戶的請求到達,獲取哪台伺服器的訂單服務呢?如果10臺中的有的訂單服務掛了怎麼辦?10台伺服器扛不住了,水平擴展又新增加了1台伺服器提供訂單服務,怎麼讓用戶請求知道有新的伺服器提供服務了?這時候就需要Co ...


一、為什麼有consul?

在微服務,每1個服務都是集群式的,訂單服務在10台伺服器上都有,那麼用戶的請求到達,獲取哪台伺服器的訂單服務呢?如果10臺中的有的訂單服務掛了怎麼辦?10台伺服器扛不住了,水平擴展又新增加了1台伺服器提供訂單服務,怎麼讓用戶請求知道有新的伺服器提供服務了?這時候就需要Consul了,它能通過心跳檢測哪些服務還活著,而且有新的服務啟動,它也能主動發現

二、consul環境準備

1、consul環境

consul官網:https://www.consul.io/downloads.html,下載windows 64bit

2、啟動consul管理後臺

然後cmd啟動,註意切盤符,路徑要對,盤符切到放consul.exe的目錄,cd D:\consul\consul agent -dev

訪問consul管理後臺:http://localhost:8500

三、代碼實現

1、添加Webapi服務

namespace ConsulServiceFind.Controllers
{
    [Route("api/[controller]")]
    [ApiController]
    public class ValuesController : ControllerBase
    {
        private IConfiguration _IConfiguration = null;
        private ILogger<ValuesController> _logger = null;

        public ValuesController(IConfiguration iConfiguration, ILogger<ValuesController> logger)
        {
            _IConfiguration = iConfiguration;
            _logger = logger;
        }

        // GET api/values
        [HttpGet]
        public ActionResult<IEnumerable<string>> Get()
        {
            this._logger.LogWarning("ValuesController-Get 執行");
            return new JsonResult(new
            {
                Id = 123,
                Name = "david_test",
                IP = this._IConfiguration["ip"],
                port = this._IConfiguration["port"],
                urls = this._IConfiguration["urls"],
                CurrentPath = base.HttpContext.Request.Path
            });
        }

    }
}

2、log4net 集成到Core

2.1、Nuget引入log4net

2.2、Nuget引入Microsoft.Extensions.Logging.Log4Net.AspNetCore

2.3、添加log4net 配置文件 (設置配置文件屬性為始終複製,預設配置文件放在根目錄下)

2.4、註入ILogger

namespace ConsulServiceFind
{
    public class Program
    {
        public static void Main(string[] args)
        {
            CreateWebHostBuilder(args).Build().Run();
        }


        public static IWebHostBuilder CreateWebHostBuilder(string[] args) =>
            WebHost.CreateDefaultBuilder(args)
            .ConfigureLogging((context, LoggingBuilder) =>//ILogger
            {
                LoggingBuilder.AddFilter("System", LogLevel.Warning); // 忽略系統的其他日誌
                LoggingBuilder.AddFilter("Microsoft", LogLevel.Warning);
                LoggingBuilder.AddLog4Net();
            })
            .UseStartup<Startup>();
    }
}

3、網站啟動後需要consul註冊

3.1、Nuget引用consul,ConsulRegister類

namespace ConsulServiceFind
{
    public static class ConsulRegister
    {
        public static void RegistConsul(this IConfiguration configuration)
        {
            string ip = configuration["ip"] ?? "Localhost";
            //部署到不同伺服器的時候不能寫成127.0.0.1或者0.0.0.0,因為這是讓服務消費者調用的地址
            int port = int.Parse(configuration["port"]);
            //實例化consul客戶端
            ConsulClient consulClient = new ConsulClient(c => {
                c.Address = new Uri("http://127.0.0.1:8500");
                c.Datacenter = "consul";
            });
            //向consul註冊服務
            Task<WriteResult> result = consulClient.Agent.ServiceRegister(new AgentServiceRegistration() {
                ID = "david_webapi_test_" + Guid.NewGuid(),//服務編號,不能重覆
                Name = "david_webapi",//服務的名字--將來調用時用的就是這個
                Address = ip,
                Port = port,
                Tags = new string[] { },//可以用來設置權重
                Check=new AgentServiceCheck() {
                    DeregisterCriticalServiceAfter = TimeSpan.FromSeconds(5),//服務停止多久後反註冊
                    Interval = TimeSpan.FromSeconds(10),//健康檢查時間間隔,或者稱為心跳間隔
                    HTTP = $"http://{ip}:{port}/api/health",//健康檢查地址,
                    Timeout = TimeSpan.FromSeconds(5)
                }
            });
        }
    }
}

3.2、在Startup的Configure方法里使用consul

3.3、ConsulRegister心跳檢測,添加health-check,健康檢查

namespace ConsulServiceFind
{
    [Route("api/[controller]")]
    [ApiController]
    public class HealthController : ControllerBase
    {
        private IConfiguration _IConfiguration = null;
        private ILogger<HealthController> _logger = null;
        public HealthController(IConfiguration configuration, ILogger<HealthController> logger)
        {
            this._IConfiguration = configuration;
            this._logger = logger;
        }
       
        [HttpGet]
        public IActionResult Check()
        {
            this._logger.LogWarning($"{this._IConfiguration["port"]}-Health Check!");
            return Ok();//200
        }
    }
}

4、啟動多個WebApi實例,運行兩個WebApi服務起來

4.1、cd  切路徑--C:\Users\dell\Desktop\ConsulServiceFind\ConsulServiceFind\bin\Debug\netcoreapp2.2

4.2、通過命令行啟動2個不同埠的webapi

dotnet ConsulServiceFind.dll --urls="http://*:10010" --ip="127.0.0.1" --port=10010

dotnet ConsulServiceFind.dll --urls="http://*:10020" --ip="127.0.0.1" --port=10020

http://localhost:10010/api/values

http://localhost:10020/api/values

4.3、去http://localhost:8500查看多個服務被髮現和心跳檢測 

 

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 《瘋狂Java講義(第4版)》是《瘋狂Java講義》的第4版,第4版保持了前3版系統、全面、講解淺顯、細緻的特性,全面新增介紹了Java 9的新特性。 《瘋狂Java講義(第4版)》深入介紹了Java編程的相關方面,《瘋狂Java講義(第4版)》內容覆蓋了Java的基本語法結構、Java的面向對象特 ...
  • 1.引言 上一篇博文關於淺拷貝和深拷貝 https://www.cnblogs.com/zhaoyixiang/p/12116203.html 我們瞭解到我們在淺拷貝時對帶指針的對象進行拷貝會出現記憶體泄漏,那C++是否可以實現像python,JAVA一樣引入垃圾回收機制,來靈活的來管理記憶體。 遺憾的 ...
  • 上一篇文章我們已經知道可以通過task.wait/task.WaitAny/task.WaitAll,等方法來實現等待一個tsak或者一組task的執行完畢,這一個方法都會阻塞主線程也就是這一些操作都是主流程的一個必然環節,但是我們在實際項目中,也還會遇到這樣的場景,那就是主流程根本不關心task的... ...
  • 時間如流水,只能流去不流回! 點贊再看,養成習慣,這是您給我創作的動力! 本文 Dotnet9 https://dotnet9.com 已收錄,站長樂於分享dotnet相關技術,比如Winform、WPF、ASP.NET Core、Xamarin.Forms等,亦有C++桌面相關的Qt Quick和 ...
  • 隨著.NET Core 3.1的發佈,國內2019 中國.NET開發者峰會在上海的成功舉辦。從技術採用生命周期的角度來說,隨著.NET Core 3.1的發佈,有越來越多的廠商開始採用.NET Core, .NET Core 正在跨越技術鴻溝。.NET Core 正是順應應用程式現代化,應用程式容器... ...
  • 在上一篇文章 abp(net core)+easyui+efcore實現倉儲管理系統——ABP WebAPI與EasyUI結合增刪改查之五(三十一) 中我們實現了新增組織部門信息功能,不過還存在一些BUG。今天我們來繼續完善組織部門信息新增功能,併進行測試。 ...
  • 前言 我是從.net 4.5直接跳到.net core 3.x的,感覺asp.net這套東西最初是從4.5中的owin形成的。目前官方文檔重點是講路由,沒有特別說明與傳統路由的區別,本篇主要介紹終結點路由的相關概念和如何使用,不會詳細介紹路由,這個參考官方文檔就ok了。如果將來有機會研究到底層再深度 ...
  • 問題 在開發微信支付的小微商戶進件介面時,需要通過表單來上傳身份證圖片等數據。在微信支付介面文檔也說明瞭,需要使用 multipart/form data 的方式發送請求。.NET 提供了 類型,幫助我們構建表單請求,故有以下代碼: 按照微信支付官方文檔提交之後,一直提示參數錯誤,百思不得其解。 原 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...