Eureka注册中心快速入门

╰+哭是因爲堅強的太久メ 2024-03-26 01:30 74阅读 0赞

## 一、提供者与消费者 ##

*  \*\*服务提供者：\*\*一次业务中，被其他微服务调用的服务。（提供接口给其他微服务）

*  \*\*服务消费者：\*\*一次业务中，调用其他微服务的服务。（调用其它微服务提供的接口）

比如我们刚刚的案例中，我们在order-service中调用user-service服务，所以order-service是服务消费者，user-service是服务提供者

![aa1d5a8018bd6c0bbfc3c1ccc143ac18.png][]

**注意！提供者和消费者角色是相对的**

一个服务可能是提供者，也可能是消费者

## 二、Eureka注册中心 ##

### 2.1 服务调用出现的问题 ###

#### 2.1.1 **硬编码问题** ####

我们在远程服务调用的时候将红框内的代码硬写在程序中，这样修改非常的不方便

![020c306c90e8615e97d185a58a4068e5.png][]

为了应对更多的并发，我们的user服务可能会部署多实例，形成一个集群。

比如下图，我们如果还有8082，8083，那我们的硬编码就没有作用了，不知道改写谁的地址了，所以这里一定不能写成硬编码的形式。

![bdc813c90e4c0f20fe998f4bf300a6a3.png][]

#### 2.1.2**如果不是硬编码的形式，那这三个服务我们该怎么去获取呢？** ####

Eureka、nacos均可以解决这个问题

#### 2.1.3**服务消费者该如何获取服务提供者的地址信息？** ####

*  服务提供者启动时向eureka注册自己的信息

*  eureka保存这些信息

*  消费者根据服务名称向eureka拉去提供者信息

我们要做的就是根据服务名称向eureka拉去即可

#### 2.1.4**如果有多个服务提供者，消费者该如何选择呢？** ####

服务消费者利用负载均衡算法，从服务列表中挑选一个

#### 2.1.5**消费者如何得知服务提供者的健康状态呢？** ####

*  服务提供者会每隔30秒向Eureka Server发送心跳请求，报告健康状态

*  eureka会更新记录服务列表的信息，心跳不正常会被剔除

*  消费者就可以拉取到最新的信息

### 2.2 Eureka的作用 ###

eureka-server服务端：注册中心，记录和管理这些微服务

eureka-client客户端：服务消费者、服务提供者都是微服务，所以都是客户端

对于服务提供者，每一个服务启动时都会把服务信息注册给eureka-server客户端，然后客户端会记录下来user-service名称及端口

如果这个时候有一个人想要消费，那不就不需要自己记录信息，直接在eureka-server中拉去想要的服务信息即可

![58fb94d533410d7eed6da3b884918c1e.png][]

但是对于上图拉去的信息而言，我们同样的东西有三种配置，我们需要挑一个，这就需要负载均衡的知识了，从三个中挑选一个（比如localhost:8081），之后在由order-service向user-service发起请求

其中我们也不用担心localhost:8081会挂掉，因为我们user-service服务每隔一段时间就会向注册中心发一次请求确认自己的状态，若一段时间没有发送请求，则注册中心就会把user-service剔除，order-service再次拉去时就不会拉取到他，所以不用担心负载均衡选取的地址失效问题

![a57e65beda8171cbc2bc7138205a4e37.png][]

## 三、Eureka使用 ##

下面进行Eureka使用的三步走：

搭建EurekaServer、将服务注册到Eureka中、

### 3.1 搭建EurekaServer ###

#### 3.1.1 配置 ####

**新建maven工程，并添加maven坐标**

注意，下面的操作都是在创建的maven工程中去实现

##### 3.1.1.1**maven坐标** #####

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

这个地方没有指定版本，原因就是在父工程中将版本都管理好了，下图所示便是父工程中的版本管理，在下面的配置管理中，有大量的组件和版本信息，所以我们子工程引入的时候，无需引入任何版本

![ae8a3d6ee630651784b1347b1d9fc231.png][]

下面的图示可以更清楚的辨别子工程与父工程的关系

![ad50f3005906cbcee340b862b53511ec.png][]

![836e2b8324df4a01cf1fe7082ce3225c.png][]

##### 3.1.1.2 在启动类添加@EnableEurekaServer #####

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

#### 3.1.2编写配置文件 ####

