2.SpringCloud组件之Eureka

[toc]

Eureka注册中心

1. 简介

• Eureka是Netflix开发的服务发现框架，本身是一个基于REST的服务，主要用于定位运行在AWS域中的中间层服务，以达到负载均衡和中间层服务故障转移的目的。SpringCloud将它集成在其子项目spring-cloud-netflix中，以实现SpringCloud的服务发现功能。
• Eureka包含两个组件：Eureka Server和Eureka Client。
• Eureka Server提供服务注册服务，各个节点启动后，会在Eureka Server中进行注册，这样EurekaServer中的服务注册表中将会存储所有可用服务节点的信息，服务节点的信息可以在界面中直观的看到。
• Eureka Client是一个java客户端，用于简化与Eureka Server的交互，客户端同时也就是一个内置的、使用轮询(round-robin)负载算法的负载均衡器。
• 在应用启动后，将会向Eureka Server发送心跳,默认周期为30秒，如果Eureka Server在多个心跳周期内没有接收到某个节点的心跳，Eureka Server将会从服务注册表中把这个服务节点移除(默认90秒)。
• Eureka Server之间通过复制的方式完成数据的同步，Eureka还提供了客户端缓存机制，即使所有的Eureka Server都挂掉，客户端依然可以利用缓存中的信息消费其他服务的API。综上，Eureka通过心跳检查、客户端缓存等机制，确保了系统的高可用性、灵活性和可伸缩性。

1.1 问题分析

1. 在刚才的案例中，justweb-service-provider对外提供服务，需要对外暴露自己的地址。而consumer（调用者）需要记录服务提供者的地址。将来地址出现变更，还需要及时更新。这在服务较少的时候并不觉得有什么，但是在现在日益复杂的互联网环境，一个项目肯定会拆分出十几，甚至数十个微服务。此时如果还人为管理地址，不仅开发困难，将来测试、发布上线都会非常麻烦，这与DevOps的思想是背道而驰的。

2. 这就好比是 网约车出现以前，人们出门叫车只能叫出租车。一些私家车想做出租却没有资格，被称为黑车。而很多人想要约车，但是无奈出租车太少，不方便。私家车很多却不敢拦，而且满大街的车，谁知道哪个才是愿意载人的。一个想要，一个愿意给，就是缺少引子，缺乏管理啊。

3. 此时滴滴这样的网约车平台出现了，所有想载客的私家车全部到滴滴注册，记录你的车型（服务类型），身份信息（联系方式）。这样提供服务的私家车，在滴滴那里都能找到，一目了然。

4. 此时要叫车的人，只需要打开APP，输入你的目的地，选择车型（服务类型），滴滴自动安排一个符合需求的车到你面前，为您服务。

1.2 Eureka能做什么？

1. Eureka就好比是滴滴，负责管理、记录服务提供者的信息。服务调用者无需自己寻找服务，而是把自己的需求告诉Eureka，然后Eureka会把符合你需求的服务告诉你。

2. 同时，服务提供方与Eureka之间通过“心跳”机制进行监控，当某个服务提供方出现问题，Eureka自然会把它从服务列表中剔除。

3. 这就实现了服务的自动注册、发现、状态监控。

1.3 Eureka原理图

• Eureka：就是服务注册中心（可以是一个集群），对外暴露自己的地址。
• 提供者：启动后向Eureka注册自己信息（地址，提供什么服务）。
• 消费者：向Eureka订阅服务，Eureka会将对应服务的所有提供者地址列表发送给消费者，并且定期更新。
• 心跳(续约)：提供者定期通过http方式向Eureka刷新自己的状态。

2. Eureka入门案例–搭建Eureka服务

• 依然使用spring提供的快速搭建工具：搭建Eureka服务
• ==选择依赖==：EurekaServer–服务注册中心依赖
• 对于eureka来说：服务提供方和服务消费方都属于客户端
• pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.6.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    
    <groupId>cn.justweb</groupId>
    <artifactId>justweb-eureka</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>justweb-eureka</name>
    <description>Demo project for Spring Boot</description>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
        <spring-cloud.version>Finchley.SR2</spring-cloud.version>
    </properties>

    <dependencies>

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

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupId>org.junit.vintage</groupId>
                    <artifactId>junit-vintage-engine</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

    </dependencies>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

2.1 编写application.yml

# 端口
server:
  port: 10087 
  
spring:
  application:
    #应用名称，会在eureka中显示
    name: eureka-server
    
