微服務系列-基於Spring Cloud Eureka進行服務的註冊與消費

来源:https://www.cnblogs.com/waldron/archive/2023/11/16/17836044.html
-Advertisement-
Play Games

公眾號「架構成長指南」，專註於生產實踐、雲原生、分散式系統、大數據技術分享。 在之前的幾個教程中，我們學了： 使用 RestTemplate 的 Spring Boot 微服務通信示例 使用 WebClient 的 Spring Boot 微服務通信示例 使用 Spring Cloud Open F ...


公眾號「架構成長指南」，專註於生產實踐、雲原生、分散式系統、大數據技術分享。

在之前的幾個教程中，我們學了：

使用 RestTemplate 的 Spring Boot 微服務通信示例

使用 WebClient 的 Spring Boot 微服務通信示例

使用 Spring Cloud Open Feign 的 Spring Boot 微服務通信示例

在本教程中，我們將學習如何在Spring boot微服務項目中使用Spring Cloud Eureka進行服務註冊與消費

服務註冊和發現概述

在微服務項目中，我們一般會對一個項目，以業務的維度拆分至多個服務，比如用戶服務、賬務服務、訂單服務、倉儲服務等，這些服務在生產環境部署，
至少是2個服務實例，如果業務量大幾十個都是有可能的。

試想這樣一種場景

訂單服務實例部署了4個，倉庫服務部署了5個，倉庫服務要調用訂單服務，如果沒有註冊中心，他會怎麼做，那隻有把對應的ip和埠寫死在代碼中，如果新增了一個訂單服務怎麼辦？或者下線了訂單服務怎麼辦？

另外，在雲環境中，服務實例隨時都有可能啟動和關閉，隨之IP也會發生變化，沒法把IP寫死在代碼中。

基於以上問題就有了服務註冊中心Eureka

Eureka能實現服務自動的註冊和發現，在每次服務調用的時候根據服務名稱會獲取到目標服務的IP和埠，在進行調用。

如果服務下線或者上線，對應的服務的地址信息也會進行更新，這樣就保證了，隨時可以調用到有效的服務。

同時為了提高性能，這個服務地址信息會在每個服務本地緩存一份地址信息表，定時更新，這樣每次請求服務時，不用每次去Eureka查詢來降低服務調用耗時。

在本教程中，我們將學習如何使用SpringCloud Eureka進行服務註冊和發現，並通過OpenFeign進行服務的調用。

我們將做什麼

我們部署一個Eureka Server，並將我們的微服務（部門服務和用戶服務）作為 Eureka 客戶端，註冊到Eureka Server，同時使用用戶服務調用根據部門服務的Service ID 來調用部門服務相關介面。

創建Eureka Server

1. 在 IntelliJ IDEA 中創建並設置 Spring boot 項目

讓我們使用 springinitializr創建一個 Spring boot 項目。
請參閱下麵的屏幕截圖，在使用 springinitializr創建 Spring Boot 應用程式時輸入詳細信息 ：

單擊生成按鈕以 zip 文件形式下載 Spring boot 項目。解壓zip文件併在IntelliJ IDEA中導入Spring boot項目。
這是 pom.xml 文件供參考：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
	<modelVersion>4.0.0</modelVersion>
	<parent>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-parent</artifactId>
		<version>2.7.17</version>
		<relativePath/> <!-- lookup parent from repository -->
	</parent>
	<groupId>io.wz</groupId>
	<artifactId>eureka-server</artifactId>
	<version>0.0.1-SNAPSHOT</version>
	<name>eureka-server</name>
	<description>eureka-server</description>
	<properties>
		<java.version>1.8</java.version>
		<spring-cloud.version>2021.0.8</spring-cloud.version>
	</properties>
	<dependencies>
		<dependency>
			<groupId>org.springframework.cloud</groupId>
			<artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
		</dependency>

		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-test</artifactId>
			<scope>test</scope>
		</dependency>
	</dependencies>
	<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>

	<build>
		<plugins>
			<plugin>
				<groupId>org.springframework.boot</groupId>
				<artifactId>spring-boot-maven-plugin</artifactId>
				<configuration>
					<image>
						<builder>paketobuildpacks/builder-jammy-base:latest</builder>
					</image>
				</configuration>
			</plugin>
		</plugins>
	</build>

