主頁 > .NET開發 > (8)ASP.NET Core3.1 Ocelot Consul服務注冊與發現

(8)ASP.NET Core3.1 Ocelot Consul服務注冊與發現

2020-12-10 06:11:13 .NET開發

1.服務注冊與發現(Service Discovery)

●服務注冊:我們通過在每個服務實體寫入注冊代碼,實體在啟動的時候會先去注冊中心(例如Consul、ZooKeeper、etcd、Eureka)注冊一下,那么客戶端通過注冊中心可以知道每個服務實體的地址,埠號,健康狀態等等資訊,也可以通過注冊中心洗掉服務實體,這里注冊中心相當于是負責維護服務實體的管控中心,
●服務發現:服務實體在注冊中心注冊之后,客戶端通過注冊中心可以了解這些服務實體運行狀況,

2.Consul

如果要實作服務注冊與發現,需要一個注冊中心,這里主要介紹是Consul,
Consul官網:https://www.consul.io/,它主要功能有:服務注冊與發現、健康檢查、Key/Value、多資料中心,
如果在Windows上部署Consul,在consul.exe目錄下執行consul.exe agent -dev命令列即可,
如果在Linux上部署Consul,大伙可以移步我之前寫過這篇文章“Consul在linux環境的集群部署”參考下,

3.Asp.Net Core向Consul注冊服務實體