# 配置微服务名称
    spring:
      application:
        name: eurekaserver
    
    
    # eureka自己也是一个微服务，也需要一个名字
    # eureka也会将自己注册到eureka上，
    #   为了以后eureka集群之间通讯使用，若启动了多个eureka，他们会互相做注册，完成数据的交流
    eureka:
      client:
    #   eureka地址信息
        service-url:
          defaultZone: http://127.0.0.1:10086/eureka

#### 3.1.3 启动Eureka ####

直接启动main函数

![cfb998a877892e1b6d197d53be1ad0f9.png][]

当我们启动之后，ctrl+单机方框内的端口号，直接打开页面，其中**红框中的内容最为重要**

“Instances currently registered with Eureka”翻译为“当前在Eureka上注册的实例”

![22ee7df205b281b82edcf3cc4253f361.png][]

**那怎么理解这个实例呢？**

一个服务每被部署一份，就叫做一个实例。

若部署十个user服务，那就会出现十个实例。

> application：服务名称，我们在配置文件中进行配置的  
> Status：IP和服务端口（由于window的原因，这个地方显示的时计算机名），其中UP代表正常状态，DOWN代表服务挂掉

### 3.2 将user-service服务注册到eureka中 （服务注册） ###

#### 3.2.1 配置 ####

##### 3.2.1.1 maven坐标 #####

我在导入坐标的时候出现了cannot reconnect ，翻译：不能连接我把idea重启了一下，解决了这个错误，我感觉我的idea有毛病

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

现在的依赖与eureka-server工程的依赖有所不同，这个**是eureka的client端**（客户端）

##### 3.2.1.2 application.yml文件配置 #####

下面除了微服务的名称与之前eureka-server工程不一样，其他配置和刚刚的是一个样子的

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

#### 3.2.2 启动 ####

启动下面的类即可

@MapperScan("cn.itcast.user.mapper")
    @SpringBootApplication
    public class UserApplication {
        public static void main(String[] args) {
            SpringApplication.run(UserApplication.class, args);
        }
    }

观察下图，确实变成两个实例了

![aac517756d794fc1c658a0fbe6c87efa.png][]

### 3.3 将order-service服务注册到eureka中（服务注册） ###

参照3.2 进行

![cc67b8855b744f744af3cc5b2d2a3e7e.png][]

### 3.4 实现某个服务多个实例 ###

#### 3.4.1 创建多个服务与实例 ####

比如，我们可以将user-service多次启动，模拟实例部署，但为了避免端口冲突，需要修改端口设置：

![818167893ba48b3207f306a6ca227c0d.png][]

![c7ee464f67b1c09bee866e5d1eabbc4f.png][]

![cf770a7a635172520bb03ac471afa82b.png][]

“-D”代表着参数，“server.port=8082”是配置端口，这个端口覆盖了yaml文件中的配置的端口

之后点击“OK”

![9684c0531106c388d31bae23ecdfeccc.png][]

启动成功

![8782cd65c4efb245c72ca687f300f06f.png][]

**查看**

我们看到确实是两个，这就是服务的列表

![51d7d86c9a244c1674e2496ad4b3f3bd.png][]

### 服务注册总结 ###

*  引入eureka-client依赖

*  在application.yml中配置eureka地址

### 3.5 服务发现（服务拉取）与负载均衡 ###

依然是在order-service完成服务拉取

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

#### 3.5.1 在order-service完成服务拉取 ####

##### 3.5.1.1 之前服务拉取代码 #####

@Service
    public class OrderService {
    
        @Autowired
        private OrderMapper orderMapper;
    
        @Autowired
        private RestTemplate restTemplate;
    
    
        public Order queryOrderById(Long orderId) {
            // 1.查询订单    从数据库中获取
            Order order = orderMapper.findById(orderId);
            //2. 利用RestTemplate发起HTTP请求，获取用户
            //         get请求：getForObject(url路径,返回值类型)
            //                 我们下面的返回值类型不需要JSON，而是需要一个User对象的形式，所以写User.class
            //         post请求：postForObject()
            String url = "http://localhost:8081/user/" + order.getUserId();
            User user = restTemplate.getForObject(url, User.class);
    
            //3. 封装user到Order中
            order.setUser(user);
            // 4.返回
            return order;
        }
    }

@MapperScan("cn.itcast.order.mapper")
    @SpringBootApplication
    public class OrderApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(OrderApplication.class, args);
        }
    
        @Bean
        public RestTemplate restTemplate(){
            return  new RestTemplate();
        }
    
    }

##### 3.5.1.2 如今服务拉取代码 #####

**服务名称代替IP端口**

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

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

