eureka技术分享

2022年05月15日 阅读数：4
这篇文章主要向大家介绍eureka技术分享,主要内容包括基础应用、实用技巧、原理机制等方面，希望对大家有所帮助。
标签： javanodewebspring浏览器缓存安全服务器网络架构

上一篇文章《微服务零基础入门教学》，详细的介绍了微服务的大背景以及微服务架构的演进，咱们还对各类解决微服务的方案进行了分析，今天就让咱们正式开始微服务的实战环节：注册中心。java

我打算将迄今为止常见的八种注册中心逐一展开介绍，首先讲解第一个你们最为熟知的注册中心——Eureka。node

注册中心之Eureka

1、Eureka的基础知识

Eureka是Netflix开发的服务发现框架，SpringCloud将它集成在本身的子项目spring-cloud-netflix中，实现SpringCloud的服务发现功能。web

在这里插入图片描述
上图简要描述了Eureka的基本架构，由3个角色组成：spring

  1. Eureka Server
    提供服务注册和发现
  2. Service Provider
    服务提供方将自身服务注册到Eureka，从而使服务消费方可以找到
  3. Service Consumer
    服务消费方从Eureka获取注册服务列表，从而可以消费服务

2、Eureka的交互流程与原理

在这里插入图片描述

图是来自Eureka官方的架构图，大体描述了Eureka集群的工做过程。图中包含的组件很是多，可能比较难以理解，咱们用通俗易懂的语言解释一下：浏览器

  • Application Service 至关于本书中的服务提供者，Application Client至关于服务消费者；
  • Make Remote Call，能够简单理解为调用RESTful API；
  • us-east-1c、us-east-1d等都是zone，它们都属于us-east-1这个region；

由图可知，Eureka包含两个组件：Eureka Server 和 Eureka Client，它们的做用以下：缓存

  • Eureka Client是一个Java客户端，用于简化与Eureka Server的交互；
  • Eureka Server提供服务发现的能力，各个微服务启动时，会经过Eureka Client向Eureka Server进行注册本身的信息（例如网络信息），Eureka Server会存储该服务的信息；
  • 微服务启动后，会周期性地向Eureka Server发送心跳（默认周期为30秒）以续约本身的信息。若是Eureka Server在必定时间内没有接收到某个微服务节点的心跳，Eureka Server将会注销该微服务节点（默认90秒）；
  • 每一个Eureka Server同时也是Eureka Client，多个Eureka Server之间经过复制的方式完成服务注册表的同步；
  • Eureka Client会缓存Eureka Server中的信息。即便全部的Eureka Server节点都宕掉，服务消费者依然可使用缓存中的信息找到服务提供者。

综上，Eureka经过心跳检测、健康检查和客户端缓存等机制，提升了系统的灵活性、可伸缩性和可用性。安全

3、搭建Eureka注册中心

一、搭建Eureka服务中心

(1) 建立shop_eureka_server子模块
在 shop_parent 下建立子模块 shop_eureka_server
(2) 引入maven坐标服务器

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

(3) 配置application.yml网络

server:
 port: 8761
eureka:
 instance:
   hostname: localhost
 client:
   registerWithEureka: false  
   fetchRegistry: false
   serviceUrl:
     defaultZone: http://${
   
   eureka.instance.hostname}:${
   
   server.port}/eureka/

	registerWithEureka: 是否将本身注册到Eureka服务中，自己就是全部无需注册
	fetchRegistry : 是否从Eureka中获取注册信息
	serviceUrlEureka: 客户端与Eureka服务端进行交互的地址

(4) 配置启动类
在 cn.itcast.eureka 下建立启动类 EurekaServerApplication架构

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

EnableEurekaServer : 激活Eureka Server端配置

二、服务注册中心管理后台

打开浏览器访问http://localhost8761便可进入EurekaServer内置的管理控制台,显示效果以下
在这里插入图片描述

4、服务注册到Eureka注册中心

一、商品服务注册

(1) 商品模块中引入坐标
在 shop_service_product 的pom文件中添加eureka client的相关坐标

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

