0
点赞
收藏
分享

微信扫一扫

Eureka

黎轩的闲暇时光 2022-04-03 阅读 37
eureka

理论知识

1.基本概念

  • 原理图在这里插入图片描述
  • Eureka Server：注册中心服务端
对外提供三个功能：
1.服务注册：服务提供者启动时，向Eureka Server注册信息，Eureka Server存储该信息
	Eureka Server内部有两层缓存机制来维护整个注册表
2.提供注册表：服务消费者调用服务时，Eureka Client未缓存注册表，则会从Eureka Server获取最新的注册表
3.同步状态：Eureka Client通过注册、心跳机制和Eureka Server同步当前客户端的状态
	心跳机制：Eureka Client每隔30秒发送一次心跳来续约(服务续约)，通过续约告知注册中心服务端该服务提供者是否正常运行，默认90秒未收到续约信号则会将该服务提供者从注册列表中删除(服务剔除)
		续约间隔配置：eureka.instance.lease-renewal-interval-in-seconds=30
		服务失效时间：eureka.instance.lease-expiration-duration-in-seconds=90
  • Eureka Client：注册中心客户端
Eureka Client会拉取、更新和缓存Eureka Server中的信息，当所有的Eureka Server节点都掉线，服务消费者依然可以通过缓存中信息找到服务提供者信息，但服务有变更时会出现信息不一致
  • Cancel: 服务下线
服务下线不会自动完成，手动调用DiscoveryManager.getInstance().shutdownComponent()；
  • GetRegisty: 获取注册列表信息
默认情况下Eureka Client使用JSON格式获取注册列表的信息
	启用服务消费者从注册中心获取注册列表配置：eureka.client.fetch-registry=true
	设置服务消费者从注册中心拉取服务列表的间隔：eureka.client.registry-fetch-interval-seconds=30
  • Remote Call: 远程调用
服务消费者从注册中心获取到服务提供者信息后，可通过Http请求调用对应的服务
当服务提供者有多个时，服务消费者通过Ribbon自动进行负载均衡

2.自我保护机制

  • 出现
微服务架构内服务之间通常是跨进程调用，网络通信面临各种问题，	Eureka Server在90秒之内未收到续约则会注销该实例，而大量的实例注销严重威胁整个微服务架构的可用性，此时推出自我保护机制
  • 含义
Eureka Server在运行期间统计心跳失败比例在 15分钟内是否低于85%，如果低于85%，Eureka Server即会进入自我保护机制

当个别客户端出现心跳失联时，则认为是客户端的问题，剔除掉客户端
当Eureka捕获到大量的心跳失败时，则认为可能是网络问题，进入自我保护机制
当客户端心跳恢复时，Eureka会自动退出自我保护机制
  • 用于防止误杀服务
  • 配置参数
eureka.server.enable-self-preservation=true

配置

1.基础配置

  • 配置内容
1.基础连接配置
2.应用名+实例名
  • 服务端 Eureka Server
<dependency>
	<groupId>org.springframework.cloud</groupId>
	<artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>

-------------------------------------------------------
@SpringBootApplication
@EnableEurekaServer//启动服务器
class EurekaServer {
    public static void main(String[] args) {
        SpringApplication.run(EurekaServer.class, args);
    }
}

application.yml----------------------------------------
server:
  port: 8101 #端口
eureka:
  instance:
    hostname: localhost
  client:
    register-with-eureka: false #当前客户端是否注册到eureka
    fetch-registry: false #是否从服务端获取其他服务地址
    serviceUrl:
      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
spring:
  application:
    name: eureka-server
  • 客户端 Provider
<dependency>
	<groupId>org.springframework.cloud</groupId>
	<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

-------------------------------------------------------
@SpringBootApplication
@EnableEurekaClient//启用eureka的服务提供者
class Provider {
    public static void main(String[] args) {
        SpringApplication.run(Provider.class, args);
    }
}

application.yml----------------------------------------
spring:
  application:
    name: microservice-provider-product #注册到eureka中的应用名
eureka:
  client:
    service-url:
      defaultZone: http://localhost:8101/eureka/ #注册中心服务端地址
  instance:
    instance-id: microservice-provider-product_1 #实例名：一个应用有多个微服务

2.启动监控器Acurator

  • 客户端 Provider
<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

application.yml----------------------------------------
#打开actuator中端口，默认情况这些端点都没有开放
management:
  endpoints:
    web:
      exposure:
        include: "*"  #在yml中 * 是特殊意义的关键字，加""
        
