springcloud-Eureka集群实战

超、凢脫俗 2022-11-03 15:28 271阅读 0赞

springcloud-Eureka集群实战

    • 1、Eureka简介
    • 2、修改hosts文件
    • 3、新建一个maven模块，取名springcloud-eureka-7001
        1. 编写pom.xml文件
        1. 编写application.yml
        1. 编写启动类
        1. 启动测试
    • 4、新建一个maven模块，取名springcloud-eureka-7002
        1. 编写pom.xml文件
        1. 编写application.yml
        1. 编写启动类
        1. 启动测试
    • 5、修改springcloud-provider-user-8001子模块
        1. 修改pom.xml
        1. 修改配置
        1. 启动类添加注解
    • 6、测试

1、Eureka简介

  • Eureka是Netflix开发的服务发现框架，本身是一个基于REST的服务，主要用于定位运行在AWS域中的中间层服务，以达到负载均衡和中间层服务故障转移的目的。SpringCloud将它集成在其子项目spring-cloud-netflix中，以实现SpringCloud的服务发现功能。
  • Eureka包含两个组件：Eureka Server和Eureka Client。
  • Eureka Server提供服务注册服务，各个节点启动后，会在Eureka Server中进行注册，这样EurekaServer中的服务注册表中将会存储所有可用服务节点的信息，服务节点的信息可以在界面中直观的看到。
  • Eureka Client是一个java客户端，用于简化与Eureka Server的交互，客户端同时也就是一个内置的、使用轮询(round-robin)负载算法的负载均衡器。
  • 在应用启动后，将会向Eureka Server发送心跳,默认周期为30秒，如果Eureka Server在多个心跳周期内没有接收到某个节点的心跳，Eureka Server将会从服务注册表中把这个服务节点移除(默认90秒)。
  • Eureka Server之间通过复制的方式完成数据的同步，Eureka还提供了客户端缓存机制，即使所有的Eureka Server都挂掉，客户端依然可以利用缓存中的信息消费其他服务的API。综上，Eureka通过心跳检查、客户端缓存等机制，确保了系统的高可用性、灵活性和可伸缩性。
    （百度百科）

2、修改hosts文件

在 C:\Windows\System32\drivers\etc 的hosts文件追加如下内容

  1. 127.0.0.1   ybg.eureka1.com
  2. 127.0.0.1   ybg.eureka2.com

3、新建一个maven模块，取名springcloud-eureka-7001

springcloud-eureka-7001是其中的一个注册中心

1. 编写pom.xml文件

  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.     <parent>
  4.         <artifactId>springcloud</artifactId>
  5.         <groupId>org.example</groupId>
  6.         <version>1.0-SNAPSHOT</version>
  7.     </parent>
  8.     <modelVersion>4.0.0</modelVersion>
  10.     <artifactId>springcloud-eureka-7001</artifactId>
  11.     <!-- 导包 -->
  12.     <dependencies>
  14.         <!-- eureka -->
  15.         <dependency>
  16.             <groupId>org.springframework.cloud</groupId>
  17.             <artifactId>spring-cloud-starter-eureka-server</artifactId>
  18.             <version>1.4.6.RELEASE</version>
  19.         </dependency>
  21.         <!-- 热部署工具 -->
  22.         <dependency>
  23.             <groupId>org.springframework.boot</groupId>
  24.             <artifactId>spring-boot-devtools</artifactId>
  25.         </dependency>
  27.     </dependencies>
  28. </project>

2. 编写application.yml

  1. server:
  2.   port: 7001
  4. # Eureka 配置
  5. eureka:
  6.   instance:
  7.     hostname: ybg.eureka1.com     # Eureka 服务端的实例名称
  8.   client:
  9.     fetch-registry: false       # fetch-registry为false表示自己为注册中心
  10.     register-with-eureka: false    # 表示是否向eureka注册中心注册自己
  11.     service-url:        # 监控页面
  12.       # 单机 defaultZone: http://${ eureka.instance.hostname}:${ server.port}/eureka/
  13.       # 集群（关联） 后面有多少个就接多少个，用逗号隔开
  14.       defaultZone: http://ybg.eureka2.com:7002/eureka/

