文章目录

  • 1:Eureka是什么?
  • 2:EurekaServer服务注册中心建立
  • 3:将已有的微服务注册进Eureka服务中心
  • 4:Eureka的集群模式
  • 5:actuator微服务信息完善【可选择配置,不过建议配置上】
  • 6:服务发现Discovery
  • 7:Eureka的自我保护机制

1:Eureka是什么?

  • Spring Cloud封装了Netflixt 公司开发的Eureka模块来实现服务治理,在传统的rpc远程调用框架中,管理每个服务与服务之间依赖关系比较复杂,管理比较复杂,所以需要使用服务治理,管理服务于服务之间依赖关系,可以实现服务调用、负载均衡、容错等,实现服务发现与注册

  • Eureka是Netflix的一个子模块,也是核心模块之一。Eureka是一 个基于REST的服务,用于定位服务,以实现云端中间层服务发现和故障转移。服务注册与发现对于微服务架构来说是非常重要的,有了服务发现与注册,只需要使用服务的标识符,就可以访问到服务,而不需要修改服务调用的配置文件了。功能类似于dubbo的注册中心,比如Zookeeper。

  • Eureka的基本架构
    Spring Cloud封装了Netflix 公司开发的Eureka模块来实现服务注册和发现(请对比Zookeeper)。Eureka采用了C-S的设计架构。Eureka Server作为服务注册功能的服务器,它是服务注册中心。而系统中的其他微服务,使用Eureka的客户端连接到Eureka Server并维持心跳连接。这样系统的维护人员就可以通过EurekaServer来监控系统中各个微服务是否正常运行。SpringCloud 的一些其他模块(比如Zuu) 就可以通过Eureka Server来发现系统中的其他微服务,并执行相关的逻辑。(我们后面举的例子就可以更好理解这一段话)就好比学生去学校,肯定要去学校注册了才可以读书,学校就是Eureka Server服务中心,学生就是EurekaClient

Eureka包含两个组件: Eureka ServerEureka Client Eureka
Server提供服务注册服务。各个节点启动后,会在EurekaServer中进行注册, 这样EurekaServer中的服务注册表中将会存储所有可用服务节点的信息,服务节点的信息可以在界面中直观的看到
EurekaClient是一个Java客户端, 用于简化EurekaServer的交互,客户端同时也具备一个内置的、 使用轮询(round-robin)负载算法的负载均衡器。在应用启动后,将会向EurekaServer发送心跳(默认周期为30秒)。如果Eureka Server在多个心跳周期内没有接收到某个节点的心跳,EurekaServer将会从服务注册表中把这个服务节点移除(默认90秒)

2:EurekaServer服务注册中心建立

分为以下几步骤
第一步:新建一个maven moudle命名为cloud-eureka-server7001
如下结构图

第二步:在pom.xml中引入maven

<dependencies><!-- eureka-server服务端 --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-eureka-server</artifactId></dependency><!-- 修改后立即生效,热部署 --><dependency><groupId>org.springframework</groupId><artifactId>springloaded</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-devtools</artifactId></dependency></dependencies>

第三步:新建一个application.yml文件

server:port: 7001eureka:instance:hostname: eureka7001.com  #eureka服务端的实例名字client:register-with-eureka: false  #表示不向注册中心注册自己fetch-registry: false #表示自己就是注册中心,职责是维护服务实例,并不需要去检索服务service-url:defaultZone: http://eureka7002.com:7002/eureka/#设置与eureka server交互的地址查询服务和注册服务都需要依赖这个地址server:enable-self-preservation: false   #关闭Eureka的自我保护机制,保证不可用服务被及时删除eviction-interval-timer-in-ms: 2000

第四步:测试运行类,
EurekaMain7001.java

@EnableEurekaServer //EurekaServer服务器端启动类,接受其它微服务注册进来,有了它才可以接受其它微服务注册进来

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

输入http://localhost:7001/地址,如果出现以下界面,说明Eureka服务中心建立成功,界面中的Application显示,当前没有client注册到服务中心

3:将已有的微服务注册进Eureka服务中心

分以下几步骤
第一步:新建一个maven moudle项目命名为cloud-provider-payment8001,
如下结构图

