Eureka

1. Eureka 注册中心

Eureka 的作用：

• 服务消费者该如何获取服务提供者的地址信息？
  • 服务提供者启动时向 Eureka 注册自己的信息
  • Eureka 保存这些信息
  • 消费者根据服务名称向 Eureka 拉取提供者信息
• 如果有多个服务提供者，消费者该如何选择？
  • 服务消费者利用负载均衡算法，从服务列表中挑选一个
• 消费者如何得知服务提供者的健康状态？
  • 服务提供者会每隔 30 秒向 EurekaServer 发送心跳请求，报告健康状态
  • Eureka 会更新记录服务列表信息，心跳不正常会被剔除
  • 消费者就可以拉取到最新的信息

在 Eureka 架构中，微服务角色有两类：

• EurekaServer：服务端，注册中心
  • 记录服务信息
  • 心跳监控
• EurekaClient：客户端
  • Provider：服务提供者，例如案例中的 user-service
    • 注册自己的信息到 EurekaServer
    • 每隔 30 秒向 EurekaServer 发送心跳
  • Consumer：服务消费者，例如案例中的 order-service
    • 根据服务名称从 EurekaServer 拉取服务列表
    • 基于服务列表做负载均衡，选中一个微服务后发起远程调用

2. 搭建 EurekaServer

1. 创建项目，引入spring-cloud-starter-netflix-eureka-server的依赖：

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

2. 编写启动类，添加@EnableEurekaServer注解

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

3. 添加 application.yml 文件，配置如下：

   server:
     port: 10086 # 服务端口
   spring:
     application:
       name: eurekaserver # eureka 的服务名称
   eureka:
     client:
       service-url: # eureka 的地址信息
         defaultZone: http://localhost:10086/eureka/

3. 服务注册

将 user-service 服务注册到 EurekaServer 步骤如下：

1. 在 user-service 项目引入 spring-cloud-starter-netflix-eureka-client 的依赖：

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

2. 在 application.yml 文件，编写下面的配置：

   spring:
     application:
       name: userservice
   eureka:
     client:
       service-url:
         defaultZone: http://127.0.0.1:10086/eureka/

可以这样模拟配置同一个服务的多个实例：

4. 服务发现

服务拉取是基于服务名称获取服务列表，然后再对服务列表做负载均衡。

在 order-service 中完成服务拉取：

1. 修改OrderService的代码，修改访问的路径，用服务名代替 ip、端口

   String url = "http://userservice/user/" + order.getUserId();

   public Order queryOrderById(Long orderId) {
       // 1. 查询订单
       Order order = orderMapper.findById(orderId);
       // 2. 利用 RestTemplate 发起 http 请求，查询用户
       // 2.1. url 路径
       String url = "http://userservice/user/" + order.getUserId();
       // 2.2. 发送 http 请求，实现远程调用
       User user = restTemplate.getForObject(url, User.class);
       // 3. 封装 user 到 Order
       order.setUser(user);
       // 4. 返回
       return order;
   }

2. 在 order-service 项目的启动类OrderApplication中的RestTemplate添加负载均衡注解：

   @Bean
   @LoadBalanced
   public RestTemplate restTemplate() {
       return new RestTemplate();
   }