3. 编写启动类

  1. package com.hzxy.springcloud;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
  7. @SpringBootApplication
  8. @EnableEurekaServer
  9. public class Eureka_7001 { 
  10.     public static void main(String[] args) { 
  11.         SpringApplication.run(Eureka_7001.class,args);
  12.     }
  13. }

4. 启动测试

在这里插入图片描述
成功！

4、新建一个maven模块，取名springcloud-eureka-7002

springcloud-eureka-7002是其中的一个注册中心，两个一起组成一个集群

1. 编写pom.xml文件

  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.     <parent>
  4.         <artifactId>springcloud</artifactId>
  5.         <groupId>org.example</groupId>
  6.         <version>1.0-SNAPSHOT</version>
  7.     </parent>
  8.     <modelVersion>4.0.0</modelVersion>
  10.     <artifactId>springcloud-eureka-7002</artifactId>
  12.     <!-- 导包 -->
  13.     <dependencies>
  14.         <!-- eureka -->
  15.         <dependency>
  16.             <groupId>org.springframework.cloud</groupId>
  17.             <artifactId>spring-cloud-starter-eureka-server</artifactId>
  18.             <version>1.4.6.RELEASE</version>
  19.         </dependency>
  21.         <!-- 热部署工具 -->
  22.         <dependency>
  23.             <groupId>org.springframework.boot</groupId>
  24.             <artifactId>spring-boot-devtools</artifactId>
  25.         </dependency>
  26.     </dependencies>
  29. </project>

2. 编写application.yml

  1. server:
  2.   port: 7002
  4. # Eureka 配置
  5. eureka:
  6.   instance:
  7.     hostname: ybg.eureka2.com     # Eureka 服务端的实例名称
  8.   client:
  9.     fetch-registry: false       # fetch-registry为false表示自己为注册中心
  10.     register-with-eureka: false    # 表示是否向eureka注册中心注册自己
  11.     service-url:        # 监控页面
  12.       # 单机 defaultZone: http://${ eureka.instance.hostname}:${ server.port}/eureka/
  13.       # 集群（关联） 后面有多少个就接多少个，用逗号隔开
  14.       defaultZone: http://ybg.eureka1.com:7001/eureka/

3. 编写启动类

  1. package com.hzxy.springcloud;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
  7. @SpringBootApplication
  8. @EnableEurekaServer
  9. public class Eureka_7002 { 
  10.     public static void main(String[] args) { 
  11.         SpringApplication.run(Eureka_7002.class,args);
  12.     }
  13. }

4. 启动测试

在这里插入图片描述
成功！

5、修改springcloud-provider-user-8001子模块

我们使用https://blog.csdn.net/weixin\_43520670/article/details/114215777这个的8001端口作为基础

1. 修改pom.xml

