Ocelot + Consul + Registrator 基於Docker 實現服務發現、服務自動註冊

来源:https://www.cnblogs.com/zhangdk/archive/2018/07/25/ms1.html
-Advertisement-
Play Games

基於Ocelot、Consul、Registrator搭建微服務架構,實現服務發現和自動註冊,後續逐步完善許可權驗證、負載均衡等功能。 ...


目錄

關於這個工具的介紹這裡就不多說了,網上、官網都很詳細,這裡直接記錄一下搭建過程。另外最後有幾個疑惑還未解決,希望各位前輩答疑解惑。

1. Consul集群搭建

我們基於Docker搭建三個Server和兩個Client的DC。

  • server1
docker run -d --name server1 consul agent -server -node=server1 -bootstrap-expect=3
# 獲取server1IP地址,方便後續節點接入集群
JOIN_IP="$(sudo docker inspect -f '{{.NetworkSettings.IPAddress}}' server1)"
  • server2
docker run -d --name server2 consul agent -server -node=server2 -join $JOIN_IP
  • server3
docker run -d --name server3 consul agent -server -node=server3 -join $JOIN_IP
  • client1
docker run -d --name client1 consul agent -node=client1 -join $JOIN_IP
  • client2
docker run -d --name client2 -p 8400:8400 -p 8500:8500 -p 8600:53/udp  consul agent -ui -node=client2 -client=0.0.0.0 -join $JOIN_IP

運行效果:

image

1.1 F&Q

Consul官方推薦的host網路模式運行

查看Consul官方文檔,官方推薦Consul以Docker的host網路模式運行。但是這樣的話,一個Docker寄宿主機只運行一個consul agent?生產中的Docker集群是如何搭建的?

2. Registrator服務註冊工具

啟動Registrator工具容器,Registrator使用主機網路模式,使用-internal選項,註冊基於expose埠的服務。

docker run -d --name registrator --net host --volume=/var/run/docker.sock:/tmp/docker.sock gliderlabs/registrator -internal consul://172.17.0.6:8500

Consul管理UI服務截圖,Registrator會把Consul也作為服務註冊到Consul。這也是可以理解的,因為Registrator的觀點是任何監聽在埠的程式都是服務。

iamge

2.1 F&Q

Registrator懸掛服務

正常情況下,這裡應該是沒有clientservice的,但是由於我之前測試沒有正常按順序啟停容器,形成了懸掛服務,一直沒有清除。我看Registrator文檔中有-cleanup選項可以清理懸掛服務,後續嘗試一下。

Registrator的-internal選項

不指定這個選項時,Registrator使用容器的發佈埠(映射到寄宿主機的埠)自動註冊服務,這時候一般要用-ip選項指定主機的IP地址,因為Registrator一般很難推斷出主機的IP地址。當使用-internal選項時,Registrator使用服務所在容器分配的內部地址自動註冊服務。

3. clientservice服務Demo

clientservice是一個web api項目,由於是自動服務發現和註冊,因此clientservice跟無需做特別的配置。
我僅僅指定服務的埠為5000,修改了ValueController,返回服務調用情況。

3.1 Program.cs

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

        public static IWebHostBuilder CreateWebHostBuilder(string[] args) =>
            WebHost.CreateDefaultBuilder(args)
                .UseUrls("http://*:5000")
                .UseStartup<Startup>();
    }

3.2 ValuesController.cs

...
[HttpGet]
        public ActionResult<RequestInfo> Get()
        {
            var clientHost = HttpContext.Connection.RemoteIpAddress.MapToIPv4().ToString();
            var serverHost = HttpContext.Connection.LocalIpAddress.MapToIPv4().ToString();
            var path = HttpContext.Request.Path;
            return new RequestInfo{
                RemoteIp = clientHost,
                RemotePort = HttpContext.Connection.RemotePort,
                LocalIp = serverHost,
                LocalPort = HttpContext.Connection.LocalPort,
                Path = path,
                Host = HttpContext.Request.Host.ToUriComponent()
            };
        }
...

3.3 Dockerfile

