SpringCloud：Eureka注册中心

偏执的太偏执、 2024-03-27 03:50 25阅读 0赞

假如我们的服务提供者`user-service`部署了多个实例，如图：

![在这里插入图片描述][0d78286e174e4c3b8c4565dfd0c478e5.png_pic_center]

大家思考几个问题：

*  `order-service`在发起远程调用的时候，该如何得知`user-service`实例的`ip`地址和端口？
 *  有多个`user-service`实例地址，`order-service`调用时该如何选择？
 *  `order-service`如何得知某个`user-service`实例是否依然健康，是不是已经宕机？

### 1.`Eureka`的结构和作用 ###

这些问题都需要利用`SpringCloud`中的注册中心来解决，其中最广为人知的注册中心就是`Eureka`，其结构如下：

![在这里插入图片描述][53e386e6260940f7b7a5aa20ec7ad9ff.png_pic_center]

回答之前的各个问题。

问题1：`order-service`如何得知`user-service`实例地址？

获取地址信息的流程如下：

*  `user-service`服务实例启动后，将自己的信息注册到`eureka-server`（`Eureka`服务端）。这个叫服务注册
 *  `eureka-server`保存服务名称到服务实例地址列表的映射关系
 *  `order-service`根据服务名称，拉取实例地址列表。这个叫服务发现或服务拉取

问题2：`order-service`如何从多个`user-service`实例中选择具体的实例？

*  `order-service`从实例列表中利用负载均衡算法选中一个实例地址
 *  向该实例地址发起远程调用

问题3：`order-service`如何得知某个`user-service`实例是否依然健康，是不是已经宕机？

*  `user-service`会每隔一段时间（默认30秒）向`eureka-server`发起请求，报告自己状态，称为心跳
 *  当超过一定时间没有发送心跳时，`eureka-server`会认为微服务实例故障，将该实例从服务列表中剔除
 *  `order-service`拉取服务时，就能将故障实例排除了

> 注意：一个微服务，既可以是服务提供者，又可以是服务消费者，因此`eureka`将服务注册、服务发现等功能统一封装到了`eureka-client`端

因此，接下来我们动手实践的步骤包括：

![在这里插入图片描述][6c43d4b4e4ef4c5ba288fd3580aecd8c.png_pic_center]

### 2.搭建`eureka-server` ###

首先大家注册中心服务端：`eureka-server`，这必须是一个独立的微服务

#### 2.1.创建`eureka-server`服务 ####

在`cloud-demo`父工程下，创建一个子模块：

![在这里插入图片描述][98801c36f4174efa8f1703e4c0727f99.png_pic_center]

填写模块信息：

![在这里插入图片描述][fa15baedaf0241a7aff246dbf85d5b34.png_pic_center]

#### 2.2.引入`eureka`依赖 ####

引入`SpringCloud`为`eureka`提供的`starter`依赖：

<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 http://maven.apache.org/maven-v4_0_0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <parent>
            <groupId>com.dcxuexi.demo</groupId>
            <artifactId>cloud-demo</artifactId>
            <version>1.0</version>
        </parent>
        <artifactId>eureka-server</artifactId>
    
        <properties>
            <maven.compiler.source>8</maven.compiler.source>
            <maven.compiler.target>8</maven.compiler.target>
        </properties>
    
        <dependencies>
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
                <version>2.2.7.RELEASE</version>
            </dependency>
        </dependencies>
    
    </project>

#### 2.3.编写启动类 ####

给`eureka-server`服务编写一个启动类，一定要添加一个`@EnableEurekaServer`注解，开启`eureka`的注册中心功能：

package com.dcxuexi.eureka;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
    
    /***
     * @Title EurekaApplication
     * @Description TOTD
     * @Auter DongChuang
     * @Date 2023/2/5 10:08
     * @Version 1.0.0
     */
    @EnableEurekaServer
    @SpringBootApplication
    public class EurekaApplication {
        
        public static void main(String[] args) {
        
            SpringApplication.run(EurekaApplication.class,args);
        }
    }

#### 2.4.编写配置文件 ####

编写一个`application.yml`文件，内容如下：

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

#### 2.5.启动服务 ####

启动微服务，然后在浏览器访问：`http://localhost:10086/`

看到下面结果应该是成功了：

![在这里插入图片描述][abb5aed6da8f4d3aa8f6580b671c5d57.png_pic_center]

### 3.服务注册 ###

下面，我们将`user-service`注册到`eureka-server`中去。

#### 3.1.引入依赖 ####

在`user-service`的`pom`文件中，引入下面的`eureka-client`依赖：

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

#### 3.2.配置文件 ####

在`user-service`中，修改`application.yml`文件，添加服务名称、`eureka`地址：

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

#### 3.3.启动多个`user-service`实例 ####

为了演示一个服务有多个实例的场景，我们添加一个`SpringBoot`的启动配置，再启动一个`user-service`。

首先，复制原来的`user-service`启动配置：

![在这里插入图片描述][a251f425d555430c99d0491b77a25fa2.png_pic_center]

然后，在弹出的窗口中，填写信息：

