【spring cloud】（二）保证Eureka高可用的集群搭建

忘是亡心i 2021-06-14 00:51 321阅读 0赞

## 1 Eureka集群的高可用 ##

为了保证服务的高可用，所以需要对Eureka进行一个集群的搭建，用以保证Eureka的稳定，同时防止各种意外宕机事故的发生。  
在没有使用集群之前Server端只有一个，Client端也只有一个，这时我们为了保证Eureka的高可用提出了集群的概念。  
用下图来对比有无集群的运行过程：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTUxNTMxMjgzMg_size_16_color_FFFFFF_t_70]

## 2 分布式和集群的区别 ##

可能有很多人对分布式和集群这两个概念有点混淆。我先用通俗易懂的话给大家解释下：

> 分布式：一个业务分拆多个子业务，部署在不同的服务器上

> 集群：同一个业务，分别部署在不同的服务器上

所以分布式的每一个节点，完成的是不同的业务，一个节点挂了，那么这个业务功能就无法访问了，甚至可能会影响到其他业务。而集群是一个比较有组织的架构，正因为有组织性，一个服务节点挂了，其他服务节点可以顶上来，从而保证了服务的健壮性。

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

## 3 项目搭建 ##

### 3.1 Server端搭建 ###

目录结构：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTUxNTMxMjgzMg_size_16_color_FFFFFF_t_70 1]

#### 3.1.1 新建spring boot项目 ####

在pom文件中添加依赖

<?xml version="1.0" encoding="UTF-8"?>
    <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/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.1.6.RELEASE</version>
            <relativePath/> 
        </parent>
        <groupId>com.example</groupId>
        <artifactId>eureka-cluster</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>eureka-cluster</name>
        <description>Demo project for Spring Boot</description>
    
        <properties>
            <java.version>1.8</java.version>
        </properties>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
                <version>2.0.0.RELEASE</version>
            </dependency>
        </dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    </project>

#### 3.1.2 在启动文件上添加注解 ####

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTUxNTMxMjgzMg_size_16_color_FFFFFF_t_70 2]

#### 3.1.3 配置文件配置 ####

application.properties

#应用名
    spring.application.name=eureka-cluster
    # 禁止注册到eureka中心, 当前这个应用就是Eureka Server，所以不需要把自己注册
    eureka.client.register-with-eureka=false

application-eureka-server1.properties

##eureka-server1节点配置，配置参数--spring.profiles.active=eureka-server1来启动该环境
    spring.profiles=eureka-server1
    server.port=8761
    eureka.instance.hostname=eureka-server1
    eureka.client.serviceUrl.defaultZone=http://eureka-server2:8762/eureka/

application-eureka-server2.properties

##eureka-server2节点配置，配置参数--spring.profiles.active=eureka-server2来启动该环境
    spring.profiles=eureka-server2
    server.port=8762
    eureka.instance.hostname=eureka-server2
    eureka.client.serviceUrl.defaultZone=http://eureka-server1:8761/eureka/

### 3.2 客户端搭建——提供者（producer） ###

目录结构：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTUxNTMxMjgzMg_size_16_color_FFFFFF_t_70 3]

#### 3.2.1 新建spring boot项目在pom文件中添加依赖 ####

<?xml version="1.0" encoding="UTF-8"?>
    <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/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.1.6.RELEASE</version>
            <relativePath/> 
        </parent>
        <groupId>com.example</groupId>
        <artifactId>eureka-client</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>eureka-client</name>
        <description>Demo project for Spring Boot</description>
    
        <properties>
            <java.version>1.8</java.version>
        </properties>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
                <version>2.0.0.RELEASE</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
                <version>2.0.0.RELEASE</version>
            </dependency>
        </dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    </project>

#### 3.2.2 在启动类上添加注解 ####

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTUxNTMxMjgzMg_size_16_color_FFFFFF_t_70 4]

#### 3.2.3 添加HelloController ####

package com.example.eurekaclient.controller;
    
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    public class HelloController { 
    
        @GetMapping(value = "/hello")
        public String index() { 
            return "hello，this is first messge";
        }
    
    }

#### 3.2.4 添加配置文件 ####

application.properties

#应用名
    spring.application.name=eureka-client

application-eureka-client1.properties

spring.profiles=eureka-client1
    # 端口
    server.port=9000
    # 主机名
    eureka.instance.hostname=eureka-server1
    # 注册到eureka-server上，由于2个注册中心组成了集群
    # client服务通过eureka-server1同步给了与之互相注册的eureka-server2
    # 两两注册的方式可以实现集群中节点完全对等的效果，实现最高可用性集群，任何一台注册中心故障都不会影响服务的注册与发现
    eureka.client.serviceUrl.defaultZone=http://eureka-server1:8761/eureka/,http://eureka-server2:8762/eureka/

application-eureka-client2.properties

spring.profiles=eureka-client2
    # 端口
    server.port=9001
    # 主机名
    eureka.instance.hostname=eureka-server1
    # 注册到eureka-server上，由于2个注册中心组成了集群
    # client服务通过eureka-server1同步给了与之互相注册的eureka-server2
    # 两两注册的方式可以实现集群中节点完全对等的效果，实现最高可用性集群，任何一台注册中心故障都不会影响服务的注册与发现
    eureka.client.serviceUrl.defaultZone=http://eureka-server1:8761/eureka/,http://eureka-server2:8762/eureka/

