微服務系列-基於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
  • Autofac高級應用，一個介面多個實現類如何註冊到容器並獲取實例
    當使用Autofac處理一個介面有多個實現的情況時，通常會使用鍵（key）進行區分或者通過IIndex索引註入，也可以通過IEnumerable集合獲取所有實例，以下是一個具體的例子，演示如何在Autofac中註冊多個實現，並通過構造函數註入獲取指定實現。 首先，確保你已經安裝了Autofac Nu ...
  • Prometheus+Grafana 監控平臺實踐-搭建&常用服務監控&告警
    本篇將分享Prometheus+Grafana的監控平臺搭建，並監控之前文章所搭建的主機&服務，分享日常使用的一些使用經驗本篇將配置常用服務的監控與面板配置：包括 MySQL,MongoDB,CLickHouse,Redis,RabbitMQ,Linux,Windows,Nginx,站點訪問監控，已... ...
  • 將 .NET Aspire 部署到 Kubernetes 集群
    使用Aspirate可以將Aspire程式部署到Kubernetes 集群 工具安裝 dotnet tool install -g aspirate --prerelease 註意：Aspirate 正在開發中，該軟體包將作為預覽版進行版本控制，--prelease 選項將獲得最新的預覽版。 容器註 ...
  • 漸進式web全棧：blazor web app
    前言 本文要說的這種開發模式，這種模式並不是只有blazor支持，js中有一樣的方案next.js nuxt.js；blazor還有很多其它內容，本文近關註漸進式開發模式。 是的，前後端是主流，不過以下情況也許前後端分離並不是最好的選擇： 小公司，人員不多，利潤不高，創業階段能省則省 個人開發者，接 ...
  • C#從字元串中提取固定步長的子字元串
    在.NET中，Microsoft.Extensions.Logging是一個靈活的日誌庫，它允許你將日誌信息記錄到各種不同的目標，包括資料庫。在這個示例中，我將詳細介紹如何使用Microsoft.Extensions.Logging將日誌保存到MySQL資料庫。我們將使用Entity Framewo ...
  • chatgpt介面開發筆記3: 語音識別介面
    chatgpt介面開發筆記3: 語音識別介面 1.文本轉語音 1、瞭解介面參數 介面地址： POST https://api.openai.com/v1/audio/speech 下麵是介面文檔描述內容： 參數： { "model": "tts-1", "input": "你好，我是饒坤，我是ter ...
  • c# 高併發必備技巧（三）
    前面兩篇文章主要是介紹瞭如何解決高併發情況下資源爭奪的問題。但是現實的應用場景中除了要解決資源爭奪問題，高併發的情況還需要解決更多問題，比如快速處理業務數據等， 本篇文章簡要羅列一下與之相關的更多技術細節。 1、非同步編程：使用async和await關鍵字進行非同步編程，這可以避免阻塞線程，提高程式的響 ...
  • 面向對象程式設計第三次bolg
    大家好，我是棧長。 Nacos 2.3.0 前幾天正式發佈了，新增了不少實用性的新功能，真是史上最強版本。 Nacos 2.3.0 還真是一個比較重要的大版本，因為它涉及了太多重大更新，今天棧長給大家來解讀下。 Nacos 先掃個盲： Nacos 一個用於構建雲原生應用的動態服務發現、配置管理和服務 ...
  • IntelliJ IDEA無公網遠程Linux伺服器環境開發(建議收藏!)
    IDEA的遠程開發功能，可以將本地的編譯、構建、調試、運行等工作都放在遠程伺服器上執行，而本地僅運行客戶端軟體進行常規的開發操作即可,舊版本IDEA目前不支持該功能.,本例使用的是IDEA2023.2.5版本 下麵介紹如何在IDEA中設置遠程連接伺服器開發環境並結合Cpolar內網穿透工具實現無公網 ...
  • 數據結構【動態數組】
    本文解釋為啥會有響應式編程，為什麼它在開發者中不太受歡迎，以及引入 Java 虛擬線程後它可能最終會消失。 命令式風格編程一直深受開發者喜愛，如 if-then-else、while 迴圈、函數和代碼塊等結構使代碼易理解、調試，異常易追蹤。然而，像所有好的東西一樣，通常也有問題。這種編程風格導致線程 ...
所有分類