spring:
  application:
    name: microservice-provider-product #注册到eureka中的应用名
eureka:
  client:
    service-url:
      defaultZone: http://localhost:8101/eureka/
  instance:
    instance-id: microservice-provider-product_1 #实例名：一个应用有多个微服务
    metadata-map:
      management:
        context-path: ${server.servlet.context-path}/actuator  #server中配置content-path,防止覆盖,所以重新映射actuator路径

3.关闭自我保护机制+配置续约刷新间隔

  • 服务端 Eureka Server
server:
  port: 8101 #端口
eureka:
  instance:
    hostname: localhost
  client:
    register-with-eureka: false #当前应用的客户端是否注册到eureka
    fetch-registry: false #是否从服务端获取其他服务地址
    serviceUrl:
      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
  server:
    eviction-interval-timer-in-ms: 1000  #清理服务注册列表的间隔时间(清除掉线的，默认情况60s)
    enable-self-preservation: false  #是否启用自我保护模式(默认关闭)
spring:
  application:
    name: eureka-server
  • 客户端 Provider
spring:
  application:
    name: microservice-provider-product #注册到eureka中的应用名
eureka:
  client:
    service-url:
      defaultZone: http://localhost:8101/eureka/
  instance:
    instance-id: microservice-provider-product_1 #实例名：一个应用有多个微服务
    metadata-map:
      management:
        context-path: ${server.servlet.context-path}/actuator  #server中配置content-path,防止覆盖,所以重新映射actuator路径
    lease-renewal-interval-in-seconds: 2  #设置客户端向服务端发送心跳信息的时间间隔(默认:30s)
    lease-expiration-duration-in-seconds: 6  #设置服务器如果6秒都没有接到心跳，则将此客户端的租约设为超期

4.在客户端获取eureka配置信息

  • 方法1：原生EurekaClient(netflix)对象
@Autowired
private EurekaClient eurekaClient;

@RequestMapping("/eurekaClient")
public Object discovery(){
    System.out.println("客户端配置信息:" + this.eurekaClient.getEurekaClientConfig());
    System.out.println("服务端应用列表:"+   this.eurekaClient.getApplications());
    return this.eurekaClient.getAllKnownRegions();//["us-east-1"]
}
  • 方法2：DiscoveryClient(springcloud)对象
@SpringBootApplication
@EnableDiscoveryClient//启用springcloud的   discoveryClient
public class ProviderProductApp {
    public static void main(String[] args) {
        SpringApplication.run(  ProviderProductApp.class, args);
    }
}
-------------------------------------------
@Autowired
private DiscoveryClient discoveryClient;

@RequestMapping("/discoveryClient")
public Object springCloudDiscoveryClient(){
    System.out.println(this.discoveryClient.description());
    System.out.println("注册的服务名:"+this.discoveryClient.getServices());
    return this.discoveryClient;
}

5.在服务端加入安全配置security

  • 服务端有许多服务信息，需要增强安全性
  • 服务端 Eureka Server
<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-security</artifactId>
</dependency>

application.yml----------------------------------------
server:
  port: 8101 #端口
eureka:
  instance:
    hostname: localhost
  client:
    register-with-eureka: false #当前客户端是否注册到eureka
    fetch-registry: false #是否从服务端获取其他服务地址
    serviceUrl:
      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
spring:
  application:
    name: eureka-server
  security:
    user:
      name: admin #安全机制：增加登录
      password: a
      
-------------------------------------------------------
//增加一个类，在eureka中关闭csrf(csrf:攻击者盗用你的信息，以你的名义发送恶意请求)
@EnableWebSecurity
class WebSecurityConfig extends WebSecurityConfigurerAdapter {
    @Override
    protected void configure(HttpSecurity http) throws Exception {
        http.csrf().disable();//取消csrf()
        super.configure(http);
    }
}
  • CSRF原理
    在这里插入图片描述
  • 客户端 Provider
//服务提供者登录到eureka服务器注册服务时需要加上用户名密码
defaultZone: http://admin:a@localhost:8101/eureka/

Eureka集群

1.理论

  • 一个分布式系统不可能同时满足以下三种
1.一致性（C:Consistency）
	在分布式环境中，一致性指数据在多个副本之间保持数据一致
	在一致性的需求下，当一个系统在数据一致的状态下执行更新操作后，应保证系统的数据仍然处于一致状态
	例如一个将数据副本分布在不同分布式节点上的系统来说，如果对第一个节点的数据进行了更新操作并且更新成功后，其他节点上的数据也应该得到更新，并且所有用户都可以读取到其最新的值，那么这样的系统就被认为具有强一致性（或严格的一致性，最终一致性）
	一致性要求节点少(节点越少，数据同步的消耗就小)，但带来的节点少却又造成服务的可用性差