(2) 配置application.yml文件
在工程的 application.yml 中添加Eureka Server的主机地址

eureka:
 client:
   serviceUrl: # eureka server的路径
     defaultZone: http://localhost:8761/eureka/
 instance:
   prefer-ip-address: true #使用ip注册

(3) 修改启动类添加服务注册注解

@SpringBootApplication
//@EnableDiscoveryClient
//@EnableEurekaClient
public class OrderApplication {
   
   
public static void main(String[] args) {
   
   
SpringApplication.run(OrderApplication.class, args);
 }
}

从Spring Cloud Edgware版本开始， @EnableDiscoveryClient 或 @EnableEurekaClient 可省略。只需加上相关依赖，并进行相应配置，便可将微服务注册到服务发现组件上。

二、订单服务注册

和商品微服务同样,只须要引入坐标依赖,在工程的 application.yml 中添加Eureka Server的主机地址便可

(1) 订单模块中引入坐标
在 shop_service_product 的pom文件中添加eureka client的相关坐标

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

(2) 配置application.yml文件
在工程的 application.yml 中添加Eureka Server的主机地址

eureka:
 client:
   serviceUrl: # eureka server的路径
     defaultZone: http://localhost:8761/eureka/
 instance:
   prefer-ip-address: true #使用ip注册

(3) 修改启动类添加服务注册注解

@SpringBootApplication
//@EnableDiscoveryClient
//@EnableEurekaClient
public class OrderApplication {
   
   
public static void main(String[] args) {
   
   
SpringApplication.run(OrderApplication.class, args);
 }
}

从Spring Cloud Edgware版本开始， @EnableDiscoveryClient 或 @EnableEurekaClient 可省略。只需加上相关依赖，并进行相应配置，便可将微服务注册到服务发现组件上。

5、Eureka中的自我保护

微服务第一次注册成功以后，每30秒会发送一次心跳将服务的实例信息注册到注册中心。通知 Eureka Server 该实例仍然存在。若是超过90秒没有发送更新，则服务器将从注册信息中将此服务移除。

Eureka Server在运行期间，会统计心跳失败的比例在15分钟以内是否低于85%，若是出现低于的状况（在单机调试的时候很容易知足，实际在生产环境上一般是因为网络不稳定致使），Eureka Server会将当前的实例注册信息保护起来，同时提示这个警告。保护模式主要用于一组客户端和Eureka Server之间存在网络分区场景下的保护。一旦进入保护模式，Eureka Server将会尝试保护其服务注册表中的信息，再也不删除服务注册表中的数据（也就是不会注销任何微服务）验证完自我保护机制开启后，并不会立刻呈现到web上，而是默认需等待 5 分钟（能够通eureka.server.wait-time-in-ms-when-sync-empty 配置），即 5 分钟后你会看到下面的提示信息：

在这里插入图片描述
若是关闭自我保护
经过设置 eureka.enableSelfPreservation=false 来关闭自我保护功能。

6、Eureka中的元数据

Eureka的元数据有两种：标准元数据和自定义元数据。

  • 标准元数据：主机名、IP地址、端口号、状态页和健康检查等信息，这些信息都会被发布在服务注册表中，用于服务之间的调用。
  • 自定义元数据：可使用eureka.instance.metadata-map配置，符合KEY/VALUE的存储格式。这些元数据能够在远程客户端中访问。

在程序中可使用DiscoveryClient 获取指定微服务的全部元数据信息

@SpringBootTest
@RunWith(SpringJUnit4ClassRunner.class)
public class RestTemplateTest {
   
   
	@Autowired
	private DiscoveryClient discoveryClient;
	@Test
	public void test() {
   
   
	//根据微服务名称从注册中心获取相关的元数据信息
	List<ServiceInstance> instances = discoveryClient.getInstances("shop-service-product");
		for (ServiceInstance instance : instances) {
   
   
			System.out.println(instance);
		 }
	 }
}

7、Eureka高可用集群

