SpringCloud-2.0（5. 服务注册发现 - Eureka）

Posted 2021-06-30 ABin-阿斌

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了SpringCloud-2.0（5. 服务注册发现 - Eureka）相关的知识，希望对你有一定的参考价值。

我是 ABin-阿斌：写一生代码，创一世佳话，筑一揽芳华。如果小伙伴们觉得我的文章有点 feel ，那就点个赞再走哦。

上一篇：4. Rest工程构建

下一篇：6. 服务注册发现 - ZooKeeper

Eureka 已经停止更新

1 . 基础知识

1 . 什么是服务治理

SpringCloud 封装了 Netfilx 公司开发的 Eureka 模块来实现 服务治理
在传统的 RPC 远程调用框架中，管理每个服务与服务之间依赖关系比较复杂，导致管理比较复杂，所以需要使用服务治理，用来管理服务于服务之间的依赖关系，可以实现服务调用、负载均衡、容错……，实现服务注册与发现。

2 . 什么是服务注朋与发现

Eureka 采用了 CS 的设计架构， Eureka Server 作为服务注册功能的服务器，它是服务注阶中心。而系统中的其他微服务，使用 Eufeka 的客户端连接到 Eureka Server 并维持心跳连接。
这样系统的维护人员就可以通过 Eureka Server 来监控系统中各个微服务是否正常运行
在服务注册与发现中，有一个注册中心。当服务器启动的时候，会把当前自己服务器的信息，比如服务地址、通讯地址等以别名方式注册到注册中心上。
另一方（消费者 | 服务提供者），以该别名的方式去注册中心上获取到实际的服务通讯地址。然后再实现本地 RPC 调用 RPC 远程调用框架。
核心设计思想： 在于注册中心，因为使用注册中心管理每个服务与服务之间的一个依赖关系（服务治理概念）。在任何 RPC 远程框架中．都会有注册中心，存放服务地址相关信息（接口地址）

3 . Eureka 的两个组件

Eureka Server 提供服务注册服务
- 各个微服务节点通过配置启动后，会在 Eureka Server 中进行注册，这样 Eureka Server 中的服务注册表中将会存储所有可用服务节点的信息，服务节点的信息可用再界面中直观看到。
Eureka Client 通过注册中心进行访问
- 是一个 Java 客户端，用于简化 Eureka Server 的交互，客户端同时也具备一个内置的、使用轮询负载算法的负载均衡器。在应用启动后，将会向 Eureka Server 发送心跳（默认周期为 30 秒）。
- 如果 Eureka Server 在多个心跳周期内没有接收到某个节点的心跳，Eureka Server 将会从服务注册表中把这个服务节点移除（默认 90 秒）

2 . 单机 Eureka 构建

2.1 Eureka Server 注册中心

建立一个 Eureke Server 模块：cloud-eureka-server7001

修改 POM 文件

<dependencies>
    <!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-eureka-server -->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
    </dependency>

    <dependency>
        <groupId>com.demo.springcloud</groupId>
        <artifactId>cloud-api-commons</artifactId>
        <version>${project.version}</version>
    </dependency>

    <!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-web -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>

    <!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-web  -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-actuator</artifactId>
    </dependency>

    <!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-devtools -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-devtools</artifactId>
        <scope>runtime</scope>
        <optional>true</optional>
    </dependency>

    <!-- https://mvnrepository.com/artifact/org.projectlombok/lombok -->
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
    </dependency>

    <!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-test -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
    <dependency>
        <groupId>junit</groupId>
        <artifactId>junit</artifactId>
    </dependency>

</dependencies>

编写 YML

server:
  port: 7001

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

编写主启动类

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

启动该项目，测试

2.2 将 Provider 注册进去

修改 cloud-provider-payment-8001 项目

修改 POM 文件

添加 Eureka Client 依赖

 <!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-eureka-server -->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>

编写 YML

添加 Eureka 相关配置

eureka:
  client:
    register-with-eureka: true
    fetchRegistry: true
    service-url:
      defaultZone: http://localhost:7001/eureka

配置主启动类

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

启动测试

2.3 将 Consumer 注册进去

修改 cloud-consumer-order-80 项目

修改 POM 文件

 <!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-eureka-server -->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>

修改 YML

spring:
  application:
    name: cloud-order-service

eureka:
  client:
    register-with-eureka: true
    fetchRegistry: true
    service-url:
      defaultZone: http://localhost:7001/eureka

修改主启动类

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

启动测试

3 . Eureka 集群构建

3.1 Eureka Server

新建一个 Eureka Server 项目：cloud-eureka-server-7002
修改 POM 文件（复制 7001 的）
修改 Windows 的 Host 文件
- 修改方式一：
  - C:\\Windows\\System32\\drivers\\etc路径下的hosts文件
  - 添加上这两句：
    - 127.0.0.1 eureka7001.com
    - 127.0.0.1 eureka7002.com
- 修改方式二：
  - 下载这个软件： 在公司实际开发中用的都是这个
  - 官网地址： https://oldj.github.io/SwitchHosts/#cn
- 还有不修改 Host 的解决方法
- 我这里没有修改 Host 文件，具体看下面的 YML

修改 YML
- 相互注册，自己的 YML 中要注册上其他所有的 Eureka Server，多台 Server 用逗号隔开
- Eureka 7001 的

Eureka 7002 的

编写主启动类

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

启动两个注册中心，测试

3.2 将 Provider 注册进去

修改 cloud-provider-payment-8001 的 YML

我这里没有修改 HOST 文件，所以写的还是 localhost ，如果修改过的，就写自己设定的名字
```
service-url:
  defaultZone: http://localhost:7001/eureka, http://localhost:7002/eureka
```

启动测试

3.3 将 Consumer 注册进去

修改 YML

service-url:
  defaultZone: http://localhost:7001/eureka, http://localhost:7002/eureka

启动测试

4 . Provider 集群构建

4.1 构建集群

新建一个模块 cloud-provider-payment-8002
修改 POM
- 直接复制 8001 的
编写 YML

直接复制 8001 的
修改端口号为 8002

编写主启动类

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

业务类
- 直接复制 8001 的
测试
- 启动 8002

4.2 配置 Consumer

目前 Consumer 的 Controller 中访问 Provider 的地址还是写死的

修改 Consumer 的 Controller

private static final String PAYMENT_URL = "http://CLOUD-PAYMENT-SERVICE";

把原来的 IP 地址改为微服务名

修改一下 8001 和 8002 的 Controller

@Value("${server.port}")
    private String serverPort;

"【端口：】"+ serverPort +"---【查询成功】"

在 ApplicationContextConfig 中的 getRestTemplate 方法上添加负载均衡的注解
测试

访问 http://localhost/consumer/getPaymentById/1 查询数据

刷新一下

当前这种负载均衡策略就是轮询，多个 Provider 轮着来

5 . actuator微服务信息完善

5.1 主机名称：服务名称修改

修改 Provider 的 YML

instance:
    instance-id: payment8001

查看结果
将 8002 也修改一下

5.2 访问信息有ip信息提示

修改 Provider 的 YML
```
prefer-ip-address: true
```

查看结果

6 . 服务发现Discovery

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

修改 Provider 的 Controller

/** 注入 服务发现 */
@Autowired
private DiscoveryClient discoveryClient;

/** 暴露查询自己相关信息的接口 */
@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("ServiceId : " + instance.getServiceId()+"\\n"+
                "Host : " + instance.getHost()+"\\n" +
                "Port :" + instance.getPort()+"\\n"+
                "Uri : " + instance.getUri());
    }
    return this.discoveryClient;
}