Asp.Net Core向Consul注冊服務實體呼叫程序如下圖所示(圖片來源于https://www.cnblogs.com/zhouandke/p/10534836.html):

Asp.Net Core向Consul注冊服務實體需要在Gateway專案中參考Consul支持的NuGet軟體包,安裝命令如下:

Install-Package Ocelot.Provider.Consul

然后將以下內容添加到您的ConfigureServices方法中:

services.AddOcelot().AddConsul();

在Ocelot服務發現專案示例中,通過APIGateway專案GlobalConfiguration選項可以配置服務注冊與發現,檔案配置具體代碼如下:

{
  "Routes": [
    {
      "UseServiceDiscovery": true,
      "DownstreamPathTemplate": "/{url}",
      "DownstreamScheme": "http",
      "ServiceName": "MyService",
      "LoadBalancerOptions": {
        "Type": "RoundRobin"
      },
      "UpstreamPathTemplate": "/{url}",
      "UpstreamHttpMethod": [ "Get" ],
      "ReRoutesCaseSensitive": false
    }
  ],
  "GlobalConfiguration": {
    //服務發現配置
    "ServiceDiscoveryProvider": {
      //注冊中心Consul地址
      "Host": "192.168.113.128",
      //注冊中心Consul埠號
      "Port": 8500,
      "Type": "Consul",
      //以毫秒為單位,告訴Ocelot多久呼叫一次Consul來更改服務配置,
      "PollingInterval": 100,
      //如果你有在Consul上配置key/value,則在這里輸入配置key,
      "ConfigurationKey": "MyService_AB"
    }
  }
}

ServiceDiscoveryProvider選項說明:
●Host:注冊中心Consul地址,
●Port:注冊中心Consul埠號,
●Type:注冊中心型別,
●PollingInterval:以毫秒為單位,告訴Ocelot多久呼叫一次Consul來更改服務配置,
●ConfigurationKey:如果你有在Consul上配置key/value,則在這里輸入配置key,

4.專案演示

4.1APIGateway專案

ConfigureServices添加Ocelot、Consul注入:

services.AddOcelot().AddConsul();

Configure添加使用Ocelot:

app.UseOcelot().Wait();

服務發現配置如Ocelot服務發現專案示例一樣,

4.2Common專案

先安裝Consul的NuGet軟體包,安裝命令如下:

Install-Package Consul

在該專案添加一個AppExtensions擴展類,用來對服務APIServiceA、APIServiceB專案在Consul注冊實體,為了展示效果,具體代碼稍作修改如下:

public static class AppExtensions
{
    public static IServiceCollection AddConsulConfig(this IServiceCollection services, IConfiguration configuration)
    {
        services.AddSingleton<IConsulClient, ConsulClient>(p => new ConsulClient(consulConfig =>
        {
            var address = configuration.GetValue<string>("Consul:Host");
            consulConfig.Address = new Uri(address);
        }));
        return services;
    }
    public static IApplicationBuilder UseConsul(this IApplicationBuilder app, string host = null, string port = null)
    {
        //獲取consul客戶端實體
        var consulClient = app.ApplicationServices.GetRequiredService<IConsulClient>();
        var logger = app.ApplicationServices.GetRequiredService<ILoggerFactory>().CreateLogger("AppExtensions");
        var lifetime = app.ApplicationServices.GetRequiredService<IApplicationLifetime>();

        if (!(app.Properties["server.Features"] is FeatureCollection features)) return app;

        //var addresses = features.Get<IServerAddressesFeature>();
        //var address = addresses.Addresses.FirstOrDefault();
        //if (address == null)
        //{
        //    return app;
        //}

        var address = host + ":" + port;
        if (string.IsNullOrWhiteSpace(host) || string.IsNullOrWhiteSpace(port))
        {
            Console.WriteLine($"host或者port為空!");
            return app;
        }

        Console.WriteLine($"address={address}");
        var uri = new Uri(address);
        Console.WriteLine($"host={uri.Host},port={uri.Port}");

        var registration = new AgentServiceRegistration()
        {
            ID = $"MyService-{uri.Port}",
            Name = "MyService",
            Address = $"{uri.Host}",
            Port = uri.Port,
            Check = new AgentServiceCheck()
            {
                DeregisterCriticalServiceAfter = TimeSpan.FromSeconds(5),//服務啟動多久后注冊
                Interval = TimeSpan.FromSeconds(10),//健康檢查時間間隔
                HTTP = $"{address}/HealthCheck",//健康檢查地址
                Timeout = TimeSpan.FromSeconds(5)//超時時間
            }
        };
        logger.LogInformation("Registering with Consul");
        logger.LogInformation($"Consul RegistrationID:{registration.ID}");
        //注銷
        consulClient.Agent.ServiceDeregister(registration.ID).ConfigureAwait(true);
        //注冊
        consulClient.Agent.ServiceRegister(registration).ConfigureAwait(true);
        //應用程式關閉時候
        lifetime.ApplicationStopping.Register(() =>
        {
            //正在注銷
            logger.LogInformation("Unregistering from Consul");
            consulClient.Agent.ServiceDeregister(registration.ID).ConfigureAwait(true);
        });
        //每個服務都需要提供一個用于健康檢查的介面,該介面不具備業務功能,服務注冊時把這個介面的地址也告訴注冊中心,注冊中心會定時呼叫這個介面來檢測服務是否正常,如果不正常,則將它移除,這樣就保證了服務的可用性,
        app.Map("/HealthCheck", s =>
        {
            s.Run(async context =>
            {
                await context.Response.WriteAsync("ok");
            });
        });
        return app;
    }
}

4.3APIServiceA專案

專案添加一個Get方法,對應APIGateway專案的路由上下游配置,具體代碼如下:

[Route("api/[controller]")]
[ApiController]
public class ValuesController : ControllerBase
{
    // GET api/values
    [HttpGet]
    public ActionResult<IEnumerable<string>> Get()
    {
        var port = Request.Host.Port;
        return new string[] { "value1", "value2", port.Value.ToString() };
    }
}

appsettings.json配置加入Consul地址:

"Consul": {
  "Host": "http://192.168.113.128:8500"
}

4.4APIServiceB專案

專案添加一個Get方法,對應APIGateway專案的路由上下游配置,具體代碼如下:

[Route("api/[controller]")]
[ApiController]
public class ValuesController : ControllerBase
{
    // GET api/values
    [HttpGet]
    public ActionResult<IEnumerable<string>> Get()
    {
        var port = Request.Host.Port;
        return new string[] { "value3", "value4", port.Value.ToString() };
    }
}

appsettings.json配置加入Consul地址:

"Consul": {
  "Host": "http://192.168.113.128:8500"
}

4.5專案運行

在APIServiceA、APIServiceB專案的ConfigureServices添加Consul配置:

services.AddConsulConfig(Configuration);

在Configure添加Consul服務注冊:

APIServiceA:app.UseConsul("http://172.168.18.73", "9999");
APIServiceB:app.UseConsul("http://172.168.18.73", "9998");

把APIGateway、APIServiceA、APIServiceB三個專案部署到IIS上:

三個專案運行起來后,通過瀏覽器Consul客戶端可以看到MyService節點服務情況:

點擊打開MyService節點可以看到注冊到Consul的APIServiceA、APIServiceB服務狀況:

如果把APIServiceB服務實體站點停掉:

通過Consul客戶端會看到APIServiceB服務實體已經被剔除了:

如果輸入CTRL+C把集群中某一個Consul服務關閉,那么集群會重新選舉一個新的leader,負責處理所有服務實體的查詢和事務:



參考文獻:
Ocelot官網

轉載請註明出處,本文鏈接:https://www.uj5u.com/net/232249.html

標籤:.NET技术

上一篇:C# aspnetcore 完整修改專案名稱

下一篇:C#(八)基礎篇—繼承和多型

標籤雲
其他(123570) Java(13369) Python(12730) C(7542) 區塊鏈(7372) JavaScript(7059) 基礎類(6313) AI(6244) 腳本語言(PerlPython)(5129) 非技術區(4971) Android(4120) MySQL(4012) Linux(3394) C語言(3288) C++語言(3117) Java相關(2746) 疑難問題(2699) 單片機工控(2479) Web開發(1951) 網絡通信(1793) 數據庫相關(1767) VB基礎類(1755) PHP(1727) 開發(1646) 系統維護與使用區(1617) .NETCore(1586) 基礎和管理(1579) JavaEE(1566) C++(1527) 專題技術討論區(1515) Windows客戶端使用(1484) HtmlCss(1466) ASP.NET(1428) Unity3D(1354) VCL組件開發及應用(1353) HTML(CSS)(1220) 其他技術討論專區(1200) WindowsServer(1192) .NET技术(1165) 交換及路由技術(1149) 語言基礎算法系統設計(1133) WindowsSDKAPI(1124) 界面(1088) JavaSE(1075) Qt(1074) VBA(1048) 新手樂園(1016) 其他開發語言(947) Go(907) HTML5(901) 新技術前沿(898) 硬件設計(872) 區塊鏈技術(860) 網絡編程(857) 非技術版(846) 一般軟件使用(839) 網絡協議與配置(835) Eclipse(790) Spark(750) 下載資源懸賞專區(743)

熱門瀏覽
  • WebAPI簡介

    Web體系結構: 有三個核心:資源(resource),URL(統一資源識別符號)和表示 他們的關系是這樣的:一個資源由一個URL進行標識,HTTP客戶端使用URL定位資源,表示是從資源回傳資料,媒體型別是資源回傳的資料格式。 接下來我們說下HTTP. HTTP協議的系統是一種無狀態的方式,使用請求/ ......

    uj5u.com 2020-09-09 22:07:47 more
  • asp.net core 3.1 入口:Program.cs中的Main函式

    本文分析Program.cs 中Main()函式中代碼的運行順序分析asp.net core程式的啟動,重點不是剖析原始碼,而是理清程式開始時執行的順序。到呼叫了哪些實體,哪些法方。asp.net core 3.1 的程式入口在專案Program.cs檔案里,如下。ususing System; us ......

    uj5u.com 2020-09-09 22:07:49 more
  • asp.net網站作為websocket服務端的應用該如何寫

    最近被websocket的一個問題困擾了很久,有一個需求是在web網站中搭建websocket服務。客戶端通過網頁與服務器建立連接,然后服務器根據ip給客戶端網頁發送資訊。 其實,這個需求并不難,只是剛開始對websocket的內容不太了解。上網搜索了一下,有通過asp.net core 實作的、有 ......

    uj5u.com 2020-09-09 22:08:02 more
  • ASP.NET 開源匯入匯出庫Magicodes.IE Docker中使用

    Magicodes.IE在Docker中使用 更新歷史 2019.02.13 【Nuget】版本更新到2.0.2 【匯入】修復單列匯入的Bug,單元測驗“OneColumnImporter_Test”。問題見(https://github.com/dotnetcore/Magicodes.IE/is ......

    uj5u.com 2020-09-09 22:08:05 more
  • 在webform中使用ajax

    如果你用過Asp.net webform, 說明你也算是.NET 開發的老兵了。WEBform應該是2011 2013左右,當時還用visual studio 2005、 visual studio 2008。后來基本都用的是MVC。 如果是新開發的專案,估計沒人會用webform技術。但是有些舊版 ......

    uj5u.com 2020-09-09 22:08:50 more
  • iis添加asp.net網站,訪問提示:由于擴展配置問題而無法提供您請求的

    今天在iis服務器配置asp.net網站,遇到一個問題,記錄一下: 問題:由于擴展配置問題而無法提供您請求的頁面。如果該頁面是腳本,請添加處理程式。如果應下載檔案,請添加 MIME 映射。 WindowServer2012服務器,添加角色安裝完.netframework和iis之后,運行aspx頁面 ......

    uj5u.com 2020-09-09 22:10:00 more
  • WebAPI-處理架構

    帶著問題去思考,大家好! 問題1:HTTP請求和回傳相應的HTTP回應資訊之間發生了什么? 1:首先是最底層,托管層,位于WebAPI和底層HTTP堆疊之間 2:其次是 訊息處理程式管道層,這里比如日志和快取。OWIN的參考是將訊息處理程式管道的一些功能下移到堆疊下端的OWIN中間件了。 3:控制器處理 ......

    uj5u.com 2020-09-09 22:11:13 more
  • 微信門戶開發框架-使用指導說明書

    微信門戶應用管理系統,采用基于 MVC + Bootstrap + Ajax + Enterprise Library的技術路線,界面層采用Boostrap + Metronic組合的前端框架,資料訪問層支持Oracle、SQLServer、MySQL、PostgreSQL等資料庫。框架以MVC5,... ......

    uj5u.com 2020-09-09 22:15:18 more
  • WebAPI-HTTP編程模型

    帶著問題去思考,大家好!它是什么?它包含什么?它能干什么? 訊息 HTTP編程模型的核心就是訊息抽象,表示為:HttPRequestMessage,HttpResponseMessage.用于客戶端和服務端之間交換請求和回應訊息。 HttpMethod類包含了一組靜態屬性: private stat ......

    uj5u.com 2020-09-09 22:15:23 more
  • 部署WebApi隨筆

    一、跨域 NuGet參考Microsoft.AspNet.WebApi.Cors WebApiConfig.cs中配置: // Web API 配置和服務 config.EnableCors(new EnableCorsAttribute("*", "*", "*")); 二、清除默認回傳XML格式 ......

    uj5u.com 2020-09-09 22:15:48 more
最新发布