Eureka Client会定时链接Eureka Server，获取注册表中的信息并缓存到本地。微服务在消费远程API时老是使用本地缓存中的数据。所以通常来讲，即便Eureka Server发生宕机，也不会影响到服务之间的调用。但若是Eureka Server宕机时，某些微服务也出现了不可用的状况，Eureka Server中的缓存若不被刷新，就可能会影响到微服务的调用，甚至影响到整个应用系统的高可用。所以，在生成环境中，一般会部署一个高可用的Eureka Server集群。

Eureka Server能够经过运行多个实例并相互注册的方式实现高可用部署，Eureka Server实例会彼此增量地同步信息，从而确保全部节点数据一致。事实上，节点之间相互注册是Eureka Server的默认行为。
在这里插入图片描述

一、搭建 Eureka Server高可用集群

一、修改本机host属性

127.0.0.1 eureka1
127.0.0.1 eureka2

二、修改 shop_eureka_server 工程中的yml配置文件，添加以下配置属性

#指定应用名称
spring:
 application:
   name: shop-eureka-server
---
#执行peer1的配置信息
spring:
 profiles: eureka1
server:
 port: 8761
eureka:
 instance:
   hostname: eureka1
 client:
   service-url:
     defaultZone: http://eureka2:8762/eureka
---
#执行peer2的配置信息
spring:
 profiles: eureka2
server:
 port: 8762
eureka:
 instance:
   hostname: eureka2
 client:
   service-url:
     defaultZone: http://eureka1:8761/eureka

在配置文件中经过连字符（—）将文件分为三个部分，第一部分为应用名称，第二部分和第三部分是根据不一样的profiles选项动态添加，能够在IDEA启动时进行激活配置

在这里插入图片描述

使用IDEA启动历次EurekaServerApplicaion分别激活eureka1和eureka2配置。访问http://eureka1:8761和http://eureka1:8762/。会发现注册中心 SHOP-EUREKA-SERVER 已经有两个节点，而且registered-replicas (相邻集群复制节点)中已经包含对方。
在这里插入图片描述

二、服务注册到Eureka Server集群

若是须要将微服务注册到Eureka Server集群只须要修改yml配置文件便可

eureka:
 client:
   serviceUrl:
     defaultZone: http://eureka1:8761/eureka/,http://eureka1:8761/eureka/

以商品微服务为例，修改defaultZone配置添加多个Eureka Server的地址

8、Eureka中的常见问题

一、服务注册慢

默认状况下，服务注册到Eureka Server的过程较慢。SpringCloud官方文档中给出了详细的缘由
在这里插入图片描述

大体含义：服务的注册涉及到心跳，默认心跳间隔为30s。在实例、服务器、客户端都在本地缓存中具备相同的元数据以前，服务不可用于客户端发现（因此可能须要3次心跳）。能够经过配置eureka.instance.leaseRenewalIntervalInSeconds (心跳频率)加快客户端链接到其余服务的过程。在生产中，最好坚持使用默认值，由于在服务器内部有一些计算，他们对续约作出假设。

二、服务节点剔除问题

默认状况下，因为Eureka Server剔除失效服务间隔时间为90s且存在自我保护的机制。因此不能有效而迅速的剔除失效节点，这对开发或测试会形成困扰。解决方案以下：

Eureka Server：
配置关闭自我保护，设置剔除无效节点的时间间隔

eureka:
 instance:
   hostname: eureka1
 client:
   service-url:
     defaultZone: http://eureka2:8762/eureka
 server:
   enable-self-preservation: false  #关闭自我保护
   eviction-interval-timer-in-ms: 4000 #剔除时间间隔,单位:毫秒

Eureka Client：
配置开启健康检查，并设置续约时间

eureka:
 client:
   healthcheck: true #开启健康检查(依赖spring-boot-actuator)
   serviceUrl:
     defaultZone: http://eureka1:8761/eureka/,http://eureka1:8761/eureka/
 instance:
   preferIpAddress: true
   lease-expiration-duration-in-seconds: 10 #eureka client发送心跳给server端后，续约到期时间（默认90秒）
   lease-renewal-interval-in-seconds: 5 #发送心跳续约间隔

