SpringCloud之一注册中心（Eureka）

2024-08-24 06:36
文章标签 java spring 注册 springcloud 中心 eureka

本文主要是介绍SpringCloud之一注册中心（Eureka），希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

一、Eureka概述

Eureka是Netflix公司开源的一个服务注册与发现的中间组件。
在微服务架构系统之中，我们经常提三个角色：注册中心 (Register)、服务提供者(Provider)、服务消费者(Consumer)。
1.注册中心：服务提供者可以将服务发布到注册中心，服务消费者从注册中心获取可以进行访问的服务列表;注册中心支持集群部署，集群中的机器，数据会进行同步复制更新(replicate)，保证注册中心数据最终一致性。
2.服务提供者： 即下游相关的平台或者是提供服务的应用，对于自己的应用服务(Application Service)，做下面的操作：

  1.服务注册：将自己的服务接口方法以及服务发布的地址等，注册到Eureka Server注册中心中；2.服务更新：对已经发布到注册中心的服务通知进行更新操作;3.服务删除:通过相关操作(如停止应用操作)通知注册中心，将应用服务从注册中心删除(移除);4.服务发布者通过Eureka这个注册中心，每30秒发送一次心跳更新注册中心的数据;

服务消费者： 在应用启动的时候，根据自己订阅的服务，会去注册中心(Eureka Server)拉取所有的服务清单列表，会缓存到应用本地缓存。

二、创建注册中心

下面就使用spring-cloud-starter-netflix-eureka来创建一个服务注册中心
1.创建一个spring boot项目，添加以下依赖：
主要是引入下面这个：

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

有的项目引入的是：

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

pom.xml原始内容：

    <properties><spring-cloud.version>Hoxton.SR6</spring-cloud.version></properties><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-server</artifactId></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>

注：Spring boot版本要和spring-cloud版本相对应
注：spring-cloud-starter-eureka-server 是在1.5版本中使用的，在2.0版本中废弃，建议使用spring-cloud-starter-netflix-eureka-server

2.配置application.properties

#eureka服务端口号
server.port=8000
#eureka的服务名称
spring.application.name=eureka-server 
#表示是否将自己注册到Eureka Server，默认为true。由于当前这个应用就是Eureka Server，故而设为false。
eureka.client.registerWithEureka=false
#表示是否从Eureka Server获取注册信息，默认为true。因为这是一个单点的Eureka Server，不需要同步其他的Eureka Server节点的数据，故而设为false。
eureka.client.fetchRegistry=false
#eureka的地址信息
eureka.client.serviceUrl.defaultZone=http://localhost:${server.port}/eureka/:${server.port}/eureka/

3.在启动类上添加@EnableEurekaServer注解，就可以将该项目作为SpringCloud中的注册中心了。

@SpringBootApplication
@EnableEurekaServer
public class SpringCloudDemoApplication {public static void main(String[] args) {SpringApplication.run(SpringCloudDemoApplication.class, args);}}

4.启动注册中心
启动项目，这里设置了端口号为8000（根据自己的端口号来访问），访问http://localhost:8000，看到下面的页面，说明注册中心搭建完成：
在这里插入图片描述
Eureka注册中心UI界面参数：

Environment: 环境，默认为test，该参数在实际使用过程中，可以不用更改
Data center： 数据中心，使用的是默认的是 “default”
Current time：当前的系统时间
Uptime：已经运行了多少时间
Lease expiration enabled：是否启用租约过期 ，自我保护机制关闭时，该值默认是true， 自我保护机制开启之后为false。
Renews threshold： 每分钟最少续约数，Eureka Server 期望每分钟收到客户端实例续约的总数。
Renews (last min)： 最后一分钟的续约数量（不含当前，1分钟更新一次），Eureka Server 最后 1 分钟收到客户端实例续约的总数。

DS Replicas（注册到Eureka的实例信息）
Instances currently registered with Eureka：表示当前在Eureka注册的实例，因为现在还没有实例注册到eureka，所以显示为No instances available（没有可用的实例）

Instances currently registered with Eureka下的选项：

  • Application：实例名称，即spring.application.name或者eureka.instance.appname配置的名称，同时配置时，eureka.instance.appname优先级更高。
    如果没有配置eureka.instance.appname，则使用spring.application.name的值，如果连spring.application.name都没有配置，则取unknown。
  • AMIs：n/a (1)，字符串n/a+实例的数量
  • Availability Zones：实例的数量
  • Status：实例的状态加id，up为正常。id为eureka.instance.instance-id设置的值，如果没有设置eureka.instance.instance-id，那么显示的值将是一个由Eureka自动生成的编号

