草庐IT

微服务架构 | 3.1 Netflix Eureka 注册中心

多氯环己烷 2023-03-28 原文


前言

参考资料
《Spring Microservices in Action》
《Spring Cloud Alibaba 微服务原理与实战》
《B站 尚硅谷 SpringCloud 框架开发教程 周阳》
《Spring Cloud Netflix 官方资料》

Eureka 是 Netflix 开发的服务发现框架,本身是一个基于REST的服务,主要用于定位运行在 AWS 域中的中间层服务,以达到负载均衡和中间层服务故障转移的目的;

Spring Cloud 将它集成在其子项目 spring-cloud-netflix 中,以实现 Spring Cloud 的服务发现功能;


1. Eureka 基础知识

1.1 Eureka 模型中的服务器与客户端

  • 服务器:服务的注册中心,负责维护与管理注册的服务列表;
  • 客户端:所有要注册进 Eureka 的服务都称为 Eureka 的客户端,它可以是服务配置中心 Spring Cloud Config;也可以是网关 zuul;还可以是实际的业务服务等;

1.2 Eureka 的 30s 启动机制

  • 当客户端服务通过 Eureka 注册时, Eureka 将在 30s 内等待 3 次连续的健康检查,然后才能通过 Eureka 获取该服务;
  • 每次服务注册需要 30 s 的时间才能显示在 Eureka服务中,因为 Eureka需要从服务接收 3 次。连续心跳包 ping,每次心跳包 ping 间隔 10 s,然后才能使用这个服务;

1.3 Eureka 为什么注册服务的 IP ,而不是主机名

  • 具体例子详情可以参考《3.2 修改 boostrap.yml 配置文件》;
  • 在基于服务器的环境中时:Eureka 在尝试注册客户端服务时,客户端服务会被分配一个 DNS 支持的主机名,客户端服务通过这个 DNS 主机名与外界联系;
  • 在基于容器的部署(如 Docker)中:容器以随机生成的主机名启动,没有 DNS 记录;使用主机名将无法解析;

1.4 Eureka 服务器的高可用(集群)

  • 在实际生产中,为了实现 Eureka 的高可用,需要建立多个 Eureka 服务器以便相互复制注册表的内容;
  • 一组 Eureka 注册表相互之间使用点对点通信模型进行通信;
  • 需要在客户端 eureka.serviceUrl.defaultZone 属性中用逗号隔开多个 Eureka 服务器的位置;
  • 同时,服务器的 eureka.serviceUrl.defaultZone 属性中用逗号隔开多个除了自身的 Eureka 服务器的位置;

2. 构建 Eureka 服务器

2.1 引入 pom.xml 依赖

<!-- 1.x老版本的依赖 -->
<dependency>  
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-eureka-server</artifactId>
</dependency>
<!-- 2.x新版本的依赖 -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>
  • Eureka 的 Maven 依赖文件默认包含 Ribbon 组件;
  • 新老版本二选一即可;

2.2 修改 application.yaml 配置文件

server:
  port: 8761 #Eureka 监听的端口
spring:
  application:
    name: eureka-server #Eureka 服务器的名称
eureka:
  client:
    fetch-registry: false #不要在本地缓存注册表信息
    register-with-eureka: false #不使用 Eureka 服务进行注册
    serviceUrl:
      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
  instance:
    hostname: localhost
  server:  #配置属性,但由于 Eureka 自我保护模式以及心跳周期长的原因,经常会遇到 Eureka Server 不剔除已关停的节点的问题
    enable-self-preservation: false
    eviction-interval-timer-in-ms: 5000
    waitTimelnMsWhenSyncEmpty: 5 #在服务器接收请求之前等待的初始时间,在实际生产中应注释掉此属性
  • 如果需要将组件注册进 Eureka 里,需要把 eureka.client.register-with-eureka 置为 true,或者不管它,使用默认值 true;
  • 只有 Eureka 的客户端才需要把 eureka.client.register-with-eureka 置为 true;

2.3 在主程序类上标注注解

@EnableEurekaServer:表示该服务为 Eureka 服务器;


3. 将客户端注册进 Eureka 服务器

3.1 引入 pom.xml 依赖

<!--注册中心-->
<dependency>  
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>
  • 因为每个服务基本上都会注册进 Eureka 服务器里,因此该依赖可以添加到父工程里,表示公共依赖;

3.2 修改 boostrap.yml 配置文件

spring:
  application:
    name: xxx-client  #应用程序ID,常写在 boostrap.yml 下
  profiles:
    active: dev
  cloud:
    config:
      enabled: true