2.可用性（A:Available）
	在分布式环境中，可用性指系统提供的服务必须一直处于可用的状态，对于用户的每一个操作请求总是能够在有限的时间内返回结果
	高可用无非就是增加节点，但很多节点之间的数据同步是一种消耗，极其容易造成数据不一致
3.分区容错性（P:Partition Tolerance）
	分布式系统在遇到任何网络分区故障的时候，仍然需要能够保证对外提供满足一致性和可用性的服务，除非是整个网络环境都发生了故障
	必须保证

P必须要保证，CA任意保证一个
  • CP
ZooKeeper保证的是CP
	1.当master节点因网络故障而数去联系时，需重新选举leader，但选举leader时间太长，且选举期间整个eureka集群不可用，导致不保证可用性
	2.为保证一致性，ZooKeeper做了两类同步：初始化同步+更新同步
		当ZooKeeper发现超过半数的Follower同步超时，则其会再次进行同步，且该期间整个eureka集群不可用
  • AP
Spring Cloud集成的Eureka采用的是AP原则(牺牲一致性 保证可用性)
	一个节点挂掉剩下正常工作的节点任然可以提供注册和查询服务
	一般配置的节点是奇数个
  • CA
不是分布式架构就使用这种
关系数据库按照CA进行设计，放弃分区容错性

2.配置

  • 域名映射
    在这里插入图片描述
    在这里插入图片描述
  • eureka1—application.yml
server:
  port: 8101 #端口
eureka:
  instance:
    hostname: eureka1 #c:\windows\system32\drivers\etc 域名映射
  client:
    register-with-eureka: false #当前客户端是否注册到eureka
    fetch-registry: false #是否从服务端获取其他服务地址
    serviceUrl:
      defaultZone: http://admin:a@eureka1:8101/eureka,http://admin:a@eureka2:8102/eureka,http://admin:a@eureka3:8103/eureka
    server:
      eviction-interval-timer-in-ms: 1000  #清理服务注册列表的间隔时间(清除掉线的，默认情况60s)
      enable-self-preservation: false  #是否启用自我保护模式(默认关闭)
spring:
  application:
    name: eureka-server1
  security:
    user:
      name: admin #安全机制：增加登录
      password: a
  • eureka2—application-second.yml
server:
  port: 8102
eureka:
  instance:
    hostname: eureka2
spring:
  application:
    name: eureka-server2
  • eureka3—application-third.yml
server:
  port: 8103
eureka:
  instance:
    hostname: eureka3
spring:
  application:
    name: eureka-server3
  • provide–application.yml
server:
  port: 8081
  servlet:
    session.timeout: 60000
    contextpath: /
spring:
  application:
    name: microservice-provider-product #注册到eureka中的应用名
#打开actuator中端口，默认情况这些端点都没有开放
management:
  endpoints:
    web:
      exposure:
        include: "*"  #在yml中 * 是特殊意义的关键字，加""
eureka:
  client:
    service-url:
      defaultZone: http://admin:a@eureka1:8101/eureka/,http://admin:a@eureka2:8102/eureka/,http://admin:a@eureka3:8103/eureka/
  instance:
    instance-id: microservice-provider-product_1 #实例名：一个应用有多个微服务
    metadata-map:
      management:
        context-path: ${server.servlet.context-path}/actuator  #server中配置content-path,防止覆盖,所以重新映射actuator路径
    lease-renewal-interval-in-seconds: 2  #设置客户端向服务端发送心跳信息的时间间隔(默认:30s)
    lease-expiration-duration-in-seconds: 6  #设置服务器如果6秒都没有接到心跳，则将此客户端的租约设为超期
  • provide–application-second.yml
server:
  port: 8082
eureka:
  instance:
    instance-id: microservice-provider-product_2
举报

相关推荐

Eureka Server和Eureka Client

powerpoint压力测试

Eureka总结

eurekaspringspring cloud

四. Eureka

eurekajavaspring cloudspringboot

Eureka详解

eureka大数据

Eureka入门

elementui前端javascript

Eureka使用

eureka云原生cloud native

eureka定义

eurekajava云原生

Eureka（三）eureka集群的实现原理

java技术理解java学习之路Java 杂谈Java

Eureka系列---【Eureka如何实现高可用？】

配置文件重启解决方案编程语言

Eureka学习

eurekajava云原生
0 条评论