第二步:改pom.xml

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

第三步:写yml

eureka:client:register-with-eureka: truefetchRegistry: trueservice-url:defaultZone: http://localhost:7001/eureka

第四步:测试,观察是否成功
第五步:主启动 --记得加上@EnableEurekaClient注解,开启Eureka> @EnableEurekaClient //本服务启动后会自动注册进eureka服务中,有了这个注解才可以注册进服务中心

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

如果登录到服务中心,观察到Application下面出现了服务注册名,说明成功

微服务注册配置说明

yml文件中需要注意:

EurekaClient端cloud-consumer-order80将注册进EurekaServer成为服务消费者consumer
第一步:新建mould :cloud-consumer-order80
第二步:改pom

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

第三步:写yml

spring:application:name: cloud-order-serviceeureka:client:register-with-eureka: truefetchRegistry: trueservice-url:defaultZone: http://localhost:7001/eureka

第四步:主启动

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

第五步:测试
1.先要启动EurekaServer,7001服务
2.再要启动服务提供者provider,8001服务
3.访问Eureka页面:

4.测试接口:http://localhost/consumer/payment/get/31,结果如下:

4:Eureka的集群模式

什么是集群?

百度百科:集群通信系统是一种用于集团调度指挥通信的移动通信系统,主要应用在专业移动通信领域。该系统具有的可用信道可为系统的全体用户共用,具有自动选择信道功能,它是共享资源、分担费用、共用信道设备及服务的多用途、高效能的无线调度通信系统。

集群技术特点:
1:通过多台计算机完成同一个工作,达到更高的效率。
2:两机或多机内容、工作过程等完全一样。如果一台死机,另一台可以起作用。

集群:同一个业务,部署在多个服务器上(不同的服务器运行同样的代码,干同一件事)

Eureka集群原理说明:

EurekaServer集群环境构建步骤:
1.参照参考cloud-eureka-server7001,新建cloud-eureka-server7002
2.改pom文件,和7001的pom文件一样
3.修改映射配置【可选择修改,若不修改则用localhost】我项目中没有修改配置
找到C:\Windows\System32\drivers\etc路径下的hosts文件

配置如下:

4.写yml
7001的yml文件

server:port: 7001eureka:instance:hostname: eureka7001.com    #eureka服务端的实例名字client:register-with-eureka: false    #表识不向注册中心注册自己fetch-registry: false   #表示自己就是注册中心,职责是维护服务实例,并不需要去检索服务service-url:defaultZone: http://eureka7002.com:7002/eureka/    #设置与eureka server交互的地址查询服务和注册服务都需要依赖这个地址

7002的yml文件

server:port: 7002eureka:instance:hostname: eureka7002.com #eureka服务端的实例名字client:register-with-eureka: false    #表识不向注册中心注册自己fetch-registry: false   #表示自己就是注册中心,职责是维护服务实例,并不需要去检索服务service-url:defaultZone: http://eureka7001.com:7001/eureka/     #设置与eureka server交互的地址查询服务和注册服务都需要依赖这个地址