@Service
    public class OrderService {
    
        @Autowired
        private OrderMapper orderMapper;
    
        @Autowired
        private RestTemplate restTemplate;
    
    
        public Order queryOrderById(Long orderId) {
            // 1.查询订单    从数据库中获取
            Order order = orderMapper.findById(orderId);
            //2. 利用RestTemplate发起HTTP请求，获取用户
            //         get请求：getForObject(url路径,返回值类型)
            //                 我们下面的返回值类型不需要JSON，而是需要一个User对象的形式，所以写User.class
            //         post请求：postForObject()
    //        String url = "http://localhost:8081/user/" + order.getUserId();
            String url = "http://userservice/user/" + order.getUserId();
            User user = restTemplate.getForObject(url, User.class);
    
            //3. 封装user到Order中
            order.setUser(user);
            // 4.返回
            return order;
        }
    }

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

LoadBalanced就是负载均衡的意思

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

#### 3.5.2 发送请求获取数据 ####

发送请求获取数据

![60699fb3cdd2b2ca6d6e28ac699d477f.png][]

端口8080、8081存在日志信息，而8082不存在日志信息

![93b8b14cd46392c89301f813705393fd.png][]

![0eed5df56b6bfc76cbb2c6f17901c8cb.png][]

再次发送请求

![4814f97111b3168f9700e5e00b9ebd76.png][]

端口8080、8082会有反应

![5c9712b669c653df3dbfc5ade17356f1.png][]

### 3.6 总结 ###

![cf8d74815475bc099c18f83994929a92.png][]

[aa1d5a8018bd6c0bbfc3c1ccc143ac18.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/40e68c3f808449a68e3cc3855df254af.png
[020c306c90e8615e97d185a58a4068e5.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/b245903de15e44caa6efba37255475f6.png
[bdc813c90e4c0f20fe998f4bf300a6a3.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/7a99f0811eeb4bfd92d34891c7419ac7.png
[58fb94d533410d7eed6da3b884918c1e.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/6897f72da65844a9859d8f113487d9d2.png
[a57e65beda8171cbc2bc7138205a4e37.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/8ffae92e62614e318a3fdc4fcb074ed8.png
[ae8a3d6ee630651784b1347b1d9fc231.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/bcd6a24ceda14706be3e86725e1e489d.png
[ad50f3005906cbcee340b862b53511ec.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/485ef142a5784dba81c195ca66fa62b9.png
[836e2b8324df4a01cf1fe7082ce3225c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/5c070b0331754f8e9aaf36e6bb55d960.png
[cfb998a877892e1b6d197d53be1ad0f9.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/085a7e7277f7428f82822ba6ef41f301.png
[22ee7df205b281b82edcf3cc4253f361.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/f73ed6e6684d42598a8f79a075f6ed8e.png
[aac517756d794fc1c658a0fbe6c87efa.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/b0ac0a2c74d940ab9cf8bb02423b8356.png
[cc67b8855b744f744af3cc5b2d2a3e7e.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/cf3bbc489a854feba8fa30253857a6b1.png
[818167893ba48b3207f306a6ca227c0d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/4db766cdad32493f9c7d69e9cf5a90ad.png
[c7ee464f67b1c09bee866e5d1eabbc4f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/6c1828c843784796a5133adbf3223ae1.png
[cf770a7a635172520bb03ac471afa82b.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/053a95a592c749f084beab558f07c01d.png
[9684c0531106c388d31bae23ecdfeccc.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/259908293dbb474f971209de37f470fe.png
[8782cd65c4efb245c72ca687f300f06f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/a9cfe6bc88ca4fd6b49a79d6c1a8789c.png
[51d7d86c9a244c1674e2496ad4b3f3bd.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/28de2a0f245740d9995a907379e26863.png
[60699fb3cdd2b2ca6d6e28ac699d477f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/e343cf6b44d346d4a73d1892b699cd8c.png
[93b8b14cd46392c89301f813705393fd.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/a6c9ea99994b4bddbd14f0e16f3166e9.png
[0eed5df56b6bfc76cbb2c6f17901c8cb.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/b907b766c07b49c0b29f04ee74f83395.png
[4814f97111b3168f9700e5e00b9ebd76.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/fac64b78c55b4877882aee11a22713db.png
[5c9712b669c653df3dbfc5ade17356f1.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/fcb93b0638d842bb800d6558a86f834e.png
[cf8d74815475bc099c18f83994929a92.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/07506d7541d24360b4958f1df67a8dce.png