三、监控页面显示ip

在Eureka Server的管控台中，显示的服务实例名称默认状况下是微服务定义的名称和端口。为了更好的对全部服务进行定位，微服务注册到Eureka Server的时候能够手动配置示例ID。配置方式以下：

eureka:
 instance:
   instance-id: ${
   
   spring.cloud.client.ip-address}:${
   
   server.port}
#spring.cloud.client.ip-address:获取ip地址

在这里插入图片描述

9、Eureka配置合集

一、Eureka Server经常使用配置

eureka:
  server:
    #服务端开启自我保护模式
    enable-self-preservation: true
    #扫描失效服务的间隔时间（单位毫秒，默认是60*1000）即60秒
    eviction-interval-timer-in-ms: 60000
    #间隔多长时间，清除过时的 delta 数据
    delta-retention-timer-interval-in-ms: 0
    #是否开启请求频率限制器
    rate-limiter-enabled: false
    #请求频率限制器
    rate-limiter-burst-size: 10
    #请求频率的平均值
    rate-limiter-full-fetch-average-rate: 100
    #是否对标准的client进行频率请求限制。若是是false，则只对非标准client进行限制
    rate-limiter-throttle-standard-clients: false
    #注册服务、拉取服务列表数据的请求频率的平均值
    rate-limiter-registry-fetch-average-rate: 500
    #设置信任的client list
    rate-limiter-privileged-clients: Collections.emptySet()
    #在设置的时间范围类，指望与client续约的百分比。
    renewal-percent-threshold: 0.85
    #多长时间更新续约的阈值
    renewal-threshold-update-interval-ms: 900000
    #对于缓存的注册数据，多长时间过时
    response-cache-auto-expiration-in-seconds: 180
    #多长时间更新一次缓存中的服务注册数据
    response-cache-update-interval-ms: 30000
    #缓存增量数据的时间，以便在检索的时候不丢失信息
    retention-time-in-m-s-in-delta-queue: 180000
    #当时间戳不一致的时候，是否进行同步
    sync-when-timestamp-differs: true
    #是否采用只读缓存策略，只读策略对于缓存的数据不会过时。
    use-read-only-response-cache: true
    
    #============== server node 与 node 之间关联的配置 ==============#

    #发送复制数据是否在request中，老是压缩
    enable-replicated-request-compression: false
    #指示群集节点之间的复制是否应批处理以提升网络效率。
    batch-replication: false
    #容许备份到备份池的最大复制事件数量。而这个备份池负责除状态更新的其余事件。能够根据内存大小，超时和复制流量，来设置此值得大小
    max-elements-in-peer-replication-pool: 10000
    #容许备份到状态备份池的最大复制事件数量
    max-elements-in-status-replication-pool: 10000
    #多个服务中心相互同步信息线程的最大空闲时间
    max-idle-thread-age-in-minutes-for-peer-replication: 15
    #状态同步线程的最大空闲时间
    max-idle-thread-in-minutes-age-for-status-replication: 15
    #服务注册中心各个instance相互复制数据的最大线程数量
    max-threads-for-peer-replication: 20
    #服务注册中心各个instance相互复制状态数据的最大线程数量
    max-threads-for-status-replication: 1
    #instance之间复制数据的通讯时长
    max-time-for-replication: 30000
    #正常的对等服务instance最小数量。-1表示服务中心为单节点。
    min-available-instances-for-peer-replication: -1
    #instance之间相互复制开启的最小线程数量
    min-threads-for-peer-replication: 5
    #instance之间用于状态复制，开启的最小线程数量
    min-threads-for-status-replication: 1
    #instance之间复制数据时能够重试的次数
    number-of-replication-retries: 5
    #eureka节点间间隔多长时间更新一次数据。默认10分钟。
    peer-eureka-nodes-update-interval-ms: 600000
    #eureka服务状态的相互更新的时间间隔。
    peer-eureka-status-refresh-time-interval-ms: 0
    #eureka对等节点间链接超时时间
    peer-node-connect-timeout-ms: 200
    #eureka对等节点链接后的空闲时间
    peer-node-connection-idle-timeout-seconds: 30
    #节点间的读数据链接超时时间
    peer-node-read-timeout-ms: 200
    #eureka server 节点间链接的总共最大数量
    peer-node-total-connections: 1000
    #eureka server 节点间链接的单机最大数量
    peer-node-total-connections-per-host: 10
    #在服务节点启动时，eureka尝试获取注册信息的次数
    registry-sync-retries: 0
    #在服务节点启动时，eureka屡次尝试获取注册信息的间隔时间
    registry-sync-retry-wait-ms:
    #当eureka server启动的时候，不能从对等节点获取instance注册信息的状况，应等待多长时间。
    wait-time-in-ms-when-sync-empty: 0