实例的状态分为UP、DOWN、STARTING、OUT_OF_SERVICE、UNKNOWN.

  • UP： 服务正常运行，特殊情况当进入自我保护模式，所有的服务依然是UP状态，所以需要做好熔断重试等容错机制应对灾难性网络出错情况
  • OUT_OF_SERVICE : 不再提供服务，其他的Eureka Client将调用不到该服务，一般有人为的调用接口设置的，如：强制下线。
  • UNKNOWN： 未知状态
  • STARTING ： 表示服务正在启动中
  • DOWN： 表示服务已经宕机，无法继续提供服务
    自我保护模式
    当微服务客户端启动后，会把自身信息注册到Eureka注册中心，以供其他微服务进行调用。一般情况下，当某个服务不可用时（一段时间内没有检测到心跳或者连接超时等），那么Eureka注册中心就会将该服务从可用服务列表中剔除，但是在微服务架构中，因为服务数量众多，可能存在跨机房或者跨区域的情况，因此当某个服务心跳探测失败并不能完全说明其无法正常提供服务而将其剔除，并且服务一旦剔除后，再重新注册将会重新进行负载均衡等等一系列的操作，考虑到性能问题，eureka会将不可用的服务暂时断开，并期望能够在接下来一段时间内接收到心跳信号，而不是直接剔除，同时，新来的请求将不会分发给暂停服务的实例，这就是eureka的保护机制，它保护了因网络等问题造成的短暂的服务不可用的实例，避免频繁注册服务对整个系统造成影响。
    我们在单机测试的时候很容易满足心跳失败比例在 15 分钟之内低于 85%，这个时候就会触发 Eureka 的保护机制，所以单机状态下不建议开启。们可以使用eureka.server.enable-self-preservation=false来关闭保护机制，这样可以确保注册中心中不可用的实例被及时的剔除(不推荐)。

5.eureka-server启动后，开始服务注册（将user-service服务注册到EurekaServer）
（1）在user-service（服务提供者）项目引入spring-cloud-starter-netflix-eureka-client依赖

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

（2）在原有application.properties添加如下配置：

# eureka服务的地址信息
eureka.client.serviceUrl.defaultZone=http://localhost:8000/eureka/
# 该配置非必须，状态页面的URL，即在eureka UI界面点击某个服务的状态跳转的链接，相对路径，默认使用 HTTP 访问，如需使用 HTTPS则要使用绝对路径配置，缺省：/info，下面配置的是user-service项目swagger-ui页面
eureka.instance.status-page-url-path = http://localhost:${server.port}/userservice/swagger-ui.html

启动user-service项目，可以在eureka UI界面看到服务已经注册
6.将order-service注册到注册中心
order-service（服务消费者）注册到注册中心的方法同上。
服务消费者通常使用Feign调用服务提供者提供的服务，使用Feign的步骤如下：
（1）引入依赖：

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>

（2）在order-service的启动类添加注解开启Feign功能：

@MapperScan("cn.itcast.order.mapper")
@SpringBootApplication
@EnableFeignClients
public class OrderApplication {public static void main(String[] args) {SpringApplication.run(OrderApplication.class, args);}
}

（3）编写Feign客户端：

/*** feign实现远程调用声明的bean*/
@FeignClient("user-service")
public interface UserClient {@GetMapping("/user/{id}")User findById(@PathVariable("id") Long id);
}

主要是基于SpringMVC的注解来声明远程调用信息，比如：

服务名称：user-service
请求方式：GET
请求路径：/user/{id}
请求参数：Long id
返回值类型：User
（4）则OrderService或OrderServiceImpl中方法改写为：

@Service
public class OrderService {@Autowiredprivate OrderMapper orderMapper;@Autowiredprivate UserClient userClient;public Order queryOrderById(Long orderId) {//1.查询订单Order order = orderMapper.findById(orderId);//2.用Feign远程调用User user = userClient.findById(order.getUserId());//3.封装user到Orderorder.setUser(user);//4.返回return order;}
}

@FeignClient注解参数说明