eureka:
  client:
    service-url:
      #eureka的服务器地址,现在是自己的地址
      #如果是集群的话，需要指定其他服务器的地址
      defaultZone: http://localhost:10086/eureka

2.2 修改引导类

/**
 * @EnableEurekaServer声明当前应用是一个eureka的服务中心
 * */
@SpringBootApplication
@EnableEurekaServer
public class JustwebEurekaApplication {

    public static void main(String[] args) {
        SpringApplication.run(JustwebEurekaApplication.class, args);
    }

}

启动服务，并访问：http://127.0.0.1:10086 就可以访问到Eureka的面板。

3. 注册到Eureka–搭建Eureka的客户端

注册服务，就是在服务上添加Eureka的客户端依赖，客户端代码会自动把服务注册到EurekaServer中。

3.1 注册服务步骤

1. 在pom.xml中，添加springcloud的相关依赖。
2. 在application.yml中，添加springcloud的相关依赖。
3. 在引导类上添加注解，把服务注入到eureka注册中心。

3.1.1 添加依赖

<!-- SpringCloud的依赖 -->
<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>Finchley.SR2</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>

<!-- Eureka客户端 -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

3.1.2 继续配置application.yml

spring:
  application:
  # 应用名称，注册到eureka后的服务名
    name: service-provider 

eureka:
  client:
    service-url: # EurekaServer地址
      defaultZone: http://127.0.0.1:10086/eureka

3.1.3 修改引导类

//@EnableEurekaClient这个也行，开启Eureka客户端功能

@SpringBootApplication
@EnableDiscoveryClient
public class JustwebServiceProviderApplication {

    public static void main(String[] args) {
        SpringApplication.run(JustwebServiceProviderApplication.class, args);
    }

}

重启项目，访问Eureka监控页面查看，我们发现service-provider服务已经注册成功了！

4. 获取Eureka中的服务

• 接下来我们修改justweb-service-consumer，尝试从EurekaServer获取服务。

• 方法与消费者类似，只需要在项目中添加EurekaClient依赖，就可以通过服务名称来获取信息了！

4.1 配置步骤

与justweb-service-provider相似！

4.1.1 添加依赖

pom.xml

<!-- SpringCloud的依赖 -->
<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>Finchley.SR2</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>

 <!-- Eureka客户端 -->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>

4.1.2 继续配置application.yml

eureka:
  client:
    service-url:
      defaultZone: http://localhost:10086/eureka
spring:
  application:
    name: service-consumer

4.1.3 修改引导类

/**
*@EnableEurekaClient  开启Eureka客户端功能
*@EnableDiscoveryClient   开启Eureka客户端功能
*@LoadBalanced  设置负载均衡
**/
@SpringBootApplication
@EnableDiscoveryClient
public class JustwebServiceConsumerApplication {
    
    @Bean
    @LoadBalanced
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }

    public static void main(String[] args) {
        SpringApplication.run(JustwebServiceConsumerApplication.class, args);
    }

}

4.1.4 修改消费端的UserController.java

@Controller
@RequestMapping("/consumer/user")
public class UserController {


    @Autowired
    private RestTemplate restTemplate;

    //eureka的客户端可以获取到eureka中的服务
    @Autowired
    private DiscoveryClient discoveryClient;


    @GetMapping
    @ResponseBody
    public User queryUserById(@RequestParam("id") Long id){
        //User user = this.restTemplate.getForObject("http://localhost/user/queryById/" + id, User.class);
        
        //根据服务名称，获取实例，有可能是集群，所以service实例是个集合，从中取出第一个实例
        ServiceInstance instance = discoveryClient.getInstances("SERVICE-PROVIDER").get(0);
        String url = "http://"+instance.getHost()+":"+instance.getPort()+"/user/queryById/"+id;
        //String url = "http://service-provider/user/queryById/"+id;
        User user = this.restTemplate.getForObject(url, User.class);
        return user;
    }

}

5. 小结

5.1 Eureka架构中的三个核心角色

• 服务注册中心-->justweb-eureka

  Eureka的服务端应用，提供服务注册和发现功能

• 服务提供者-->justweb-service-provider。

  提供服务的应用，可以是SpringBoot应用，也可以是其它任意技术实现，只要对外提供的是Rest风格服务即可。

• 服务消费者-->justweb-service-consumer

  消费应用从注册中心获取服务列表，从而得知每个服务方的信息，知道去哪里调用服务方。

• 源码地址：https://gitee.com/duanchaojie/dl.git

☆