修改后

  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.     <parent>
  4.         <artifactId>springcloud</artifactId>
  5.         <groupId>org.example</groupId>
  6.         <version>1.0-SNAPSHOT</version>
  7.     </parent>
  8.     <modelVersion>4.0.0</modelVersion>
  10.     <artifactId>springcloud-provier-user-8001</artifactId>
  12.     <dependencies>
  14.         <!-- springboot -->
  15.         <dependency>
  16.             <groupId>org.springframework.boot</groupId>
  17.             <artifactId>spring-boot-starter-web</artifactId>
  18.         </dependency>
  20.         <dependency>
  21.             <groupId>org.springframework.boot</groupId>
  22.             <artifactId>spring-boot-starter-actuator</artifactId>
  23.         </dependency>
  24.         <!-- eureka -->
  25.         <dependency>
  26.             <groupId>org.springframework.cloud</groupId>
  27.             <artifactId>spring-cloud-starter-eureka</artifactId>
  28.             <version>1.4.6.RELEASE</version>
  29.         </dependency>
  32.         <!-- 我们需要拿到实体类 ，所以配置api module -->
  33.         <dependency>
  34.             <groupId>org.example</groupId>
  35.             <artifactId>springcloud-api</artifactId>
  36.             <version>1.0-SNAPSHOT</version>
  37.         </dependency>
  39.         <!-- junit -->
  40.         <dependency>
  41.             <groupId>junit</groupId>
  42.             <artifactId>junit</artifactId>
  43.             <scope>test</scope>
  44.         </dependency>
  46.         <!-- 数据库驱动 -->
  47.         <dependency>
  48.             <groupId>mysql</groupId>
  49.             <artifactId>mysql-connector-java</artifactId>
  50.         </dependency>
  53.         <!-- mybatis_plus -->
  54.         <dependency>
  55.             <groupId>com.baomidou</groupId>
  56.             <artifactId>mybatis-plus-boot-starter</artifactId>
  57.         </dependency>
  59.         <!--druid-->
  60.         <dependency>
  61.             <groupId>com.alibaba</groupId>
  62.             <artifactId>druid</artifactId>
  63.             <version>1.1.18</version>
  64.         </dependency>
  66.         <dependency>
  67.             <groupId>org.springframework.boot</groupId>
  68.             <artifactId>spring-boot-test</artifactId>
  69.         </dependency>
  71.         <dependency>
  72.             <groupId>ch.qos.logback</groupId>
  73.             <artifactId>logback-core</artifactId>
  74.         </dependency>
  76.         <!-- jetty -->
  77.         <dependency>
  78.             <groupId>org.springframework.boot</groupId>
  79.             <artifactId>spring-boot-starter-jetty</artifactId>
  80.         </dependency>
  82.         <!-- 热部署工具 -->
  83.         <dependency>
  84.             <groupId>org.springframework.boot</groupId>
  85.             <artifactId>spring-boot-devtools</artifactId>
  86.         </dependency>
  87.     </dependencies>
  89. </project>

2. 修改配置

修改后

  1. server:
  2.   port: 8001
  3. spring:
  4.   application:
  5.     name: springcloud-provider-user
  6.   datasource:
  7.     driver-class-name: com.mysql.cj.jdbc.Driver
  8.     type: com.alibaba.druid.pool.DruidDataSource
  9.     url: jdbc:mysql://localhost:3306/mybatis_plus?serverTimezone=GMT%2B8
  10.     username: root
  11.     password: 520China
  14. mybatis-plus:
  15.   configuration:
  16.     log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
  17.   global-config:
  18.     db-config:
  19.       logic-delete-value: 1
  20.       logic-not-delete-value: 0
  22. # Eureka 配置
  23. eureka:
  24.   client:
  25.     service-url:
  26.       defaultZone: http://ybg.eureka1.com:7001/eureka/,http://ybg.eureka2.com:7002/eureka/   # 发布在哪个网址的注册中心
  27.   instance:
  28.     instance-id: springcloud-provider-user-8001  #修改Eureka上的描述信息
  30. # info配置
  31. info:
  32.   app.name: ybg-springcloud
  33.   company.name: www.hzxy.com

3. 启动类添加注解

添加@EnableEurekaClient 注解，让它自动注册到Eureka

  1. package com.hzxy.springcloud;
  3. import org.mybatis.spring.annotation.MapperScan;
  4. import org.springframework.boot.SpringApplication;
  5. import org.springframework.boot.autoconfigure.SpringBootApplication;
  6. import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
  7. import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
  9. @MapperScan("com.hzxy.springcloud.mapper")
  10. @EnableDiscoveryClient       //服务发现
  11. @EnableEurekaClient      //在服务启动后自动注册到Eureka中
  12. @SpringBootApplication
  13. public class Provider_8001 { 
  14.     public static void main(String[] args) { 
  15.         SpringApplication.run(Provider_8001.class,args);
  16.     }
  17. }

6、测试

分别启动三个服务
在这里插入图片描述
然后访问http://ybg.eureka1.com:7001/，如下
在这里插入图片描述
然后再访问http://ybg.eureka1.com:7002/，如下
在这里插入图片描述
我们关掉7002，模拟7002服务器出现故障无法正常运行
在这里插入图片描述
然后访问http://ybg.eureka1.com:7002/，如下，访问失败
在这里插入图片描述
我们在访问http://ybg.eureka1.com:7001/，如下，它可以继续运行，但是有一个红字，表示有一个服务挂了
在这里插入图片描述
如此，测试成功！

发表评论

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

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

相关阅读