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

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

1 Eureka集群的高可用

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

2 分布式和集群的区别

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

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

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

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

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

3 项目搭建

3.1 Server端搭建

目录结构：
在这里插入图片描述

3.1.1 新建spring boot项目

在pom文件中添加依赖

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <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">
  3.     <modelVersion>4.0.0</modelVersion>
  4.     <parent>
  5.         <groupId>org.springframework.boot</groupId>
  6.         <artifactId>spring-boot-starter-parent</artifactId>
  7.         <version>2.1.6.RELEASE</version>
  8.         <relativePath/> <!-- lookup parent from repository -->
  9.     </parent>
  10.     <groupId>com.example</groupId>
  11.     <artifactId>eureka-cluster</artifactId>
  12.     <version>0.0.1-SNAPSHOT</version>
  13.     <name>eureka-cluster</name>
  14.     <description>Demo project for Spring Boot</description>
  16.     <properties>
  17.         <java.version>1.8</java.version>
  18.     </properties>
  20.     <dependencies>
  21.         <dependency>
  22.             <groupId>org.springframework.boot</groupId>
  23.             <artifactId>spring-boot-starter</artifactId>
  24.         </dependency>
  25.         <dependency>
  26.             <groupId>org.springframework.boot</groupId>
  27.             <artifactId>spring-boot-starter-test</artifactId>
  28.             <scope>test</scope>
  29.         </dependency>
  30.         <dependency>
  31.             <groupId>org.springframework.cloud</groupId>
  32.             <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
  33.             <version>2.0.0.RELEASE</version>
  34.         </dependency>
  35.     </dependencies>
  37.     <build>
  38.         <plugins>
  39.             <plugin>
  40.                 <groupId>org.springframework.boot</groupId>
  41.                 <artifactId>spring-boot-maven-plugin</artifactId>
  42.             </plugin>
  43.         </plugins>
  44.     </build>
  45. </project>

3.1.2 在启动文件上添加注解

在这里插入图片描述

3.1.3 配置文件配置

application.properties

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

application-eureka-server1.properties

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

application-eureka-server2.properties

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

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

目录结构：
在这里插入图片描述

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

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <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">
  3.     <modelVersion>4.0.0</modelVersion>
  4.     <parent>
  5.         <groupId>org.springframework.boot</groupId>
  6.         <artifactId>spring-boot-starter-parent</artifactId>
  7.         <version>2.1.6.RELEASE</version>
  8.         <relativePath/> <!-- lookup parent from repository -->
  9.     </parent>
  10.     <groupId>com.example</groupId>
  11.     <artifactId>eureka-client</artifactId>
  12.     <version>0.0.1-SNAPSHOT</version>
  13.     <name>eureka-client</name>
  14.     <description>Demo project for Spring Boot</description>
  16.     <properties>
  17.         <java.version>1.8</java.version>
  18.     </properties>
  20.     <dependencies>
  21.         <dependency>
  22.             <groupId>org.springframework.boot</groupId>
  23.             <artifactId>spring-boot-starter</artifactId>
  24.         </dependency>
  25.         <dependency>
  26.             <groupId>org.springframework.boot</groupId>
  27.             <artifactId>spring-boot-starter-test</artifactId>
  28.             <scope>test</scope>
  29.         </dependency>
  30.         <dependency>
  31.             <groupId>org.springframework.cloud</groupId>
  32.             <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
  33.             <version>2.0.0.RELEASE</version>
  34.         </dependency>
  35.         <dependency>
  36.             <groupId>org.springframework.cloud</groupId>
  37.             <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  38.             <version>2.0.0.RELEASE</version>
  39.         </dependency>
  40.     </dependencies>
  42.     <build>
  43.         <plugins>
  44.             <plugin>
  45.                 <groupId>org.springframework.boot</groupId>
  46.                 <artifactId>spring-boot-maven-plugin</artifactId>
  47.             </plugin>
  48.         </plugins>
  49.     </build>
  50. </project>

3.2.2 在启动类上添加注解

在这里插入图片描述

3.2.3 添加HelloController

  1. package com.example.eurekaclient.controller;
  3. import org.springframework.web.bind.annotation.GetMapping;
  4. import org.springframework.web.bind.annotation.RestController;
  6. @RestController
  7. public class HelloController { 
  9.     @GetMapping(value = "/hello")
  10.     public String index() { 
  11.         return "hello，this is first messge";
  12.     }
  14. }