5.主启动类:(复制cloud-eureka-server7001的主启动类到7002即可
6.将支付服务8001微服务发布到上面2台Eureka集群配置中

service-url:defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka  #集群版

7.将订单服务80微服务发布到上面2台Eureka集群配置中

service-url:defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka  #集群版

8.测试

浏览器访问:http://localhost/consumer/payment/get/31


支付服务提供者8001集群环境构建
第一步:参考cloud-provider-payment8001,新建cloud-provider-payment8002
第二步:改pom,8002和8001的pom文件一样
第三步: 写yml,
7001的yml文件

server:port: 7001eureka:instance:hostname: eureka7001.com    #eureka服务端的实例名字client:register-with-eureka: false    #表识不向注册中心注册自己fetch-registry: false   #表示自己就是注册中心,职责是维护服务实例,并不需要去检索服务service-url:defaultZone: http://eureka7002.com:7002/eureka/    #设置与eureka server交互的地址查询服务和注册服务都需要依赖这个地址

7002的配置文件

server:port: 7002eureka:instance:hostname: eureka7002.com #eureka服务端的实例名字client:register-with-eureka: false    #表识不向注册中心注册自己fetch-registry: false   #表示自己就是注册中心,职责是维护服务实例,并不需要去检索服务service-url:defaultZone: http://eureka7001.com:7001/eureka/     #设置与eureka server交互的地址查询服务和注册服务都需要依赖这个地址

第四步:修改映射文件【可选择性修改,不修改则用localhost】

第五步:修改8001/8002的Controller


注意:订单微服务的访问地址不能写死

改为这个:public static final String PAYMENT_URL = "http://CLOUD-PAYMENT-SERVICE";

第六步:开启负载均衡

使用@LoadBalanced注解赋予RestTemplate负载均衡的能力

第七步:开始测试
先要启动EurekaServer,7001/7002服务,再要启动服务提供者provider,8001/8002服务,访问:http://localhost/consumer/payment/get/31

7:Eureka和Zookeeper的比较
测试结果:
负载均衡效果达到,8001/8002端口交替出现

说明:
Ribbon和Eureka整合后Consumer可以直接调用服务而不用再关心地址和端口号,且该服务还有负载功能了

5:actuator微服务信息完善【可选择配置,不过建议配置上】

没配置之前:暴露了IP地址,点击该链接时无法查看到IP地址,这样不利于集群环境中检查

status一栏只显示IP和服务名称,这样不够友好,在Eureka节点下这样设置:

instance:instance-id: payment8001  #配置服务名称prefer-ip-address: true   #访问信息有IP信息提示#Eureka的自我保护机制相关lease-renewal-interval-in-seconds:  1  #Eureka客户端向服务端发送心跳的时间间隔,单位为秒(默认是30秒)lease-expiration-duration-in-seconds:  2 #Eureka服务端在收到最后一次心跳后等待时间上限,单位为秒(默认是90秒),超时将剔除服务

注意:配置actuator,需要引入

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

设置完成后的访问界面:

6:服务发现Discovery

1.对于注册进eureka里面的微服务,可以通过服务发现来获得该服务的信息

第一步:修改cloud-provider-payment8001的Controller

@GetMapping(value = "/payment/discovery")
public Object discovery(){List<String> services = discoveryClient.getServices();for (String element : services) {log.info("***** element:"+element);}List<ServiceInstance> instances = discoveryClient.getInstances("CLOUD-PAYMENT-SERVICE");for (ServiceInstance instance : instances) {log.info(instance.getServiceId()+"\t"+instance.getHost()+"\t"+instance.getPort()+"\t"+instance.getUri());}return this.discoveryClient;
}

第二步:8001主启动类上加上注解:@EnableDiscoveryClient
第三步:测试

先要启动EurekaServer,7001/7002服务
再启动8001主启动类,需要稍等一会
访问: http://localhost:8001/payment/discovery

7:Eureka的自我保护机制

我们有时候把微服务注册到服务中心,过了十几分钟后,会观察到如下内容的红字

这就是自我保护机制在起作用

为什么会产生自我保护机制?

  • 什么是自我保护模式?
    默认情况下,如果EurekaServer在一定时间内没有接收到某个微服务实例的心跳, EurekaServer将会注销该实例 (默认90秒)。 但是当网络分区故障发生时,微服务与EurekaServer之间无法正常通信,以上行为可能变得非常危险了,因为微服务本身其实是健康的,此时本不应该注销这个微服务。Eureka通过 “自我保护模式”来解决这个问题一当EurekaServer节 点在短时间内丢失过多客户端时(可能发生了网络分区故障),那么这个节点就会进入自我保护模式。
  • 一旦进入该模式,EurekaServer就会保护服务注册表中的信息,不再删除服务注册表中的数据(也就是不会注销任何微服务)。当网络故障恢复后,该Eureka Server节点会自动退出自我保护模式
  • 在自我保护模式中,Eureka Server会保护服务注册表中的信息,不再注销任何服务实例。当它收到的心跳数重新恢复到阈值以上时,该Eureka Server节点就会自动退出自我保护模式。它的设计哲学就是宁可保留错误的服务注册信息,也不盲目注销任何可能健康的服务实例。一句话讲解:好死不如赖活着
  • 综上,自我保护模式是一种应对网络异常的安全保护措施。它的架构哲学是宁可同时保留所有微服务(健康的微服务和不健康的微服务都会保留),也不盲目注销任何健康的微服务。使用自我保护模式,可以让Eureka集群更加的健壮、稳定。(好比,学生生病了,学校不可以直接取消他的学籍,而是保留他学籍,等病好了继续上课)
  • 怎么禁止自我保护(一般生产环境中不会禁止自我保护)?
  • 注册中心eureakeServer端7001:
    1.出厂默认,自我保护机制是开启的:eureka.server.enable-self-preservation = true
    2.使用eureka.server.enable-self-preservation = false可以禁用自我保护模式
  • 生产者客户端eureakeClient端8001
    1.默认情况:
    eureka.instance.lease-renewal-interval-in-seconds=30(Eureka客户端向服务端发送心跳的时间间隔,单位为秒,默认是30秒)
    eureka.instance.lease-expiration-duration-in-seconds=90(Eureka服务端自收到最后一次心跳的等待时间上限,单位为秒,默认是90秒)
    2.修改成
    eureka.instance.lease-renewal-interval-in-seconds=1
    eureka.instance.lease-expiration-duration-in-seconds=2
    著名的CAP理论指出,一个分布式系统不可能同时满足C(一致性)、 A(可用性)和P(分区容错性)。由于分区容错性P在是分布式系统中必须要保证的,因此我们只能在A和C之间进行权衡。
    3.测试关闭自我保护
    7001和8001都配置完成,先启动7001再启动8001,先关闭8001
    结果:发现8001服务马上被删除

Zookeeper保证的是CP,
Eureka则是AP。

Zookeeper保证的是CP
当向注册中心查询服务列表时,我们可以容忍注册中心返回的是几分钟以前的注册信息,但不能接受服务直接down掉不可用。也就是说, 服务注册功能对可用性的要求要高于一 致性。但是会出现这样一 种情况,当master节 点因为网络故障与其他节点失去联系时,剩余节点会重新进行leader选举。问题在于,选举leader的时间太长,30 ~ 120s, 且选举期间整个集群都是不可用的,这就导致在选举期间注册服务瘫痪。 在云部署的环境下,因网络问题使得集群失去master节点是较大概率会发生的事, 虽然服务能够最终恢复, 但是漫长的选举时间导致的注册长期不可用是不能容忍的。

Eureka保证AP
Eureka看明白了上面这一点, 因此在设计时就优先保证可用性。Eureka各 个节点都是平等的,几个节点挂掉不会影响正常节点的工作,剩余的节点依然可以提供注册和查询服务。**而Eureka的客户端在向某个Eureka注册或时如果发现连接失败,则会自动切换至其它节点,只要有一台Eureka还在,就能保证注册服务可用(保证可用性),只不过查到的信息可能不是最新的(不保证强一致性)。**除此之外,Eureka还有一 种自我保护机制,如果在1 5分钟内超过85%的节点都没有正常的心跳,那么Eureka就认为客户端与注册中心出现了网络故障,此时会出现以下几种情况:

Eureka不再从注册列表中移除因为长时间没收到心跳而过期的服务
Eureka仍然能够接受新服务的注册和查询请求,但是不会被同步到其它节点上(即保证当前节点依然可用)
当网络稳定时,当前实例新的注册信息会被同步到其它节点中
因此,Eureka可以很好的应对因网络故障 导致部分节点失去联系的情况,而不会像zookeeper那样使整个注册服务瘫痪。

SpringCloud(二)——Eureka的使用和集群搭建相关推荐

  1. Spring Cloud(一)Eureka Server-单体及集群搭建

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

  2. eureka注册中心HA集群搭建

    今天我们讲一下高可用的eureka注册中心(eureka server cluster) SpringCloud支持Eureka.Zookeeper.Consul作为注册中心,这里我们选择Eureka ...

  3. Spark学习(二)Spark高可用集群搭建

    1.下载Spark安装包 官网网址:http://spark.apache.org/downloads.html 2.Spark安装过程 2.1.上传并解压缩 [potter@potter2 ~]$ ...

  4. 第二节HDFS完全分布式集群搭建与配置及常见问题总结

    提示:此文章内容超级全面和详细 文章目录 前言 一.HDFS完全分布式集群是什么? 二.HDFS完全分布式集群搭建与配置 1.HDFS完全分布式集群搭建库 2.HDFS完全分布式集群搭建配置 HDFS ...

  5. Windows下Kafka集群搭建

    一.Windows下Zookeeper集群搭建. 1.集群版本:2.8.1,3.0版本不再支持JDK8,不在需要Zookeeper. 2.Zookeeper版本:3.8.0. 3.Zookeeper三 ...

  6. SpringCloud(三)Eureka之集群搭建以及将服务注册到多个EurekaServer

    概述:为了保证EurekaServer的高可用,可以采用服务集群方式.当有一台挂掉时,其他节点仍可以继续提供服务.在EurekaServer的集群配置中,他们为分别配置对方为自己的注册中心,并将自己节 ...

  7. 《SpringCloud超级入门》使用Eureka集群搭建《十三》

    前面我们搭建的注册中心只适合本地开发使用,在生产环境中必须搭建一个集群来保证高可用.Eureka 的集群搭建方法很简单:每一台 Eureka 只需要在配置中指定另外多个 Eureka 的地址就可以实现 ...

  8. 疯狂Spring Cloud连载(5)Eureka集群搭建

    2019独角兽企业重金招聘Python工程师标准>>> 本文节选自<疯狂Spring Cloud微服务架构实战> 京东购买地址:https://item.jd.com/1 ...

  9. 浅谈SpringCloud (二) Eureka服务发现组件

    上面学习到了如何由一个程序访问另一个程序,那么如果使用SpringCloud来进行访问,该如何访问呐? 可以借助Eureka服务发现组件进行访问. 可以借助官方文档:https://spring.io ...

最新文章

  1. CoreCLR源码探索(八) JIT的工作原理(详解篇)
  2. leetcode116. 填充每个节点的下一个右侧节点指针(层序遍历07)
  3. 海归硕士程序员吐槽:我回国竟然找不到工作,这到底是什么操作?
  4. 15数字华容道解法 图解_密不外传的点穴秘技:15个穴位的取穴、点法、解法(上)...
  5. 梯度锐化拉普拉斯锐化比较_锐化斧头
  6. 第八届蓝桥杯第五题取数位
  7. python3.7升级pip_完美解决python3.7 pip升级 拒绝访问问题
  8. 【iOS-Cocos2d游戏开发之二十一 】自定义精灵类并为你的精灵设置***帧以及动画创建!【二】...
  9. 基于单片机智能自动浇花控制系统设计(毕业设计)
  10. 软件测试的标准操作流程
  11. nmap扫描常用命令
  12. OpenRisc-27-wishbone接口的vga ipcore的分析与仿真
  13. 哈希表 matlab实现,MATLAB中的哈希表
  14. s32k118开发环境搭建
  15. shell中遍历字符串
  16. Logistic Regression 逻辑斯蒂回归
  17. 321影音代码(万能播放器)源码
  18. iPhone 6 图像渲染揭秘
  19. 「从零开始造 RPC 轮子系列」01 我为什么要去造一个轮子?
  20. 小程序swiper高度自适应

热门文章

  1. android auto只能用谷歌地图吗,谷歌独立车载系统 新版Android Auto无需汽车兼容
  2. h5发送短信以及判别用户浏览器版本
  3. 北风python培训
  4. CentOS 8 安装视频网站与流媒体直播Nginx-http-flv-module模块
  5. 拉格朗日插值法与牛顿插值多项式
  6. SLAM--VICP(Velocity Updating Iterative Closest Point Algorithm)学习笔记
  7. selenium常用的浏览器窗口操作
  8. 逻辑回归python正则化 选择参数_SKlearn_逻辑回归小练习
  9. Linux_mv命令移动文件夹下所有文件以及“Argument list too long”问题的解决方法
  10. 【Spark | SparkStreaming】