eureka:
  instance:
    preferIpAddress: true  #注册服务的IP,而不是服务名称
  client:
    registerWithEureka: true  #向 Eureka 注册服务
    fetchRegistry: true  #拉取注册表的本地副本
    serviceUrl: 
      defaultZone: http://localhost:8761/eureka/  #Eureka 服务模块
  • 每个通过 Eureka 注册的服务都会有两个与之相关的 ID:
    • 应用程序 ID:表示一组服务实,D始终是由 spring.application.name 属性设置的值(写在 bootstrap.yml 配置文件中,而不是 application.xml);
    • 实例 ID:一个随机数,用于代表单个服务实例;
  • 为什么注册服务的 IP ,而不是主机名:
    • 在基于服务器的环境中时:Eureka 在尝试注册客户端服务时,客户端服务会被分配一个 DNS 支持的主机名,客户端服务通过这个 DNS 主机名与外界联系;
    • 在基于容器的部署(如 Docker)中:容器以随机生成的主机名启动,没有 DNS 记录;使用主机名将无法解析;

3.3 在主程序类上标注服务发现的注解

  • @EnableEurekaClient:推荐使用 Eureka 作为注册中心;
  • @EnableDiscoveryClient:推荐使用其他组件作为注册中心;

4. Eureka Server 的自我保护

4.1 故障现象

  • 如果在Eureka Server的首页看到以下这段提示,则说明Eureka进入了保护模式:

  • Eureka Server 一旦进入自我保护模式,将会尝试保护其服务注册表中的信息,不再删除服务注册表中的数据,也不会注销任何微服务

4.2 自我保护概述

  • 保护模式主要用于一组客户端和 Eureka Server 之间存在网络分区场景下的保护;
  • 为了防止 Eureka Client 可以正常运行,但是与 Eureka Server 网络不通情况下,Eureka Server 不会立刻将 Eureka Client 服务剔除;

4.3 自我保护原理

  • 默认情况下,如果 Eureka Server 在一定时间内没有接收到某个微服务实例的心跳,Eureka Server 将会注销该实例(默认90秒);
  • 但是当网络分区故障发生(延时、卡顿、拥挤)时,微服务与 Eureka Server 之间无法正常通信,以上行为可能变得非常危险了;
  • 因为微服务本身其实是健康的,此时本不应该注销这个微服务;
  • Eureka 通过“自我保护模式”来解决这个问题:当 Eureka Server 节点在短时间内丢失过多客户端时(可能发生了网络分区故障),那么这个节点就会进入自我保护模式;
  • 在自我保护模式中,Eureka Server 会保护服务注册表中的信息,不再注销任何服务实例

4.4 关闭自我保护机制

  • 使用如下配置可以关闭自我保护机制,保证不可用服务被及时踢除:
  • eureka.server.enable-self-preservation = false


最后

新人制作,如有错误,欢迎指出,感激不尽!
欢迎关注公众号,会分享一些更日常的东西!
如需转载,请标注出处!

