服務註冊和發現（Consul）

来源:https://www.cnblogs.com/7788IT/archive/2019/04/07/10667032.html
-Advertisement-
Play Games

使用Consul提供註冊和發現服務 什麼是 Consul Consul 是 HashiCorp 公司推出的開源工具，用於實現分散式系統的服務發現與配置。與其它分散式服務註冊與發現的方案，Consul 的方案更“一站式”，內置了服務註冊與發現框架、分佈一致性協議實現、健康檢查、Key/Value 存儲 ...


使用Consul提供註冊和發現服務

什麼是 Consul

Consul 是 HashiCorp 公司推出的開源工具，用於實現分散式系統的服務發現與配置。與其它分散式服務註冊與發現的方案，Consul 的方案更“一站式”，內置了服務註冊與發現框架、分佈一致性協議實現、健康檢查、Key/Value 存儲、多數據中心方案，不再需要依賴其它工具（比如 ZooKeeper 等）。使用起來也較為簡單。Consul 使用 Go 語言編寫，因此具有天然可移植性(支持Linux、windows和Mac OS X)；安裝包僅包含一個可執行文件，方便部署，與 Docker 等輕量級容器可無縫配合。

Consul 安裝

訪問 Consul 官網 ，根據操作系統類型，選擇下載 Consul 的最新版本。我這裡選擇windows版本。

下載下來是一個zip壓縮包，解壓之後，是一個exe可執行文件。

 打開CMD終端，進入consul.exe所在目錄，執行如下命令啟動Consul服務。

cd C:\consul_1.3.0_windows_amd64　　# 進入consul.exe所在目錄

consul agent -dev        # 啟動服務, -dev 表示開發模式運行，另外還有 -server 表示服務模式運行

啟動過程信息如下圖所示。

啟動成功之後，訪問 http://localhost:8500 ， 可以查看 Consul 管理界面。

 

Consul 服務提供者

服務註冊發現中心有了，現在我們來開發服務提供者。

新建項目 spring-cloud-consul-producer，添加以下依賴。

pom.xml

複製代碼 
<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-actuator</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-consul-discovery</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
</dependencies>
複製代碼

說明：

spring-boot-starter-actuator 健康檢查依賴於此包。

spring-cloud-starter-consul-discovery Spring Cloud Consul 的支持。

註意添加Spring Cloud的依賴配置，完整內容參見源碼pom文件。

複製代碼 
　　<dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
複製代碼

添加配置

在配置文件添加內容如下。

application.yml

複製代碼 
server:
  port: 8511
spring:
  application:
    name: spring-cloud-consul-producer
  cloud:
    consul:
      host: localhost
      port: 8500
      discovery:
        serviceName: service-producer    # 註冊到consul的服務名稱
複製代碼

Consul 的地址和埠號預設是 localhost:8500 ，如果不是這個地址可以自行配置，consul服務會占用8502介面，所以不要用8501、8502。
spring.cloud.consul.discovery.serviceName 是指註冊到 Consul 的服務名稱，後期客戶端會根據這個名稱來進行服務調用。

修改啟動類

 修改啟動器類，添加 @EnableDiscoveryClient 註解，開啟服務發現支持。

複製代碼 
package com.louis.spring.cloud.consul.producer;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

@EnableDiscoveryClient
@SpringBootApplication
public class ConsuleProducerApplication {

    public static void main(String[] args) {
        SpringApplication.run(ConsuleProducerApplication.class, args);
    }
}
複製代碼

添加服務

新建 HelloController，提供 hello 介面， 返回 hello consul 字元串。

複製代碼 
package com.louis.spring.cloud.consul.producer.controller;

import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class HelloController {

    @RequestMapping("/hello")
    public String hello() {
        return "hello consul.";
    }
}
複製代碼