</project>

2.添加@EnableEurekaServer註解

我們需要添加@EnableEurekaServer註解，使我們應用程式成為服務註冊中心。

package io.wz.eurekaserver;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;

@SpringBootApplication
@EnableEurekaServer
public class EurekaServerApplication {

	public static void main(String[] args) {
		SpringApplication.run(EurekaServerApplication.class, args);
	}

}

3. 禁用Eureka Server作為Eureka Client

預設情況下，每個Eureka Server 也是一個Eureka客戶端。由於我們只想讓他做好服務註冊中心，不想讓他做客戶端，因此我們將通過在application.properties文件中配置以下屬性來禁用此客戶端行為。

spring.application.name=Eureka Server
server.port=8761
eureka.client.register-with-eureka=false
eureka.client.fetch-registry=false

4.啟動Eureka伺服器

Eureka Server 提供了 UI，我們可以在其中看到有關註冊服務的所有詳細信息。
現在運行EurekaServerApplication並訪問 http://localhost:8761，會顯示以下界面

將Department-Service註冊至Eureka Server

請參閱本教程創建 部門服務 和 用戶服務 微服務： 使用 Spring Cloud Open Feign 的 Spring Boot 微服務通信示例

讓我們將這個部門服務 作為 Eureka 客戶端並向 Eureka 伺服器註冊。
將 Eureka client pom添加到部門服務中：

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

另外，添加 Spring Cloud 依賴項：

	<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>

添加版本屬性：

	<properties>
		<java.version>1.8</java.version>
		<spring-cloud.version>2021.0.4</spring-cloud.version>
	</properties>

在application.properties中配置eureka.client.service-url.defaultZone 屬性 即可自動註冊到 Eureka Server。

spring.application.name=DEPARTMENT-SERVICE
eureka.instance.client.serviceUrl.defaultZone=http://localhost:8761/eureka/

運行部門服務Eureka客戶端

完成此配置後，啟動Department-service並訪問 http://localhost:8761。
看到部門服務已使用 SERVICE ID 註冊為 DEPARTMENT-SERVICE,註意到狀態為 UP(1)，這意味著服務已啟動並正在運行，並且部門服務的一個實例正在運行。

將User-Service微服務註冊為Eureka客戶端

添加以下依賴

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

在application.properties中配置eureka.client.service-url.defaultZone 屬性 即可自動註冊到 Eureka Server。

spring.application.name=USER-SERVICE
eureka.instance.client.serviceUrl.defaultZone=http://localhost:8761/eureka/

當服務註冊到 Eureka Server 時，它會在一定的時間間隔內不斷發送心跳。如果 Eureka 伺服器沒有收到來自任何服務實例的心跳，它將假定該服務實例已關閉並將其從池中取出

修改user-service的ApiClient

在上一節中中，我們使用APIClient完成了進行服務調用，但是是寫了部門服務的url

@FeignClient(value = "DEPARTMENT-SERVICE", url = "http://localhost:8080")

這次我們修改如下,去除url屬性

@FeignClient(value = "DEPARTMENT-SERVICE")

完整api如下

package io.wz.userservice.service;

import io.wz.userservice.dto.DepartmentDto;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;

@FeignClient(value = "DEPARTMENT-SERVICE")
public interface APIClient {
    @GetMapping(value = "/api/departments/{id}")
    DepartmentDto getDepartmentById(@PathVariable("id") String departmentId);
}

運行用戶服務Eureka客戶端

以上配置後，啟動 user-service 並訪問http://localhost:8761。看到user-service已使用 SERVICE ID 註冊為USER-SERVICE。
您還可以註意到狀態為 UP(1)，這意味著服務已啟動並正在運行，並且用戶服務的一個實例正在運行。

測試

增加測試日誌

在部門服務的DepartmentServiceImpl的getDepartmentById方法增加調試日誌,如果調用到此介面，會列印getDepartment By Id

    @Override
    public Department getDepartmentById(Long departmentId) {
        log.info("getDepartment By Id:{} ",departmentId);
        return departmentRepository.findById(departmentId).get();
    }