3.2.4 添加配置文件

application.properties

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

application-eureka-client1.properties

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

application-eureka-client2.properties

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

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

目录结构：
在这里插入图片描述

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

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <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">
  3.     <modelVersion>4.0.0</modelVersion>
  4.     <parent>
  5.         <groupId>org.springframework.boot</groupId>
  6.         <artifactId>spring-boot-starter-parent</artifactId>
  7.         <version>2.1.6.RELEASE</version>
  8.         <relativePath/> <!-- lookup parent from repository -->
  9.     </parent>
  10.     <groupId>com.example</groupId>
  11.     <artifactId>ribbon-consumer</artifactId>
  12.     <version>0.0.1-SNAPSHOT</version>
  13.     <name>ribbon-consumer</name>
  14.     <description>Demo project for Spring Boot</description>
  16.     <properties>
  17.         <java.version>1.8</java.version>
  18.     </properties>
  20.     <dependencies>
  21.         <dependency>
  22.             <groupId>org.springframework.boot</groupId>
  23.             <artifactId>spring-boot-starter</artifactId>
  24.         </dependency>
  25.         <dependency>
  26.             <groupId>org.springframework.boot</groupId>
  27.             <artifactId>spring-boot-starter-test</artifactId>
  28.             <scope>test</scope>
  29.         </dependency>
  30.         <dependency>
  31.             <groupId>org.springframework.cloud</groupId>
  32.             <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
  33.             <version>2.0.0.RELEASE</version>
  34.         </dependency>
  35.         <dependency>
  36.             <groupId>org.springframework.cloud</groupId>
  37.             <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  38.             <version>2.0.0.RELEASE</version>
  39.         </dependency>
  40.         <dependency>
  41.             <groupId>org.springframework.cloud</groupId>
  42.             <artifactId>spring-cloud-starter-ribbon</artifactId>
  43.             <version>1.3.6.RELEASE</version>
  44.         </dependency>
  45.     </dependencies>
  47.     <build>
  48.         <plugins>
  49.             <plugin>
  50.                 <groupId>org.springframework.boot</groupId>
  51.                 <artifactId>spring-boot-maven-plugin</artifactId>
  52.             </plugin>
  53.         </plugins>
  54.     </build>
  55. </project>

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

  1. package com.example.ribbonconsumer;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
  6. import org.springframework.cloud.client.loadbalancer.LoadBalanced;
  7. import org.springframework.context.annotation.Bean;
  8. import org.springframework.web.client.RestTemplate;
  10. @SpringBootApplication
  11. @EnableDiscoveryClient
  12. public class RibbonConsumerApplication { 
  14.     public static void main(String[] args) { 
  15.         SpringApplication.run(RibbonConsumerApplication.class, args);
  16.     }
  18.     @Bean
  19.     @LoadBalanced
  20.     RestTemplate restTemplate(){ 
  21.         return new RestTemplate();
  22.     }
  24. }

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

  1. package com.example.ribbonconsumer.controller;
  3. import org.springframework.beans.factory.annotation.Autowired;
  4. import org.springframework.web.bind.annotation.GetMapping;
  5. import org.springframework.web.bind.annotation.RestController;
  6. import org.springframework.web.client.RestTemplate;
  8. @RestController
  9. public class ConsumerController { 
  11.     @Autowired
  12.     RestTemplate restTemplate;
  14.     @GetMapping(value = "/ribbon-consumer")
  15.     public String helloConsumer() { 
  16.         return restTemplate.getForEntity("http://EUREKA-CLIENT/hello", String.class).getBody();
  17.     }
  19. }

3.4.4 添加配置文件

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

4 项目的启动配置

点击这个进入编辑列表
在这里插入图片描述
我的启动目录列表：
在这里插入图片描述

4.1配置启动列表

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

4.2 项目启动

在这里插入图片描述

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

4.3注意

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

4.4 启动结束

在这里插入图片描述

5 测试

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

6 项目代码

待上传

发表评论

表情：
评论列表 （有 0 条评论，449人围观）

还没有评论，来说两句吧...

相关阅读