為了模擬註冊均衡負載，複製一份上面的項目，重命名為 spring-cloud-consul-producer2 ,修改對應的埠為 8512，修改 hello 方法的返回值為："helle consul two"，修改完成後依次啟動兩個項目，啟動成功之後刷新Consul管理界面，發現我們註冊的service-producer服務，並有2個節點實例。

點擊進入節點詳情頁面，可以看到我們註冊的8511和8512兩個服務提供者節點實例。

Consul 消費者

服務註冊發現中心有了，服務提供者也有了，現在我們來開發服務消費者。

新建項目 spring-cloud-consul-comsumer，依賴同提供者。

添加配置

修改配置文件如下。

application.yml

複製代碼 
server:
  port: 8521
spring:
  application:
    name: spring-cloud-consul-consumer
  cloud:
    consul:
      host: localhost
      port: 8500
      discovery:
        register: false    #設置不需要註冊到 consul 中
複製代碼

客戶端可以設置是否註冊到 Consul 中，具體需要根據我們的業務來選擇，一般在需要對外提供服務時進行註冊。

啟動器類

ConsuleConsumerApplication.java

複製代碼 
package com.louis.spring.cloud.consul.producer;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class ConsuleConsumerApplication {

    public static void main(String[] args) {
        SpringApplication.run(ConsuleConsumerApplication.class, args);
    }
}
複製代碼

服務消費者

添加消費服務測試類，添加兩個介面，一個查詢所有我們註冊的服務，另一個從我們註冊的服務中選取一個服務，採用輪詢的方式。

ServiceController.java

複製代碼 
package com.louis.spring.cloud.consul.producer.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.cloud.client.loadbalancer.LoadBalancerClient;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class ServiceController {

    @Autowired
    private LoadBalancerClient loadBalancerClient;
    @Autowired
    private DiscoveryClient discoveryClient;

   /**
     * 獲取所有服務
     */
    @RequestMapping("/services")
    public Object services() {
        return discoveryClient.getInstances("service-producer");
    }

    /**
     * 從所有服務中選擇一個服務（輪詢）
     */
    @RequestMapping("/discover")
    public Object discover() {
        return loadBalancerClient.choose("service-producer").getUri().toString();
    }
}
複製代碼

添加完成之後，啟動項目， 訪問 http://localhost:8521/services，返回兩個服務，分別是我們註冊的8511和8512。

複製代碼 
[{
    "serviceId": "service-producer",
    "host": "GG20J1G2E.logon.ds.ge.com",
    "port": 8511,
    "secure": false,
    "metadata": {
        "secure": "false"
    },
    "uri": "http://GG20J1G2E.logon.ds.ge.com:8511",
    "scheme": null
}, {
    "serviceId": "service-producer",
    "host": "GG20J1G2E.logon.ds.ge.com",
    "port": 8512,
    "secure": false,
    "metadata": {
        "secure": "false"
    },
    "uri": "http://GG20J1G2E.logon.ds.ge.com:8512",
    "scheme": null
}]
複製代碼

反覆訪問 http://localhost:8521/discover，結果交替返回服務8511和8512，因為預設的負載均衡器是採用輪詢的方式。

http://GG20J1G2E.logon.ds.ge.com:8511
http://GG20J1G2E.logon.ds.ge.com:8512
...

8511 和 8512 兩個服務會交替出現，從而實現了獲取服務端地址的均衡負載。

大多數情況下我們希望使用均衡負載的形式去獲取服務端提供的服務，因此使用第二種方法來模擬調用服務端提供的 hello 方法。

創建 CallHelloController.java

複製代碼 
package com.louis.spring.cloud.consul.producer.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.loadbalancer.LoadBalancerClient;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

@RestController
public class CallHelloController {

    @Autowired
    private LoadBalancerClient loadBalancer;

    @RequestMapping("/call")
    public String call() {
        ServiceInstance serviceInstance = loadBalancer.choose("service-producer");
        System.out.println("服務地址：" + serviceInstance.getUri());
        System.out.println("服務名稱：" + serviceInstance.getServiceId());

        String callServiceResult = new RestTemplate().getForObject(serviceInstance.getUri().toString() + "/hello", String.class);
        System.out.println(callServiceResult);
        return callServiceResult;
    }

}
複製代碼

