首页 > 其他分享 >微服务系列-基于Spring Cloud Eureka进行服务的注册与消费

微服务系列-基于Spring Cloud Eureka进行服务的注册与消费

时间：2023-11-16 13:55:04浏览次数：35  
标签：服务 Spring springframework eureka Cloud Eureka cloud

公众号「架构成长指南」，专注于生产实践、云原生、分布式系统、大数据技术分享。

在之前的几个教程中，我们学了：

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

标签：服务,Spring,springframework,eureka,Cloud,Eureka,cloud
From： https://www.cnblogs.com/waldron/p/17836044.html

相关文章

  • Spring5学习随笔-IOC（反转控制）、DI（依赖注入）和创建复杂对象
    学习视频：【孙哥说Spring5：从设计模式到基本应用到应用级底层分析，一次深入浅出的Spring全探索。学不会Spring？只因你未遇见孙哥】第七章、反转控制与依赖注入1.反转(转移)控制（IOCinverseofControl）控制：对于成员变量赋值的控制权反转控制：把对于成员变量赋值的控制权，从代码......
  • springboot大文件上传、分片上传、断点续传、秒传的实现
    本篇攻略将详细介绍如何使用SpringBoot实现大文件上传、分片上传、断点续传和秒传功能。为方便阅读，本文将分为以下几个部分：介绍大文件上传、分片上传、断点续传和秒传的概念详细分析如何实现大文件上传、分片上传、断点续传和秒传功能给出两个示例来说明如何实现大文件上传和......
  • SpringBoot
    一、简介SpringBoot是Spring公司的一个顶级项目，和SpringFramework是一个级别的。不需要编写xml配置文件，通过利用pringFramework4自动配置特性完成配置。启动器就是引入相关的依赖，通过java配置的方式完成自动配置。1.特征使用SpringBoot可以创建独立的Spring应......
  • day130-springboot的各种配置与应用
    编写springboot应用看官方文档DevelopingwithSpringBoot查看场景依赖，引入对应自动配置的场景，编写配置文件中debug=true开启自动配置报告。Negative（不生效）Positive（生效）Lombok的应用Lombok用标签方式代替构造器、getter/setter、toString()等鸡肋代码。引入依赖......
  • SpringBean生命周期之PostConstruct、PreDestroy详解
    @PostConstruct less复制代码@Documented@Retention(RUNTIME)@Target(METHOD)public@interfacePostConstruct{}该注解只能作用于方法上，执行依赖注入后执行任何初始化操作。必须在类投入服务之前调用此方法。应用PostConstruct的方法可以是公共的、受保护的......
  • JDBC、数据库连接池、Spring JDBC：JdbcTemplate
    JDBCJDBC（JavaDataBaseConnectivity）概念：Java数据库连接，就是通过Java语言操作数据库。JDBC本质：其实是官方（sun公司）定义的一套操作所有关系型数据库的规则，即接口。各个数据库厂商去实现这套接口，提供数据库驱动jar包。我们可以使用这套接口（JDBC）编程，真正执行的代码是驱动jar包中的实......
  • SpringBoot模拟插入1000000万条数据
    一、数据库表准备CREATETABLE`student`(`id`bigintNOTNULLCOMMENT'用户id',`name`varchar(50)COLLATEutf8mb4_general_ciDEFAULTNULLCOMMENT'姓名',`address`varchar(250)COLLATEutf8mb4_general_ciDEFAULTNULLCOMMENT'地址'......
  • springboot~ConfigurableListableBeanFactory和ApplicationContext的使用场景
    在工具类中封装getBean，使用哪个接口来实现实事上，在工具类中，实现BeanFactoryPostProcessor和ApplicationContextAware接口后，使用它们构造方法里的对象ConfigurableListableBeanFactory和ApplicationContext都可以很方便的获取spring容器里的bean，而在实际应用时，还有有些不同的，比如在......
  • SpringBoot 配置文件内容加密
    1.引入pom<dependency><groupId>com.github.ulisesbocchio</groupId><artifactId>jasypt-spring-boot-starter</artifactId><version>3.0.3</version>......
  • SpringBoot和mybatisPlus得核心知识点
    SpringBoot自动配置（Auto-Configuration）：SpringBoot核心特性之一是自动配置。它尝试根据项目的依赖和内容推断应用程序应该如何配置。这简化了开发人员的工作，因为他们无需手动配置大量的设置。起步依赖（StarterDependencies）：SpringBoot提供了一系列预配置的依赖项，称为“起......

赞助商

阅读排行

网站主页关于我们联系我们网站地图

本网站内容转载自其他媒体，侵权联系[admin##ips99.com]。

Copyright © 2020-2023 IPS99 版权所有 IPS99