二、Eureka Client 经常使用配置


eureka:
  client:
    #该客户端是否可用
    enabled: true
    #实例是否在eureka服务器上注册本身的信息以供其余服务发现，默认为true
    register-with-eureka: false
    #此客户端是否获取eureka服务器注册表上的注册信息，默认为true
    fetch-registry: false
    #是否过滤掉，非UP的实例。默认为true
    filter-only-up-instances: true
    #与Eureka注册服务中心的通讯zone和url地址
    service-url: 
      defaultZone: http://${
   
   eureka.instance.hostname}:${
   
   server.port}/eureka/
    #client链接Eureka服务端后的空闲等待时间，默认为30 秒
    eureka-connection-idle-timeout-seconds: 30
    #client链接eureka服务端的链接超时时间，默认为5秒
    eureka-server-connect-timeout-seconds: 5
    #client对服务端的读超时时长
    eureka-server-read-timeout-seconds: 8
    #client链接all eureka服务端的总链接数，默认200
    eureka-server-total-connections: 200
    #client链接eureka服务端的单机链接数量，默认50
    eureka-server-total-connections-per-host: 50
    #执行程序指数回退刷新的相关属性，是重试延迟的最大倍数值，默认为10
    cache-refresh-executor-exponential-back-off-bound: 10
    #执行程序缓存刷新线程池的大小，默认为5
    cache-refresh-executor-thread-pool-size: 2
    #心跳执行程序回退相关的属性，是重试延迟的最大倍数值，默认为10
    heartbeat-executor-exponential-back-off-bound: 10
    #心跳执行程序线程池的大小,默认为5
    heartbeat-executor-thread-pool-size: 5
    # 询问Eureka服务url信息变化的频率（s），默认为300秒
    eureka-service-url-poll-interval-seconds: 300
    #最初复制实例信息到eureka服务器所需的时间（s），默认为40秒
    initial-instance-info-replication-interval-seconds: 40
    #间隔多长时间再次复制实例信息到eureka服务器，默认为30秒
    instance-info-replication-interval-seconds: 30
    #从eureka服务器注册表中获取注册信息的时间间隔（s），默认为30秒
    registry-fetch-interval-seconds: 30
    # 获取实例所在的地区。默认为us-east-1
    region: us-east-1
    #实例是否使用同一zone里的eureka服务器，默认为true，理想状态下，eureka客户端与服务端是在同一zone下
    prefer-same-zone-eureka: true
    # 获取实例所在的地区下可用性的区域列表，用逗号隔开。（AWS）
    availability-zones:
      china: defaultZone,defaultZone1,defaultZone2
    #eureka服务注册表信息里的以逗号隔开的地区名单，若是不这样返回这些地区名单，则客户端启动将会出错。默认为null
    fetch-remote-regions-registry:
    #服务器是否可以重定向客户端请求到备份服务器。 若是设置为false，服务器将直接处理请求，若是设置为true，它可能发送HTTP重定向到客户端。默认为false
    allow-redirects: false
    #客户端数据接收
    client-data-accept:
    #增量信息是否能够提供给客户端看，默认为false
    disable-delta: false
    #eureka服务器序列化/反序列化的信息中获取“_”符号的的替换字符串。默认为“__“
    escape-char-replacement: __
    #eureka服务器序列化/反序列化的信息中获取“$”符号的替换字符串。默认为“_-”
    dollar-replacement: "_-"
    #当服务端支持压缩的状况下，是否支持从服务端获取的信息进行压缩。默认为true
    g-zip-content: true
    #是否记录eureka服务器和客户端之间在注册表的信息方面的差别，默认为false
    log-delta-diff: false
    # 若是设置为true,客户端的状态更新将会点播更新到远程服务器上，默认为true
    on-demand-update-status-change: true
    #此客户端只对一个单一的VIP注册表的信息感兴趣。默认为null
    registry-refresh-single-vip-address:
    #client是否在初始化阶段强行注册到服务中心，默认为false
    should-enforce-registration-at-init: false
    #client在shutdown的时候是否显示的注销服务从服务中心，默认为true
    should-unregister-on-shutdown: true

