SpringCloud构建微服务之Eureka集群

一时失言乱红尘 2021-11-29 06:32 393阅读 0赞

## 什么是集群？ ##

在讲解如何搭建eureka**集群**前，先给大家普及一下**集群**的概念，有些小伙伴可能还不知道什么是集群。

说到集群可能就有人会想到分布式，可能有很多人对**分布式**和**集群**这两个概念有点混淆：

*  分布式：将一套系统拆分成不同子系统部署在不同服务器上
 *  集群：部署多个相同的子系统在不同的服务器上

**分布式的每一个子系统，完成的是不同的业务**，一台服务挂了，那么这个业务功能就无法访问了，甚至可能会影响到其他业务。而**集群是多个子系统完成的是一个业务**，正因为这样，其中一台服务挂了，其他服务节点可以顶上来，从而保证了服务的健壮性。

所以说，集群可以理解为：**你中有我，我中有你，手拉手肩并肩，一起保证服务的健壮性**

## Eureka集群原理 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5fY2hhbmd5aW5n_size_16_color_FFFFFF_t_70]  
基本原理  
上图是来自eureka的官方架构图，这是基于集群配置的eureka；

*  处于不同节点的eureka通过Replicate进行数据同步
 *  Application Service为服务提供者
 *  Application Client为服务消费者
 *  Make Remote Call完成一次服务调用

服务启动后向Eureka注册，Eureka Server会将注册信息向其他Eureka Server进行同步，当服务消费者要调用服务提供者，则向服务注册中心获取服务提供者地址，然后会将服务提供者地址缓存在本地，下次再调用时，则直接从本地缓存中取，完成一次调用。

当服务注册中心Eureka Server检测到服务提供者因为宕机、网络原因不可用时，则在服务注册中心将服务置为DOWN状态，并把当前服务提供者状态向订阅者发布，订阅过的服务消费者更新本地缓存。

服务提供者在启动后，周期性（默认30秒）向Eureka Server发送心跳，以证明当前服务是可用状态。Eureka Server在一定的时间（默认90秒）未收到客户端的心跳，则认为服务宕机，注销该实例。

## Eureka集群搭建 ##

在搭建eureka集群前，咱们先来回顾一下，单个eureka服务的时候，是如何来配置的

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

从上面的配置文件可以看出，`eureka7001`就是一个eureka服务，所有服务都是往这台服务上注册。那么我们如何去搭建一个 Eureka 集群呢？假设现在有三个 `Eureka` 服务：`eureka7001`、`eureka7002` 和 `eureka7003`。

为了体现出集群的你中有我，我中有你，不难想象，`eureka7001` 中应该挂上 `eureka7002` 和 `eureka7003`；`eureka7002`中应该挂上 `eureka7001` 和 `eureka7003`；`eureka7003` 中应该挂上 `eureka7001` 和 `eureka7002`。如下图所示：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5fY2hhbmd5aW5n_size_16_color_FFFFFF_t_70 1]  
现在集群的雏形已经有了，下面我们来一步步实现。

## Eureka7001改造 ##

修改defaultZone配置。

## 搭建Eureka7002 ##

将Eureka7001拷贝一份，修改其配置文件即可

server:
      port: 7002
    
    eureka:
      instance:
        hostname: eureka7002 #eureka服务端的实例名称
      client:
        register-with-eureka: false #false表示不向注册中心注册自己。
        fetch-registry: false #false表示自己端就是注册中心，我的职责就是维护服务实例，并不需要去检索服务
        service-url:
          #defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/ #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址。（单机）
          defaultZone: http://eureka7001:7001/eureka/,http://eureka7003:7003/eureka/ #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址。（集群）

## 搭建Eureka7003 ##

步骤同上

server:
      port: 7003
    
    eureka:
      instance:
        hostname: eureka7003 #eureka服务端的实例名称
      client:
        register-with-eureka: false #false表示不向注册中心注册自己。
        fetch-registry: false #false表示自己端就是注册中心，我的职责就是维护服务实例，并不需要去检索服务
        service-url:
          #defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/ #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址。（单机）
          defaultZone: http://eureka7001:7001/eureka/,http://eureka7002:7002/eureka/ #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址。（集群）