### 3.3 客户端搭建——消费者（Consumer） ###

目录结构：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTUxNTMxMjgzMg_size_16_color_FFFFFF_t_70 5]

#### 3.4.1 新建spring boot项目在pom文件中添加依赖 ####

<?xml version="1.0" encoding="UTF-8"?>
    <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/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.1.6.RELEASE</version>
            <relativePath/> 
        </parent>
        <groupId>com.example</groupId>
        <artifactId>ribbon-consumer</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>ribbon-consumer</name>
        <description>Demo project for Spring Boot</description>
    
        <properties>
            <java.version>1.8</java.version>
        </properties>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
                <version>2.0.0.RELEASE</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
                <version>2.0.0.RELEASE</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-ribbon</artifactId>
                <version>1.3.6.RELEASE</version>
            </dependency>
        </dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    </project>

#### 3.4.2 在启动类上添加注解，并且开启负载均衡 ####

package com.example.ribbonconsumer;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    import org.springframework.cloud.client.loadbalancer.LoadBalanced;
    import org.springframework.context.annotation.Bean;
    import org.springframework.web.client.RestTemplate;
    
    @SpringBootApplication
    @EnableDiscoveryClient
    public class RibbonConsumerApplication { 
    
        public static void main(String[] args) { 
            SpringApplication.run(RibbonConsumerApplication.class, args);
        }
    
        @Bean
        @LoadBalanced
        RestTemplate restTemplate(){ 
            return new RestTemplate();
        }
    
    }

#### 3.4.3 添加ConsumerController类，注入RestTemplate，写出需要消费的请求 ####

package com.example.ribbonconsumer.controller;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.client.RestTemplate;
    
    @RestController
    public class ConsumerController { 
    
        @Autowired
        RestTemplate restTemplate;
    
        @GetMapping(value = "/ribbon-consumer")
        public String helloConsumer() { 
            return restTemplate.getForEntity("http://EUREKA-CLIENT/hello", String.class).getBody();
        }
    
    }

#### 3.4.4 添加配置文件 ####

spring.application.name=ribbon-consumer
    server.port=9010
    # 注册中心地址
    eureka.client.serviceUrl.defaultZone=http://eureka-server1:8761/eureka/,http://eureka-server2:8762/eureka/

## 4 项目的启动配置 ##

点击这个进入编辑列表  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTUxNTMxMjgzMg_size_16_color_FFFFFF_t_70 6]  
我的启动目录列表：  
![在这里插入图片描述][20190724093131828.png]

### 4.1配置启动列表 ###

配置不同配置文件进行启动，后边的EurekaClientApplication1和EurekaClientApplication2依旧如下图所示的配置。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTUxNTMxMjgzMg_size_16_color_FFFFFF_t_70 7]

### 4.2 项目启动 ###

![在这里插入图片描述][20190724094036234.png]

1.  启动注册中心
2.  启动客户端–producer
3.  启动客户端–consumer

### 4.3注意 ###

在启动时修改producer的代码，用来观察负载均衡  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTUxNTMxMjgzMg_size_16_color_FFFFFF_t_70 8]

### 4.4 启动结束 ###

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTUxNTMxMjgzMg_size_16_color_FFFFFF_t_70 9]

## 5 测试 ##

![在这里插入图片描述][20190724094942557.png]  
![在这里插入图片描述][20190724094950937.png]  
两种结果会循环出现，从而达到了负载均衡的效果

## 6 项目代码 ##

待上传

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTUxNTMxMjgzMg_size_16_color_FFFFFF_t_70]: /images/20210529/0d713c3e89f040358b0643ef751a5b6e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTUxNTMxMjgzMg_size_16_color_FFFFFF_t_70 1]: /images/20210529/7708d05381564199b3379cc9084e16b1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTUxNTMxMjgzMg_size_16_color_FFFFFF_t_70 2]: /images/20210529/e848f71cedf644528ec5de3fcb86b707.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTUxNTMxMjgzMg_size_16_color_FFFFFF_t_70 3]: /images/20210529/d7c2ad2bd7c24d65903b462186ea1af1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTUxNTMxMjgzMg_size_16_color_FFFFFF_t_70 4]: /images/20210529/1bafcba84f6948f6a6b44f6c4a71b717.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTUxNTMxMjgzMg_size_16_color_FFFFFF_t_70 5]: /images/20210529/90c07823ed074557bab9bc25b33d25c3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTUxNTMxMjgzMg_size_16_color_FFFFFF_t_70 6]: /images/20210529/9629f4007d4c442ca0b75921a194124b.png
[20190724093131828.png]: /images/20210529/f00c7e33af284aec9588425d393ff518.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTUxNTMxMjgzMg_size_16_color_FFFFFF_t_70 7]: /images/20210529/3e84ae4d46144757b939924dc1fa0cff.png
[20190724094036234.png]: /images/20210529/eae82f22f4fe42e982e756a8ab4827ec.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTUxNTMxMjgzMg_size_16_color_FFFFFF_t_70 8]: /images/20210529/34a532cceb6540b08cc97cfbbcd6636c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTUxNTMxMjgzMg_size_16_color_FFFFFF_t_70 9]: /images/20210529/aef7db2ec172476889a4a9bc51ed5bc8.png
[20190724094942557.png]: /images/20210529/1d4c8170fe0a4c7aa295509164f53a5f.png
[20190724094950937.png]: /images/20210529/124269bd47ab440a809b4b2891ea85e1.png