Spring Cloud Netflix 之 Eureka

• Eureka
• 注册中心代码
• • 配置文件
• 客户端/服务提供者 代码
• • 部分配置
• 消费者/客户端代码
• • 配置客户端负载均衡（轮询）
  • 配置文件(和服务端差不多)
• 服务发现
• • 启动类
  • Controller
• Eureka自我保护

• 已经停更
• Eureka 是 Netflix 开发的，一个基于 REST 服务的，服务注册与发现的组件，以实现中间层服务器的负载平衡和故障转移。
• 它主要包括两个组件：Eureka Server 和 Eureka Client
  • Eureka Client：一个Java客户端，用于简化与 Eureka Server 的交互（微服务中的客户端和服务端）
  • Eureka Server：提供服务注册和发现的能力（微服务中的注册中心）
• 服务在Eureka上注册，然后每隔30秒发送心跳来更新它们的租约。如果客户端不能多次续订租约，那么它将在大约90秒内从服务器注册表中剔除。注册信息和更新被复制到集群中的所有eureka节点。来自任何区域的客户端都可以查找注册表信息（每30秒发生一次）来定位它们的服务（可能在任何区域）并进行远程调用

新版的依赖：

    org.springframework.cloud
    spring-cloud-starter-netflix-eureka-server



    org.springframework.cloud
    spring-cloud-starter-netflix-eureka-client

图形监控依赖:

    org.springframework.boot
    spring-boot-starter-actuator

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

server:
  port: 7001

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

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

server:
  port: 8001

spring:
  application:
    name: cloud-payment-service

eureka:
  client:
    #表示是否将自己注册进EurekaServer默认为true。
    register-with-eureka: true
    #是否从EurekaServer抓取已有的注册信息，默认为true。单节点无所谓，集群必须设置为true才能配合ribbon使用负载均衡
    fetchRegistry: true
    service-url:
      #单机版
#      defaultZone: http://localhost:7001/eureka
      # 集群版
      defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka
  instance:
      instance-id: payment8001 #实例名称
      prefer-ip-address: true #访问路径可以显示IP地址
      #Eureka客户端向服务端发送心跳的时间间隔，单位为秒(默认是30秒)
      #lease-renewal-interval-in-seconds: 1
      #Eureka服务端在收到最后一次心跳后等待时间上限，单位为秒(默认是90秒)，超时将剔除服务
      #lease-expiration-duration-in-seconds: 2

注册中心看到的两个payment服务：（红圈内的就是实例名称）

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

@Configuration
public class ApplicationContextConfig
{
    @Bean
    @LoadBalanced //客户端负载均衡
    public RestTemplate getRestTemplate()
    {
        return new RestTemplate();
    }
}

server:
  port: 80

spring:
    application:
        name: cloud-order-service

eureka:
  client:
    #表示是否将自己注册进EurekaServer默认为true。
    register-with-eureka: true
    #是否从EurekaServer抓取已有的注册信息，默认为true。单节点无所谓，集群必须设置为true才能配合ribbon使用负载均衡
    fetchRegistry: true
    service-url:
      #单机
#      defaultZone: http://localhost:7001/eureka
      # 集群
      defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka  # 集群版

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

@Resource
private DiscoveryClient discoveryClient;

@GetMapping(value = "/payment/discovery")
public Object discovery()
{
    List services = discoveryClient.getServices();
    for (String element : services) {
        log.info("*****element: "+element);
    }

    List 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;
}

• 一句话：某时刻某一个微服务不可用了，Eureka不会立刻清理，依旧会对该微服务的信息进行保存
• 默认情况下，如果客户端不能多次续订租约，那么它将在大约90秒内从服务器注册表中剔除；但如果在短时间内（90s内）丢失了大量的服务实例心跳（比如网络原因），eureka就会开启自我保护，不再剔除服务
• 属于CAP里面的AP分支