![在这里插入图片描述][7b6fe942757249f692aa9562d9d75c3d.png_pic_center]

现在，`SpringBoot`窗口会出现两个`user-service`启动配置，不过，第一个是8081端口，第二个是8082端口。

启动两个`user-service`实例：

![在这里插入图片描述][31ecbbe0bb744839a08e36fb0a79b02e.png_pic_center]

查看`eureka-server`管理页面：

![在这里插入图片描述][ef92c288c10247138555a4b64e45f653.png_pic_center]

### 4.服务发现 ###

下面，我们将`order-service`的逻辑修改：向`eureka-server`拉取`user-service`的信息，实现服务发现。

#### 4.1.引入依赖 ####

之前说过，服务发现、服务注册统一都封装在`eureka-client`依赖，因此这一步与服务注册时一致。

在`order-service`的`pom`文件中，引入下面的`eureka-client`依赖：

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

#### 4.2.配置文件 ####

服务发现也需要知道`eureka`地址，因此第二步与服务注册一致，都是配置`eureka`信息：

在`order-service`中，修改`application.yml`文件，添加服务名称、`eureka`地址：

spring:
      application:
        name: orderservice # order服务的eureka服务名称
    eureka:
      client:
        service-url: # eureka地址信息
          defaultZone: http://127.0.0.1:10086/eureka

#### 4.3.服务拉取和负载均衡 ####

最后，我们要去`eureka-server`中拉取`user-service`服务的实例列表，并且实现负载均衡。

不过这些动作不用我们去做，只需要添加一些注解即可。

在`order-service`的`OrderApplication`中，给`RestTemplate`这个`Bean`添加一个`@LoadBalanced`注解：

package com.dcxuexi.order;
    
    import org.mybatis.spring.annotation.MapperScan;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.loadbalancer.LoadBalanced;
    import org.springframework.context.annotation.Bean;
    import org.springframework.web.client.RestTemplate;
    
    @MapperScan("com.dcxuexi.order.mapper")
    @SpringBootApplication
    public class OrderApplication {
        
    
        public static void main(String[] args) {
        
            SpringApplication.run(OrderApplication.class, args);
        }
    
        @Bean
        @LoadBalanced
        public RestTemplate restTemplate() {
        
            return new RestTemplate();
        }
    }

修改`order-service`服务中的`com.dcxuexi.order.service`包下的`OrderService`类中的`queryOrderById`方法。修改访问的`url`路径，用服务名代替`ip`、端口：

package com.dcxuexi.order.service;
    
    import com.dcxuexi.order.mapper.OrderMapper;
    import com.dcxuexi.order.pojo.Order;
    import com.dcxuexi.order.pojo.User;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    import org.springframework.web.client.RestTemplate;
    
    @Service
    public class OrderService {
        
    
        @Autowired
        private OrderMapper orderMapper;
    
        @Autowired
        private RestTemplate restTemplate;
    
        public Order queryOrderById(Long orderId) {
        
            // 1.查询订单
            Order order = orderMapper.findById(orderId);
            // 2.远程访问查询user
            // 2.1. URL 地址
            //String url = "http://localhost:8081/user/" + order.getUserId();
            String url = "http://userService/user/" + order.getUserId();
            // 2.2. 发起调用
            User user = restTemplate.getForObject(url, User.class);
            // 3. 存入order中
            order.setUser(user);
            // 4.返回
            return order;
        }
    }

`spring`会自动帮助我们从`eureka-server`端，根据`userservice`这个服务名称，获取实例列表，而后完成负载均衡。

根据`id`查询订单，返回值是`Order`对象，如图：

![在这里插入图片描述][061169899c8c40c580e900b1b4d956af.png_pic_center]

[0d78286e174e4c3b8c4565dfd0c478e5.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/52a4a2f5c1af4443b96a94b6afbf419c.png
[53e386e6260940f7b7a5aa20ec7ad9ff.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/30ec5b21c3d74668baea57d1f2769de6.png
[6c43d4b4e4ef4c5ba288fd3580aecd8c.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/f6942947c0ed4df4acd88f388d94aadc.png
[98801c36f4174efa8f1703e4c0727f99.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/9af746ae9de34866902d289c00e52e82.png
[fa15baedaf0241a7aff246dbf85d5b34.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/77378b3bdb3a410097bc0d4bea63bb9d.png
[abb5aed6da8f4d3aa8f6580b671c5d57.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/c7cd56a746ea4bf2af374bfaee181db0.png
[a251f425d555430c99d0491b77a25fa2.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/4ac43d0cdbb146f6ac01b19668e9d3af.png
[7b6fe942757249f692aa9562d9d75c3d.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/64a1d6d9a9e6440dbcd83ec56458a37c.png
[31ecbbe0bb744839a08e36fb0a79b02e.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/6328d501c188487d881d7aac0b35b830.png
[ef92c288c10247138555a4b64e45f653.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/68ec1fdaa4074422971b7abd2ae04802.png
[061169899c8c40c580e900b1b4d956af.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/badc46baab4a444eb6aeef814cc59cb5.png