#基於microsoft/dotnet:latest構建Docker image
FROM microsoft/dotnet:latest

#進入docker中的/usr/local/src目錄,創建DockerWebAPI目錄
RUN cd /usr/local/src&&mkdir DockerWebAPI

#設置工作路徑
WORKDIR /usr/local/src/DockerWebAPI

#將當前文件夾下的所有文件全部複製到工作目錄
COPY ./ ./

#向外界暴露5000埠
EXPOSE 5000

#執行dotnet *.dll命令
CMD ["dotnet","clientservice.dll"]

3.4 製作鏡像並啟動容器

  • 製作鏡像
docker build -t zhangdk/clientservice .
  • 啟動容器
docker run -d zhangdk/clientservice

Consul管理UI截圖,如果你是第一次搭建集群並啟動Clientservice的話,後面應該有小標1。我這裡由於懸掛服務的問題,有啟動前的1現在變成了2。

image

clientservice註冊信息(多餘的是懸掛服務的註冊信息),要註意查看ServiceAddress和ServicePort是否正確:

image

4. Ocelot網關Demo

VS Code創建空web項目dotnet new web,安裝ocelot庫dot add package ocelot,主要修改三個文件:

4.1 Program.cs:

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

        public static IWebHostBuilder CreateWebHostBuilder(string[] args) =>
            WebHost.CreateDefaultBuilder(args)
                .UseStartup<Startup>()
                .UseUrls("http://*:5010")  //服務監聽在5010埠,後期可以調整為從外部讀取,方便配置
                .ConfigureAppConfiguration((context,builder)=>{
                    builder.AddJsonFile("configuration.json",false,true); //讀取Ocelot配置文件
                });
    }

4.2 Startup.cs:

public class Startup
    {
        public Startup(IConfiguration configuration){
            Configuration = configuration;
        }

        public IConfiguration Configuration{get;set;}
        
        public void ConfigureServices(IServiceCollection services) => services.AddOcelot(Configuration); //註冊Ocelot服務

        public void Configure(IApplicationBuilder app, IHostingEnvironment env)
        {
            if (env.IsDevelopment())
            {
                app.UseDeveloperExceptionPage();
            }

            app.UseOcelot().Wait();   //啟用Ocelot中間件
        }
    }

4.3 添加配置文件configuration.json:

{
    "ReRoutes": [
      {
        "UseServiceDiscovery": true,  //啟用服務發現
        "DownstreamPathTemplate": "/api/{url}",
        "DownstreamScheme": "http",
        "ServiceName": "clientservice",
        "LoadBalancerOptions": {
          "Type": "RoundRobin"
        },
        "UpstreamPathTemplate": "/api/clientservice/{url}",
        "UpstreamHttpMethod": [ "Get", "Post" ],
        "ReRoutesCaseSensitive": false
      }
    ],
    "GlobalConfiguration": {
      "ServiceDiscoveryProvider": {
        "Host": "172.17.0.6",  //Consul client IP
        "Port": 8500  //Consul HTTP API埠
      }
    }
  }

4.4 Dockerfile文件編寫

#基於microsoft/dotnet:latest構建Docker image
FROM microsoft/dotnet:latest

#進入docker中的/usr/local/src目錄,創建DockerWebAPI目錄
RUN cd /usr/local/src&&mkdir DockerWebAPI

#設置工作路徑
WORKDIR /usr/local/src/DockerWebAPI

#將當前文件夾下的所有文件全部複製到工作目錄
COPY ./ ./

#向外界暴露5010埠
EXPOSE 5010

#執行dotnet *.dll命令
CMD ["dotnet","oceletgateway.dll"]

4.5 發佈項目,製作鏡像,並啟動容器

  • 發佈項目
dotnet publish
  • 拷貝Dockfile到Demo的publish文件夾,打開終端
docker build -t zhangdk/ocelotgateway .
  • 運行OcelotGateway服務容器
docker run -d --name=ocelotgateway zhangdk/ocelotgateway

通過Ocelot網關服務訪問clientservice

image

直接訪問clientservice