使用 RestTemplate 進行遠程調用。添加完之後重啟 spring-cloud-consul-consumer 項目。

在瀏覽器中訪問地址：http://localhost:8521/call，依次返回結果如下：

helle consul
helle consul two
...

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

-Advertisement-
Play Games
更多相關文章
  • Java多線程
    什麼是多線程 利用對象，可將一個程式分割成相互獨立的區域。我們通常也需要將一個程式轉換成多個獨立運行的子任 務。象這樣的每個子任務都叫作一個“線程”（Thread）。編寫程式時，可將每個線程都想象成獨立運行，而且 都有自己的專用CPU。一些基礎機制實際會為我們自動分割CPU的時間。我們通常不必關心這 ...
  • 博弈論之SG函數
    Fibonacci again and again（http://acm.hdu.edu.cn/showproblem.php?pid=1848） Time Limit: 1000/1000 MS (Java/Others) Memory Limit: 32768/32768 K (Java/Oth ...
  • 如何閱讀jdk源碼？
    如何閱讀jdk源碼？ 1. 設定目標 2. 提出問題 3. 如何提出問題 4. 帶著問題閱讀源碼，忽略不必要的細節，死磕重要的細節 5. 多做比較 6. 多做實驗 7. 耐心&堅持 8. 彩蛋 ...
  • F#周報2019年第14期
    新聞 "發佈F 4.6" "SAFE Stack v1.0" "發佈fable編譯器2.2，Fable.Core 3及其它" "發佈ML.NET 1.0 RC" "Saturn：增加路由診斷頁面" "Visual Studio 2019：更快地編寫代碼，更智能地工作，創造未來" "Visual St ...
  • 紀念第一次寫博客
    2019 04 07 第一次寫博客就記錄最基礎的c語言下的利用迴圈 使用時間戳的猜數字游戲 vs 實現 #define _CRT_SECURE_NO_WARNINGS // vs 下的巨集定義 （scanf） #include<stdio.h> #include<stdlib.h> #include< ...
  • javaweb中上傳圖片並顯示圖片，用我要上傳課程信息（裡面包括照片）這個例子說明
    原理： 從客戶端上傳到伺服器 照片——文件夾——資料庫 例如：桌面一張照片，在tomacat里創建upload文件夾，把桌面照片上傳到upload文件夾里，並且把照片的名字取出來，取完名字把這個名字插入到資料庫裡面，下次要想取就取這個名字到upload文件夾下麵去尋找這個照片，找到以後寫相對路徑，就 ...
  • #leetcode刷題之路48-旋轉圖像
    給定一個 n × n 的二維矩陣表示一個圖像。將圖像順時針旋轉 90 度。說明：你必須在原地旋轉圖像，這意味著你需要直接修改輸入的二維矩陣。請不要使用另一個矩陣來旋轉圖像。示例 1:給定 matrix = [ [1,2,3], [4,5,6], [7,8,9]],原地旋轉輸入矩陣，使其變為:[ [7 ...
  • #leetcode刷題之路46-全排列
    給定一個沒有重覆數字的序列，返回其所有可能的全排列。示例:輸入: [1,2,3]輸出:[ [1,2,3], [1,3,2], [2,1,3], [2,3,1], [3,1,2], [3,2,1]] 兩種方法，第一種用了STL中的函數，第二種用遞歸+回溯，我個人很喜歡第二種方法 ...
一周排行
    -Advertisement-
    Play Games
  • C# + WPF 音頻播放器 界面優雅，體驗良好
    前言 本文介紹一款使用 C# 與 WPF 開發的音頻播放器，其界面簡潔大方，操作體驗流暢。該播放器支持多種音頻格式（如 MP4、WMA、OGG、FLAC 等），並具備標記、實時歌詞顯示等功能。 另外，還支持換膚及多語言（中英文）切換。核心音頻處理採用 FFmpeg 組件，獲得了廣泛認可，目前 Git ...
  • OAuth2.0授權-gitee授權碼模式
    OAuth2.0授權驗證-gitee授權碼模式 本文主要介紹如何筆者自己是如何使用gitee提供的OAuth2.0協議完成授權驗證並登錄到自己的系統，完整模式如圖 1、創建應用 打開gitee個人中心->第三方應用->創建應用 創建應用後在我的應用界面，查看已創建應用的Client ID和Clien ...
  • FastReport.OpenSource .Net下開源免費報表列印組件
    解決了這個問題：《winForm下，fastReport.net 從.net framework 升級到.net5遇到的錯誤“Operation is not supported on this platform.”》 本文內容轉載自：https://www.fcnsoft.com/Home/Sho ...
  • 如何在 ASP.NET Core Web API 方法執行前後 “偷偷“ 作一些 “壞“ 事？初識 ActionFilterAttribute
    國內文章 WPF 從裸 Win 32 的 WM_Pointer 消息獲取觸摸點繪製筆跡 https://www.cnblogs.com/lindexi/p/18390983 本文將告訴大家如何在 WPF 裡面，接收裸 Win 32 的 WM_Pointer 消息，從消息裡面獲取觸摸點信息，使用觸摸點 ...
  • 在 ASP.NET Core Web API 中使用異常篩選器捕獲和統一處理異常
    前言 給大家推薦一個專為新零售快消行業打造了一套高效的進銷存管理系統。 系統不僅具備強大的庫存管理功能，還集成了高性能的輕量級 POS 解決方案，確保頁面載入速度極快，提供良好的用戶體驗。 項目介紹 Dorisoy.POS 是一款基於 .NET 7 和 Angular 4 開發的新零售快消進銷存管理 ...
  • AbpHelper CLI積累與實戰分享
    ABP CLI常用的代碼分享 一、確保環境配置正確 安裝.NET CLI： ABP CLI是基於.NET Core或.NET 5/6/7等更高版本構建的，因此首先需要在你的開發環境中安裝.NET CLI。這可以通過訪問Microsoft官網下載並安裝相應版本的.NET SDK來實現。 安裝ABP ...
  • 記一次HttpClient使用問題分析
    問題 問題是這樣的：第三方的webapi，需要先調用登陸介面獲取Cookie，訪問其它介面時攜帶Cookie信息。 但使用HttpClient類調用登陸介面，返回的Headers中沒有找到Cookie信息。 分析 首先，使用Postman測試該登陸介面，正常返回Cookie信息，說明是HttpCli ...
  • .NET周刊【9月第3期 2024-09-15】
    國內文章 關於.NET在中國為什麼工資低的分析 https://www.cnblogs.com/thinkingmore/p/18406244 .NET在中國開發者的薪資偏低，主要因市場需求、技術棧選擇和企業文化等因素所致。歷史上，.NET曾因微軟的閉源策略發展受限，儘管後來推出了跨平臺的.NET ...
  • 我的網站集成ElasticSearch初體驗
    在WPF開發應用中，動畫不僅可以引起用戶的註意與興趣，而且還使軟體更加便於使用。前面幾篇文章講解了畫筆（Brush），形狀（Shape），幾何圖形（Geometry），變換（Transform）等相關內容，今天繼續講解動畫相關內容和知識點，僅供學習分享使用，如有不足之處，還請指正。 ...
  • 第23篇 委托的概述
    什麼是委托？ 委托可以說是把一個方法代入另一個方法執行，相當於指向函數的指針；事件就相當於保存委托的數組； 1.實例化委托的方式： 方式1：通過new創建實例： public delegate void ShowDelegate(); 或者 public delegate string ShowDe ...
所有分類