  • name/value：指定FeignClient的名称（调用的服务的名称），如果项目使用了Ribbon，name属性会作为微服务的名称，用于服务发现
  • contextId：用于指定为当前 Feign 客户端创建的 ApplicationContext 的唯一标识。当一个微服务中存在多个FeignClient接口调用同一个服务提供者时，就需要使用到contextId属性。这种情况常常出现在一个微服务需要调用另一个微服务提供的多个不同接口时。通过给每个FeignClient指定唯一的contextId，可以确保它们在运行时能够正确地识别和区分彼此，避免出现冲突和混淆。
  • url: url一般用于调试，可以手动指定@FeignClient调用的地址
  • decode404:当发生http 404错误时，如果该字段位true，会调用decoder进行解码，否则抛出FeignException
  • configuration: Feign配置类，可以自定义Feign的Encoder、Decoder、LogLevel、Contract
  • fallback: 定义容错的处理类，当调用远程接口失败或超时时，会调用对应接口的容错逻辑，fallback指定的类必须实现@FeignClient标记的接口
  • fallbackFactory: 工厂类，用于生成fallback类示例，通过这个属性我们可以实现每个接口通用的容错逻辑，减少重复的代码
  • path: 定义当前FeignClient的统一前缀，定义之后FeignClien的@RequestMapping中就不用写前缀了

上面的UserClient也可改为

/*** feign实现远程调用声明的bean*/
@FeignClient(name ="user-service",path="/user",contextId = "userService1")
public interface UserClient {@GetMapping("/{id}")User findById(@PathVariable("id") Long id);

此时通过order-service调用user-service就实现了远程调用，因为Feifn内部自带Ribbon，因此也同时实现了负载均衡。

这篇关于SpringCloud之一注册中心（Eureka）的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1101725。

相关文章

SpringBoot使用Apache Tika检测敏感信息

SpringBoot使用Apache Tika检测敏感信息

《SpringBoot使用ApacheTika检测敏感信息》ApacheTika是一个功能强大的内容分析工具,它能够从多种文件格式中提取文本、元数据以及其他结构化信息,下面我们来看看如何使用Ap... 目录Tika 主要特性1. 多格式支持2. 自动文件类型检测3. 文本和元数据提取4. 支持 OCR（光学
阅读更多...
Java内存泄漏问题的排查、优化与最佳实践

Java内存泄漏问题的排查、优化与最佳实践

《Java内存泄漏问题的排查、优化与最佳实践》在Java开发中,内存泄漏是一个常见且令人头疼的问题,内存泄漏指的是程序在运行过程中,已经不再使用的对象没有被及时释放,从而导致内存占用不断增加,最终... 目录引言1. 什么是内存泄漏？常见的内存泄漏情况2. 如何排查 Java 中的内存泄漏？2.1 使用 J
阅读更多...
JAVA系统中Spring Boot应用程序的配置文件application.yml使用详解

JAVA系统中Spring Boot应用程序的配置文件application.yml使用详解

《JAVA系统中SpringBoot应用程序的配置文件application.yml使用详解》：本文主要介绍JAVA系统中SpringBoot应用程序的配置文件application.yml的... 目录文件路径文件内容解释1. Server 配置2. Spring 配置3. Logging 配置4. Ma
阅读更多...
Java 字符数组转字符串的常用方法

Java 字符数组转字符串的常用方法

《Java字符数组转字符串的常用方法》文章总结了在Java中将字符数组转换为字符串的几种常用方法,包括使用String构造函数、String.valueOf()方法、StringBuilder以及A... 目录1. 使用String构造函数1.1 基本转换方法1.2 注意事项2. 使用String.valu
阅读更多...
java脚本使用不同版本jdk的说明介绍

java脚本使用不同版本jdk的说明介绍

《java脚本使用不同版本jdk的说明介绍》本文介绍了在Java中执行JavaScript脚本的几种方式,包括使用ScriptEngine、Nashorn和GraalVM,ScriptEngine适用... 目录Java脚本使用不同版本jdk的说明1.使用ScriptEngine执行javascript2.
阅读更多...
Spring MVC如何设置响应

Spring MVC如何设置响应

《SpringMVC如何设置响应》本文介绍了如何在Spring框架中设置响应,并通过不同的注解返回静态页面、HTML片段和JSON数据,此外,还讲解了如何设置响应的状态码和Header... 目录1. 返回静态页面1.1 Spring 默认扫描路径1.2 @RestController2. 返回 html2
阅读更多...
Spring常见错误之Web嵌套对象校验失效解决办法

Spring常见错误之Web嵌套对象校验失效解决办法

《Spring常见错误之Web嵌套对象校验失效解决办法》：本文主要介绍Spring常见错误之Web嵌套对象校验失效解决的相关资料,通过在Phone对象上添加@Valid注解,问题得以解决,需要的朋... 目录问题复现案例解析问题修正总结  问题复现当开发一个学籍管理系统时，我们会提供了一个 API 接口去
阅读更多...
Java操作ElasticSearch的实例详解

Java操作ElasticSearch的实例详解

《Java操作ElasticSearch的实例详解》Elasticsearch是一个分布式的搜索和分析引擎,广泛用于全文搜索、日志分析等场景,本文将介绍如何在Java应用中使用Elastics... 目录简介环境准备1. 安装 Elasticsearch2. 添加依赖连接 Elasticsearch1. 创
阅读更多...
Spring核心思想之浅谈IoC容器与依赖倒置(DI)

Spring核心思想之浅谈IoC容器与依赖倒置(DI)

《Spring核心思想之浅谈IoC容器与依赖倒置(DI)》文章介绍了Spring的IoC和DI机制,以及MyBatis的动态代理,通过注解和反射,Spring能够自动管理对象的创建和依赖注入,而MyB... 目录一、控制反转 IoC二、依赖倒置 DI1. 详细概念2. Spring 中 DI 的实现原理三、
阅读更多...
SpringBoot 整合 Grizzly的过程

SpringBoot 整合 Grizzly的过程

《SpringBoot整合Grizzly的过程》Grizzly是一个高性能的、异步的、非阻塞的HTTP服务器框架,它可以与SpringBoot一起提供比传统的Tomcat或Jet... 目录为什么选择 Grizzly？Spring Boot + Grizzly 整合的优势添加依赖自定义 Grizzly 作为
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2