美文网首页
Spring Cloud register-server(eur

Spring Cloud register-server(eur

作者: Lano_chazz | 来源:发表于2018-02-27 16:53 被阅读0次

    基本架构

    主要包含三个组件:Eureka Server、Service Provider、Service Consumer。

    Service Provider会向Eureka Server做Register(服务注册)、Renew(服务续约)、Cancel(服务下线)等操作。
    Eureka Server之间会做注册服务的同步,从而保证状态一致
    Service Consumer会向Eureka Server获取注册服务列表,并消费服务

    Eureka Server

    • 提供服务注册和发现

    • mvn依赖:

    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-eureka-server</artifactId>
    </dependency>
    
    • 启动Eureka Server:
      加上@EnableEurekaServer即可
    @EnableEurekaServer
    @SpringBootApplication
    public class EurekaServiceApplication {
      public static void main(String[] args) {
        SpringApplication.run(EurekaServiceApplication.class, args);
      }
    }
    

    Service Provider

    • 服务提供方
    • 将自身服务注册到Eureka,从而使服务消费方能够找到
    • mvn依赖:
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-eureka</artifactId>
    </dependency>
    
    • 启动Service Provider:
      加上@EnableDiscoveryClient即可
    @EnableDiscoveryClient
    @SpringBootApplication
    public class ReservationServiceApplication {
      public static void main(String[] args) {
        new SpringApplicationBuilder(ReservationServiceApplication.class)
                .run(args);
      }
    }
    

    Service Consumer

    • 服务消费方

    • 从Eureka获取注册服务列表,从而能够消费服务

    • 启动Service Consumer

      启动Service Consumer其实和Service Provider一样,因为本质上Eureka提供的客户端是不区分Provider和Consumer的,一般情况下,Provider同时也会是Consumer。

    • 通过dc.getInstances("reservation-service")就能获取到当前所有注册的reservation-service服务。

    @EnableDiscoveryClient
    @SpringBootApplication
    public class ReservationClientApplication {
      @Bean
      CommandLineRunner runner(DiscoveryClient dc) {
        return args -> {
          dc.getInstances("reservation-service")
                  .forEach(si -> System.out.println(String.format(
                          "Found %s %s:%s", si.getServiceId(), si.getHost(), si.getPort())));
        };
      }
      public static void main(String[] args) {
        SpringApplication.run(ReservationClientApplication.class, args);
      }
    }
    
    • 节点间更新频率的设置,这个方法的默认实现是从配置文件读取,所以如果Eureka Server节点相对固定的话,可以通过在配置文件中配置来实现。
    eureka.server.peerEurekaNodesUpdateIntervalMs
    
    • Renew功能配置
      • eureka.instance.leaseRenewalIntervalInSeconds

        Renew频率。默认是30秒,也就是每30秒会向Eureka Server发起Renew操作。

      • eureka.instance.leaseExpirationDurationInSeconds

        服务失效时间。默认是90秒,也就是如果Eureka Server在90秒内没有接收到来自Service Provider的Renew操作,就会把Service Provider剔除。

    Service Consumer在启动时会从Eureka Server获取所有服务列表,并在本地缓存。需要注意的是,需要确保配置eureka.client.shouldFetchRegistry=true。

    由于在本地有一份缓存,所以需要定期更新,定期更新频率可以通过eureka.client.registryFetchIntervalSeconds配置。

    其他配置信息

    • eureka.client.registry-fetch-interval-seconds

      表示eureka client间隔多久去拉取服务注册信息,默认为30秒,对于api-gateway,如果要迅速获取服务注册状态,可以缩小该值,比如5秒

    • eureka.instance.lease-expiration-duration-in-seconds

      leaseExpirationDurationInSeconds,表示eureka server至上一次收到client的心跳之后,等待下一次心跳的超时时间,在这个时间内若没收到下一次心跳,则将移除该instance。默认为90秒,如果该值太大,则很可能将流量转发过去的时候,该instance已经不存活了。如果该值设置太小了,则instance则很可能因为临时的网络抖动而被摘除掉。该值至少应该大于leaseRenewalIntervalInSeconds

    • eureka.instance.lease-renewal-interval-in-seconds

      leaseRenewalIntervalInSeconds,表示eureka client发送心跳给server端的频率。如果在leaseExpirationDurationInSeconds后,server端没有收到client的心跳,则将摘除该instance。除此之外,如果该instance实现了HealthCheckCallback,并决定让自己unavailable的话,则该instance也不会接收到流量。默认30秒

    • eureka.server.enable-self-preservation

      是否开启自我保护模式,默认为true。默认情况下,如果Eureka Server在一定时间内没有接收到某个微服务实例的心跳,Eureka Server将会注销该实例(默认90秒)。但是当网络分区故障发生时,微服务与Eureka Server之间无法正常通信,以上行为可能变得非常危险了——因为微服务本身其实是健康的,此时本不应该注销这个微服务。Eureka通过“自我保护模式”来解决这个问题——当Eureka Server节点在短时间内丢失过多客户端时(可能发生了网络分区故障),那么这个节点就会进入自我保护模式。一旦进入该模式,Eureka Server就会保护服务注册表中的信息,不再删除服务注册表中的数据(也就是不会注销任何微服务)。当网络故障恢复后,该Eureka Server节点会自动退出自我保护模式。综上,自我保护模式是一种应对网络异常的安全保护措施。它的架构哲学是宁可同时保留所有微服务(健康的微服务和不健康的微服务都会保留),也不盲目注销任何健康的微服务。使用自我保护模式,可以让Eureka集群更加的健壮、稳定。

    • eureka.server.eviction-interval-timer-in-ms

      eureka server清理无效节点的时间间隔,默认60000毫秒,即60秒

    #单例模式启动Eureka Server
    server:
      port: 8761 #启动端口
    eureka:
      client:
        registerWithEureka: false #false:不作为一个客户端注册到注册中心   
        fetchRegistry: false #为true时,可以启动,但报异常:Cannot execute request on any known server
    zuul:
      prefix: /techouse #为zuul设置一个公共的前缀
      #ignoredServices: '*'
      routes:
        cloud-client: #随便定义,当不存在serviceId时,默认该值为serviceId(就是注册服务的名称,属性spring.application.name)
          path: /usersystem/** #匹配/techouse/usersystem/** 均路由到cloud-client
          serviceId: cloud-client #指定路由到的serviceId
    ribbon:
      eureka:
        enabled: false #配置zuul路由时用将此属性设置为false
    
    cloud-client:
      ribbon:
        listOfServers: 127.0.0.1:8800 #为cloud-client服务指定一组服务地址,应该是用于负载均衡
    

    相关文章

      网友评论

          本文标题:Spring Cloud register-server(eur

          本文链接:https://www.haomeiwen.com/subject/raemxftx.html