三、Eureka Instance经常使用配置

eureka:
  instance:
    #应用名，首先获取spring.application.name的值，若是取值为空，则取默认unknown。
    appname: unknown
    #应用组名
    appGroupName: null
    #实例注册到Eureka上时，是否马上开启通信。有时候应用在准备好服务以前须要一些预处理。
    instanceEnabledOnit: false
    #非安全的端口
    nonSecurePort: 80
    #安全端口
    securePort: 443
    #是否开启非安全端口通信
    nonSecurePortEnabled: true
    #是否开启安全端口通信
    securePortEnabled: false
    #实例续约更新间隔时间
    leaseRenewalIntervalInSeconds: 30
    #实例超时/过时时间，表示最大leaseExpirationDurationInSeconds秒后没有续约，Server就认为他不可用了，随之就会将其剔除。
    leaseExpirationDurationInSeconds: 90
    #虚拟主机名，首先获取spring.application.name的值，若是取值为空，则取默认unknown。
    virtualHostName: unknown
    #注册到eureka上的惟一实例ID，不能与相同appname的其余实例重复。
    instanceId: ${
   
   spring.application.name}:${
   
   server.port}
    #安全虚拟主机名，首先获取spring.application.name的值，若是取值为空，则取默认unknown。
    secureVirtualHostName: unknown
    #实例元数据，能够供其余实例使用。好比spring-boot-admin在监控时，获取实例的上下文和端口。
    metadataMap: new HashMap();
    #实例部署的数据中心。如AWS、MyOwn。
    dataCenterInfo: new MyDataCenterInfo(DataCenterInfo.Name.MyOwn);
    #实例的IP地址
    ipAddress: null
    #实例状态页相对url
    statusPageUrlPath: "/actuator/info"
    #实例状态页绝对URL
    statusPageUrl: null
    #实例主页相对URL
    homePageUrlPath: "/"
    #实例主页绝对URL
    homePageUrl: null
    #实例健康检查相对URL
    health-check-url-path: "/actuator/health"
    #实例健康检查绝对URL
    healthCheckUrl: null
    #实例安全的健康检查绝对URL
    secureHealthCheckUrl: null
    #配置属性的命名空间（Spring Cloud中被忽略）
    namespace: "eureka"
    #主机名,不配置的时候将根据操做系统的主机名来获取
    hostname: null
    #是否优先使用IP地址做为主机名的标识
    preferIpAddress: false

推荐阅读：Java小白进阶架构师学习路线

标签： javanodewebspring浏览器缓存安全服务器网络架构
原文地址：https://blog.csdn.net/CSDN_SAVIOR/article/details/122456798

相关推荐

上一篇： nacos技术分享
下一篇： consul技术分享

热门标签

javascript
php
css
html
vue
html5
java
node
python
mysql
react
jquery
linux
android
webpack
ios
css3
nginx
c++
git
angularjs
spring
小程序
c#
机器学习
maven
分布式
区块链
大数据
eslint
DevelopQAS
关于本站
Copyright © 2008-2022 粤ICP备19150900号 .