微服務系列-基於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 微服務框架
    前言 微服務架構已經成為搭建高效、可擴展系統的關鍵技術之一，然而，現有許多微服務框架往往過於複雜，使得我們普通開發者難以快速上手並體驗到微服務帶了的便利。為瞭解決這一問題，於是作者精心打造了一款最接地氣的 .NET 微服務框架，幫助我們輕鬆構建和管理微服務應用。 本框架不僅支持 Consul 服務註 ...
  • 基於surging的木舟IOT平臺如何添加網路組件
    先看一下效果吧: 如果不會寫動畫或者懶得寫動畫，就直接交給Blend來做吧; 其實Blend操作起來很簡單，有點類似於在操作PS，我們只需要設置關鍵幀，滑鼠點來點去就可以了，Blend會自動幫我們生成我們想要的動畫效果. 第一步：要創建一個空的WPF項目 第二步：右鍵我們的項目，在最下方有一個，在B ...
  • Prism:框架介紹與安裝
    Prism:框架介紹與安裝 什麼是Prism? Prism是一個用於在 WPF、Xamarin Form、Uno 平臺和 WinUI 中構建鬆散耦合、可維護和可測試的 XAML 應用程式框架 Github https://github.com/PrismLibrary/Prism NuGet htt ...
  • 不可不知的WPF畫筆（Brush）
    在WPF中，屏幕上的所有內容，都是通過畫筆（Brush）畫上去的。如按鈕的背景色，邊框，文本框的前景和形狀填充。藉助畫筆，可以繪製頁面上的所有UI對象。不同畫筆具有不同類型的輸出（ 如：某些畫筆使用純色繪製區域，其他畫筆使用漸變、圖案、圖像或繪圖）。 ...
  • .NET 8 高併發微服務電商系統實戰
    前言 嗨，大家好！推薦一個基於 .NET 8 的高併發微服務電商系統，涵蓋了商品、訂單、會員、服務、財務等50多種實用功能。 項目不僅使用了 .NET 8 的最新特性，還集成了AutoFac、DotLiquid、HangFire、Nlog、Jwt、LayUIAdmin、SqlSugar、MySQL、 ...
  • 基於surging 如何利用peerjs進行語音視頻通話
    本文主要介紹攝像頭（相機）如何採集數據，用於類似攝像頭本地顯示軟體，以及流媒體數據傳輸場景如傳屏、視訊會議等。 攝像頭採集有多種方案，如AForge.NET、WPFMediaKit、OpenCvSharp、EmguCv、DirectShow.NET、MediaCaptre（UWP），網上一些文章以及 ...
  • [WPF]數據綁定時為何會出現StringFormat失效
    前言 Seal-Report 是一款.NET 開源報表工具，擁有 1.4K Star。它提供了一個完整的框架，使用 C# 編寫，最新的版本採用的是 .NET 8.0 。 它能夠高效地從各種資料庫或 NoSQL 數據源生成日常報表，並支持執行複雜的報表任務。 其簡單易用的安裝過程和直觀的設計界面，我們 ...
  • NET Core 多身份校驗與策略模式
    背景需求： 系統需要對接到XXX官方的API，但因此官方對接以及管理都十分嚴格。而本人部門的系統中包含諸多子系統，系統間為了穩定，程式間多數固定Token+特殊驗證進行調用，且後期還要提供給其他兄弟部門系統共同調用。 原則上：每套系統都必須單獨接入到官方，但官方的接入複雜，還要官方指定機構認證的證書 ...
  • C#自定義控制項—轉換開關
    本文介紹下電腦設備關機的情況下如何通過網路喚醒設備，之前電源S狀態 電腦Power電源狀態- 唐宋元明清2188 - 博客園 (cnblogs.com) 有介紹過遠程喚醒設備，後面這倆天瞭解多了點所以單獨加個隨筆 設備關機的情況下，使用網路喚醒的前提條件： 1. 被喚醒設備需要支持這WakeOnL ...
  • .NET 8.0 前後分離快速開發框架
    前言 大家好，推薦一個.NET 8.0 為核心，結合前端 Vue 框架，實現了前後端完全分離的設計理念。它不僅提供了強大的基礎功能支持，如許可權管理、代碼生成器等，還通過採用主流技術和最佳實踐，顯著降低了開發難度，加快了項目交付速度。 如果你需要一個高效的開發解決方案，本框架能幫助大家輕鬆應對挑戰，實 ...
所有分類