## host映射 ##

从前面的配置文件可以看到，为了区分不同的服务，`hostname`不再是`localhost`了，因此我们还要修改一下`host`文件，此处环境为Mac，Windows下如何修改host文件自行百度

打开命令行，输入`sudo vi /private/etc/hosts` 修改host文件。注意：执行此命令需要输入用户密码  
将一下内容添加到host文件中，保存即可：

127.0.0.1 eureka7001
    127.0.0.1 eureka7002
    127.0.0.1 eureka7003

## 用户服务提供者改造 ##

因为现在是集群模式，所有我们需要将服务分别注册到三个eureka中，同样是修改`defaultZone`配置

server:
      port: 8001
    
    mybatis:
      config-location: classpath:mybatis/mybatis-config.xml        # mybatis配置文件所在路径
      type-aliases-package: com.chaytech.model.*    # 所有Entity别名类所在包
      mapper-locations:
      - classpath:mybatis/mapper/**/*.xml                       # mapper映射文件
    
    spring:
       application:
        name: user-provider
       datasource:
        type: com.alibaba.druid.pool.DruidDataSource            # 当前数据源操作类型
        driver-class-name: org.gjt.mm.mysql.Driver              # mysql驱动包
        url: jdbc:mysql://127.0.0.1:3306/spring_cloud_db01              # 数据库名称
        username: root
        password: root
        dbcp2:
          min-idle: 5                                           # 数据库连接池的最小维持连接数
          initial-size: 5                                       # 初始化连接数
          max-total: 5                                          # 最大连接数
          max-wait-millis: 200                                  # 等待连接获取的最大超时时间
    
    eureka:
      client: #客户端注册进eureka服务列表内
        service-url:
          #defaultZone: http://localhost:7001/eureka （单机）
          defaultZone: http://eureka7001:7001/eureka/,http://eureka7002:7002/eureka/,http://eureka7003:7003/eureka/ #（集群）
    
    info:
      app.name: user-provider
      build.artifactId: $project.artifactId$
      build.version: $project.version$

## 测试 ##

通过前面的步骤已经将eureka集群搭建好了，下面我们来测试一下：  
依次启动`Eureka7001、Eureka7002、Eureka7003、UserProvider8001`等服务  
访问`Eureka7001`：[http://eureka7001:7001/][http_eureka7001_7001]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5fY2hhbmd5aW5n_size_16_color_FFFFFF_t_70 2]  
可以看到`Eureka7001`上挂着 `eureka7002` 和 `eureka7003`，并且用户服务也成功注册到该注册中心

接着访问`Eureka7002`：[http://eureka7002:7002/][http_eureka7002_7002]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5fY2hhbmd5aW5n_size_16_color_FFFFFF_t_70 3]  
可以看到`Eureka7002`上挂着 `eureka7001` 和 `eureka7003`，并且用户服务也成功注册到该注册中心

接着访问`Eureka7003`：[http://eureka7003:7003/][http_eureka7003_7003]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5fY2hhbmd5aW5n_size_16_color_FFFFFF_t_70 4]  
可以看到`Eureka7003`上挂着 `eureka7001` 和 `eureka7002`，并且用户服务也成功注册到该注册中心

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5fY2hhbmd5aW5n_size_16_color_FFFFFF_t_70]: /images/20211129/7367c9cce1de44e79e196ad51dc622f3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5fY2hhbmd5aW5n_size_16_color_FFFFFF_t_70 1]: /images/20211129/b8ee295d9bdd4a24b78cb21cd5b52658.png
[http_eureka7001_7001]: http://eureka7001:7001/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5fY2hhbmd5aW5n_size_16_color_FFFFFF_t_70 2]: /images/20211129/b675870c431d458ab1edf05d3131745c.png
[http_eureka7002_7002]: http://eureka7002:7002/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5fY2hhbmd5aW5n_size_16_color_FFFFFF_t_70 3]: /images/20211129/db1a6ae2464049c4b00abac53d88a39b.png
[http_eureka7003_7003]: http://eureka7003:7003/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5fY2hhbmd5aW5n_size_16_color_FFFFFF_t_70 4]: /images/20211129/a4c17fdb533e4e75a486260d427316d1.png