image

4.6 F&Q

Ocelot服務發現地址怎麼配置

剛開始的我以為應該配置Leader server的地址,但是由於leader server的埠並沒有暴露,因此容器間無法訪問。嘗試使用client的地址,發現也是可以成功的。

Ocelot的服務發現地址配置

Consul在集群模式運行時,單個server或者client agent節點掛掉後仍然可以通過投票等協議正常運行。但是,Ocelot網關服務中配置了唯一的一個agent地址,那豈不是意味著這個節點掛掉後,Ocelot網關服務就和Consul集群的服務發現就失去了聯繫,那這裡的Consul集群有什麼意義?

5 總結

初步按照自己的思路搭建起來的服務發現,自動註冊的架構,後續會繼續完善許可權驗證、負載均衡等網關的其他功能。搭建的過程中也有許多困惑還沒有想明白,後續邊想邊做。微服務這一塊也是剛剛接觸,有什麼問題或錯誤,還希望各位前輩指正。


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

-Advertisement-
Play Games
更多相關文章
  • 遇到一種業務場景,前端上傳的文件需要經過java服務轉發至文件服務。期間遇到了原生HttpClient怎麼使用的問題、怎麼把MultipartFile怎麼重新組裝成Http請求發送出去的問題、文件中文名亂碼問題。最後都解決了,先上代碼,再講遇到的坑 特別說明及遇到的坑: 1. 這裡基於tomcat進 ...
  • 大佬的總結(大贊!) final可以修飾:屬性,方法,類,局部變數(方法中的變數) final修飾的屬性的初始化可以在編譯期,也可以在運行期,初始化後不能被改變。 final修飾的屬性跟具體對象有關,在運行期初始化的final屬性,不同對象可以有不同的值。 final修飾的屬性表明是一個常數(創建後 ...
  • 一, 繼承 繼承是一種創建新類的方式,在python中,新建的類可以繼承一個或多個父類,父類又可稱為 基類或超類,新建的類稱為派生類或子類 1. python中類的繼承分為:單繼承和多繼承 2. 查看繼承 提示:如果沒有指定基類,python的類會預設繼承object類,object是所有pytho ...
  • 對象操作流(序列化流) 每次讀取和寫出的都是JavaBean對象. 序列化:將對象寫入到文件中的過程 反序列化:從文件中讀取對象到程式的過程 transient: 標識瞬態,序列化的時候,該修飾符修飾的成員不能序列化 ObjectOutputStream 構造方法: public ObjectOut ...
  • 要想學習java語言,首先要搭建Java的開發環境,包括開發環境和運行環境,那就要下載jdk的安裝包來進行搭建了 下載地址:鏈接: https://pan.baidu.com/s/1msUuHYRfIjxyPnwZEksNRw 密碼: ssv4 首先我們先來瞭解一下JDK JDK:java deve ...
  • """關係型資料庫(SQL資料庫):MySQL、Oracle、Sqlite3、SQLServer...1.可以存儲統一格式的數據2.可以用於保存大量的數據3.表與表之間有關聯 非關係型數據(NoSQL資料庫):Mangodb、Redis....""" # 1.建立資料庫連接# connect() 若 ...
  • 1. 重新排列數列,使得數組左邊為奇數,右邊為偶數 空間複雜度O(1) 時間複雜度O(n) 思路:兩個指針分別指向數組的頭和尾,頭指針正向遍曆數組,找到第一個偶數 尾指針反向遍曆數組,找到第一個奇數,兩者交換 2. 如何找出數組中唯一的重覆元素 每個數組只能訪問一次,不能用輔助空間 數組a[n] 數 ...
  • 正如我們在《控制反轉》提到過的,很多人將IoC理解為一種“面向對象的設計模式”,實際上IoC自身不僅與面向對象沒有必然的聯繫,它也算不上是一種設計模式。一般來講,設計模式提供了一種解決某種具體問題的方案,但是IoC既沒有一個針對性的問題領域,其自身沒有提供一種可實施的解決方案,所以我更加傾向於將Io... ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...