有关微服务架构 | 3.1 Netflix Eureka 注册中心的更多相关文章

  1. ruby-on-rails - Rails 3.1 中具有相同形式的多个模型? - 2

    我正在使用Rails3.1并在一个论坛上工作。我有一个名为Topic的模型,每个模型都有许多Post。当用户创建新主题时,他们也应该创建第一个Post。但是,我不确定如何以相同的形式执行此操作。这是我的代码:classTopic:destroyaccepts_nested_attributes_for:postsvalidates_presence_of:titleendclassPost...但这似乎不起作用。有什么想法吗?谢谢! 最佳答案 @Pablo的回答似乎有你需要的一切。但更具体地说...首先改变你View中的这一行对此#

  2. Observability:从零开始创建 Java 微服务并监控它 (二) - 2

    这篇文章是继上一篇文章“Observability:从零开始创建Java微服务并监控它(一)”的续篇。在上一篇文章中,我们讲述了如何创建一个Javaweb应用,并使用Filebeat来收集应用所生成的日志。在今天的文章中,我来详述如何收集应用的指标,使用APM来监控应用并监督web服务的在线情况。源码可以在地址 https://github.com/liu-xiao-guo/java_observability 进行下载。摄入指标指标被视为可以随时更改的时间点值。当前请求的数量可以改变任何毫秒。你可能有1000个请求的峰值,然后一切都回到一个请求。这也意味着这些指标可能不准确,你还想提取最小/

  3. 阿里云国际版免费试用:如何注册以及注意事项 - 2

    作为新的阿里云用户,您可以50免费试用多种优惠,价值高达1,700美元(或8,500美元)。这将让您了解和体验阿里云平台上提供的一系列产品和服务。如果您以个人身份注册免费试用,您将获得价值1,700美元的优惠。但是,如果您是注册公司,您可以选择企业免费试用,提交基本信息通过企业实名注册验证,即可开始价值$8,500的免费试用!本教程介绍了如何设置您的帐户并使用您的免费试用版。​关于免费试用在我们开始此试用之前,您还必须遵守以下条款和条件才能访问您的免费试用:只有在一年内创建的账户才有资格获得阿里云免费试用。通过此免费试用优惠,用户可以免费试用免费试用活动页面上列出的每种产品一次。如果您有多个帐

  4. ruby-on-rails - 带有 Zeus 的 RSpec 3.1,我应该在 spec_helper 中要求 'rspec/rails' 吗? - 2

    使用rspec-rails3.0+,测试设置分为spec_helper和rails_helper我注意到生成的spec_helper不需要'rspec/rails'。这会导致zeus崩溃:spec_helper.rb:5:in`':undefinedmethod`configure'forRSpec:Module(NoMethodError)对thisissue最常见的回应是需要'rspec/rails'。但这是否会破坏仅使用spec_helper拆分rails规范和PORO规范的全部目的?或者这无关紧要,因为Zeus无论如何都会预加载Rails?我应该在我的spec_helper中做

  5. ruby-on-rails - 设计注册确认 - 2

    我在我的项目中有一个用户和一个管理员角色。我使用Devise创建了身份验证。在我的管理员角色中,我没有任何确认。在我的用户模型中,我有以下内容:devise:database_authenticatable,:confirmable,:recoverable,:rememberable,:trackable,:validatable,:timeoutable,:registerable#Setupaccessible(orprotected)attributesforyourmodelattr_accessible:email,:username,:prename,:surname,:

  6. ruby - Ruby 和 Ruby on Rails 中的三层架构 - 2

    我是一名决定学习Ruby和RubyonRails的ASP.NETMVC开发人员。我已经有所了解并在RoR上创建了一个网站。在ASP.NETMVC上开发,我一直使用三层架构:数据层、业务层和UI(或表示)层。尝试在RubyonRails应用程序中使用这种方法,我发现没有关于它的信息(或者也许我只是找不到它?)。也许有人可以建议我如何在RubyonRails上创建或使用三层架构?附言我使用ruby​​1.9.3和RubyonRails3.2.3。 最佳答案 我建议在制作RoR应用程序时遵循RubyonRails(RoR)风格。Rails

  7. ruby-on-rails - 特征未注册 : attribute name - 2

    完成这个有困难。我正在使用seed.rb+factory_girl来使用rakedb:seed填充数据库。(我知道固定装置存在,但我想以这种方式完成,这只是一个示例,数据库将填充复杂的关联对象。)我的种子.rb:require'factory_girl_rails'["QM","CDC","SI","QS"].eachdo|n|FactoryGirl.create(:grau,nome:n)end还有我的/factories/graus.rbFactoryGirl.definedofactory:graudonomeendend但是当我运行时:rakedb:seed我得到:rakeab

  8. jquery - 如何在 rails 3.1 上安装 jQuery - 2

    我以为它已经安装了,但在我的gemfile中有gem"jquery-rails"但是在我的asset/javascripts文件夹中accounts.js.coffeeapplication.js都被注释掉了这是我的虚拟railsapplication但是在源代码中没有jQuery并且删除链接不起作用......任何想法都丢失了 最佳答案 看看thisRailscast.您可能需要检查application.js文件并确保它包含以下语句。//=requirejquery//=requirejquery_ujs

  9. ruby-on-rails - 带有自定义处理器的 CarrierWave 未注册 - 2

    我正在使用carrierwave上传视频然后有一个名为thumb的版本,带有自定义处理器,可以获取视频并使用streamio-ffmpeg创建屏幕截图。视频和文件都已正确上传,但在调用uploader.url(:thumb)时我得到:ArgumentError:Versionthumbdoesn'texist!VideoUploader.rbrequire'carrierwave/processing/mime_types'require'streamio-ffmpeg'classVideoUploader5)File.renamethumb_path,current_pathendd

  10. ruby-on-rails - Rails 3.1,工厂女孩错误 - 2

    已修复。Rails中有一个错误。参见https://github.com/rails/rails/issues/2333我对FactoryGirlRails和Rails3.1.0.rc5有疑问当我多次执行user=FactoryGirl.create(:user)时出现错误。Failure/Error:user=FactoryGirl.create(:user)NameError:uninitializedconstantUser::User#./app/models/user.rb:17:in`generate_token'#./app/models/user.rb:4:in`blo

随机推荐