啟動2個Department-Service

1. 啟動一個8082的部門服務

在idea中複製DepartmentServiceApplication配置，同時在啟動參數指定應用埠 -Dserver.port=8082


2. 啟動預設的部門服務，埠為8080

以上2個部門服務啟動完成，會在eureka看到2個部門服務

點擊獲取用戶 REST API進行測試

多點擊幾次，會看到2個部門服務控制台都會列印，getDepartment By Id:1，這裡使用的是Spring Cloud LoadBalancer提供的輪訓演算法

結論

在本教程中，我們學習瞭如何在 Spring boot 微服務項目中使用Eureka來進行服務的註冊與發現，同時基於Feign進行服務的調用，但是這裡還有遺留問題，如

  • 啟動服務以後需要多久才會被消費方查詢到地址?
  • 如果要做服務更新，如何讓消費無感知，感受不到服務再重啟?
  • 如何讓調用方知道調用的是提供方多個實例中具體哪一個服務實例？

以上問題後續文章解答，請關註此公眾號。

源碼下載：
github
gitee


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

-Advertisement-
Play Games
更多相關文章
  • 【C++】【圖像處理】形態學處理（腐蝕、膨脹）演算法解析（以.raw格式的圖像為基礎進行圖像處理、gray levels：256）
    1 void erosion(BYTE* image, int w, int h, BYTE* outImg) 2 { 3 int rept; 4 //腐蝕 5 memcpy(outImg, image, sizeof(BYTE) * w * h); //將讀取的圖像賦值給outImg，方便進行腐蝕 ...
  • 一鍵整合,萬用萬靈,Python3.10項目嵌入式一鍵整合包的製作(Embed)
    我們知道Python是一門解釋型語言，項目運行時需要依賴Python解釋器，並且有時候需要安裝項目中對應的三方依賴庫。對於專業的Python開發者來說，可以直接通過pip命令進行安裝即可。但是如果是分發給其他的Windows用戶，特別是不熟悉Python的人來說，這樣過於繁瑣。因此最好的辦法是連同P... ...
  • JUC併發編程（終章）各種鎖的理解
    各種鎖的理解 公平鎖、非公平鎖 公平鎖：先到先得（不可插隊） 非公平鎖：達者為先（可插隊） >預設 public ReentrantLock() { //預設非公平鎖 sync = new NonfairSync(); } //重載的構造方法，通過fair控制是否公平 public Reentran ...
  • Mybatis和其他主流框架的整合使用
    Mybatis簡介 MyBatis歷史 MyBatis最初是Apache的一個開源項目iBatis, 2010年6月這個項目由Apache Software Foundation遷移到了Google Code。隨著開發團隊轉投Google Code旗下，iBatis3.x正式更名為MyBatis。代 ...
  • Python實用技巧：將 Excel轉為PDF
    將Excel文件轉換為PDF可以方便儲存表格數據，此外在列印或共用文檔時也能確保表格樣式佈局等在不同設備和操作系統上保持一致。今天給大家分享一個使用第三方Python庫Spire.XLS for Python 實現Excel轉PDF的簡單方法。 Python中Excel轉PDF的實現步驟 1. 首先 ...
  • golang map
    golang 的 map 使用的是 hash map 基本結構 下麵截取自源碼，已翻譯 // runtime/map.go:117 // go map 定義,hashmap 縮寫 type hmap struct { count int // map 里文件數 flags uint8 // map ...
  • 二叉樹初步理解
    二叉樹初步： 代碼如下，註釋很詳細。 #define _CRT_SECURE_NO_WARNINGS #include <iostream> #include <cstring> #include <stdlib.h> #include <stdio.h> #include <math.h> #in ...
  • 如何用Java設計自動售貨機?
    如何用Java設計自動售貨機?是大多在高級Java開發人員面試中經常被問到的好問題之一。在典型的編碼面試中,你會得到一個問題描述來開發一個售貨機,在有限的時間內,通常2到3小時內,你需要在Java中編寫設計文檔、工作代碼和單元測試。這種Java面試的一個關鍵優勢是可以一次測試候選人的許多基本技能。為 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 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 ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類