SpringCloud构建微服务之Eureka服务注册与发现

男娘i 2021-12-14 03:45 462阅读 0赞

前言

在上篇文章我讲到如何搭建SpringCloud微服务基础环境，本次我将介绍Netflix的Eureka，并整合到SpringCloud中

什么是Eureka？

Eureka是Netflix的一个子模块，也是核心模块之一。Eureka是一个基于REST的服务，用于定位服务，以实现云端中间层服务发现和故障转移。服务注册与发现对于微服务架构来说是非常重要的，有了服务发现与注册，只需要使用服务的标识符，就可以访问到服务，而不需要修改服务调用的配置文件了。功能类似于dubbo的注册中心，比如Zookeeper。

Netflix在设计Eureka时遵守的就是AP原则

CAP原则又称CAP定理，指的是在一个分布式系统中，Consistency（一致性）、 Availability（可用性）、Partition tolerance（分区容错性），三者不可兼得

下面我们就来撸代码啦~

建立Eureka注册中心(spring-cloud-eureka)

首先建立一个Eureka父工程(spring-cloud-eureka))(此父工程非必需，看个人的工程层次结构的划分)，此处建立是便于知识点划分

选中父工程（`spring-cloud-examples``）鼠标点击右键File → Module → Maven
不用勾选任务任何选项，直接Next → Finish
在这里插入图片描述

创建好后，删除src目录，并选中spring-cloud-eureka工程，创建此工程的子模块eureka
选中父工程（spring-cloud-eureka）鼠标点击右键File → Module → Maven
不用勾选任务任何选项，直接Next → Finish
在这里插入图片描述
创建好后，修改eureka工程的pom文件

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <parent>
  6.         <artifactId>spring-cloud-eureka</artifactId>
  7.         <groupId>com.chaytech</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>eureka</artifactId>
  14.     <dependencies>
  15.         <!--eureka-server服务端 -->
  16.         <dependency>
  17.             <groupId>org.springframework.cloud</groupId>
  18.             <artifactId>spring-cloud-starter-eureka-server</artifactId>
  19.         </dependency>
  20.         <!-- 修改后立即生效，热部署 -->
  21.         <dependency>
  22.             <groupId>org.springframework</groupId>
  23.             <artifactId>springloaded</artifactId>
  24.         </dependency>
  25.         <dependency>
  26.             <groupId>org.springframework.boot</groupId>
  27.             <artifactId>spring-boot-devtools</artifactId>
  28.         </dependency>
  29.     </dependencies>
  30. </project>

创建application.yml

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

启动类

  1. @SpringBootApplication
  2. // EurekaServer服务器端启动类,接受其它微服务注册进来
  3. @EnableEurekaServer
  4. public class EurekaServer7001_Application {
  5.     public static void main(String[] args) {
  6.         SpringApplication.run(EurekaServer7001_Application.class, args);
  7.     }
  8. }

启动eureka工程，测试
浏览器中访问：http://localhost:7001/

显示页面
在这里插入图片描述
ok，eureka注册中心已成功搭建！

但是细心的人可以发现页面中显示No application available 翻译成中文的意思是：没有服务被发现

因为没有注册服务进来当然不可能有服务被发现，下面将介绍如何将服务注册到eureka中

上面步骤完成后看看结构是不是和我这一样呢？
最终工程展现
在这里插入图片描述

将已有的(spring-cloud-provider-user)用户微服务注册进eureka

不要慌，服务注册不是很复杂，只需小改代码和配置文件即可
修改spring-cloud-provider-user的pom文件
增加如下内容

  1. <!-- 将微服务provider侧注册进eureka -->
  2.    <dependency>
  3.      <groupId>org.springframework.cloud</groupId>
  4.      <artifactId>spring-cloud-starter-eureka</artifactId>
  5.    </dependency>
  6.    <dependency>
  7.      <groupId>org.springframework.cloud</groupId>
  8.      <artifactId>spring-cloud-starter-config</artifactId>
  9.    </dependency>

修改后的完整pom文件

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <parent>
  6.         <artifactId>spring-cloud-examples</artifactId>
  7.         <groupId>com.chaytech</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>spring-cloud-provider-user</artifactId>
  13.     <packaging>jar</packaging>
  15.     <dependencies>
  16.         <dependency>
  17.             <groupId>com.chaytech</groupId>
  18.             <artifactId>spring-cloud-model</artifactId>
  19.             <version>${project.version}</version>
  20.         </dependency>
  21.         <!-- 将微服务provider侧注册进eureka -->
  22.         <dependency>
  23.             <groupId>org.springframework.cloud</groupId>
  24.             <artifactId>spring-cloud-starter-eureka</artifactId>
  25.         </dependency>
  26.         <dependency>
  27.             <groupId>org.springframework.cloud</groupId>
  28.             <artifactId>spring-cloud-starter-config</artifactId>
  29.         </dependency>
  30.         <dependency>
  31.             <groupId>junit</groupId>
  32.             <artifactId>junit</artifactId>
  33.         </dependency>
  34.         <dependency>
  35.             <groupId>mysql</groupId>
  36.             <artifactId>mysql-connector-java</artifactId>
  37.         </dependency>
  38.         <dependency>
  39.             <groupId>com.alibaba</groupId>
  40.             <artifactId>druid</artifactId>
  41.         </dependency>
  42.         <dependency>
  43.             <groupId>ch.qos.logback</groupId>
  44.             <artifactId>logback-core</artifactId>
  45.         </dependency>
  46.         <dependency>
  47.             <groupId>org.mybatis.spring.boot</groupId>
  48.             <artifactId>mybatis-spring-boot-starter</artifactId>
  49.         </dependency>
  50.         <dependency>
  51.             <groupId>org.springframework.boot</groupId>
  52.             <artifactId>spring-boot-starter-tomcat</artifactId>
  53.         </dependency>
  54.         <dependency>
  55.             <groupId>org.springframework.boot</groupId>
  56.             <artifactId>spring-boot-starter-web</artifactId>
  57.         </dependency>
  58.         <dependency>
  59.             <groupId>org.springframework.boot</groupId>
  60.             <artifactId>spring-boot-starter-test</artifactId>
  61.         </dependency>
  62.         <!-- 修改后立即生效，热部署 -->
  63.         <dependency>
  64.             <groupId>org.springframework</groupId>
  65.             <artifactId>springloaded</artifactId>
  66.         </dependency>
  67.         <dependency>
  68.             <groupId>org.springframework.boot</groupId>
  69.             <artifactId>spring-boot-devtools</artifactId>
  70.         </dependency>
  71.     </dependencies>
  72. </project>

修改application.yml文件
增减如下内容

  1. eureka:
  2.   client: #客户端注册进eureka服务列表内
  3.     service-url:
  4.       defaultZone: http://localhost:7001/eureka

修改后的完整application.yml文件

  1. server:
  2.   port: 8001
  4. mybatis:
  5.   config-location: classpath:mybatis/mybatis-config.xml        # mybatis配置文件所在路径
  6.   type-aliases-package: com.chaytech.model.*    # 所有Entity别名类所在包
  7.   mapper-locations:
  8.   - classpath:mybatis/mapper/**/*.xml                       # mapper映射文件
  10. spring:
  11.    application:
  12.     name: user-provider
  13.    datasource:
  14.     type: com.alibaba.druid.pool.DruidDataSource            # 当前数据源操作类型
  15.     driver-class-name: org.gjt.mm.mysql.Driver              # mysql驱动包
  16.     url: jdbc:mysql://127.0.0.1:3306/spring_cloud_db01              # 数据库名称
  17.     username: root
  18.     password: root
  19.     dbcp2:
  20.       min-idle: 5                                           # 数据库连接池的最小维持连接数
  21.       initial-size: 5                                       # 初始化连接数
  22.       max-total: 5                                          # 最大连接数
  23.       max-wait-millis: 200                                  # 等待连接获取的最大超时时间
  25. eureka:
  26.   client: #客户端注册进eureka服务列表内
  27.     service-url:
  28.       defaultZone: http://localhost:7001/eureka

修改spring-cloud-provider-user服务启动类，增加@EnableEurekaClient注解，此注解代表此服务是eureka客户端，并将此服务注册进eureka服务中

  1. @SpringBootApplication
  2. // 本服务启动后会自动注册进eureka服务中
  3. @EnableEurekaClient
  4. public class UserProvider8001_Application {
  6.     public static void main(String[] args) {
  7.         SpringApplication.run(UserProvider8001_Application.class,args);
  8.     }
  9. }

测试
要先启动EurekaServer也是前面建立的eureka工程，再启动spring-cloud-provider-user
再次访问：http://localhost:7001/
在这里插入图片描述
可以看到此时没有No application available提示了，有服务注册进来了

此处注意了，列表Application列显示的名称就是我们在配置文件中配置的spring.application.name
在这里插入图片描述
在这里插入图片描述
然后再看列表最后面的Status列，数据是带超链接的，点击可以跳转，但此时点击显示Error Page
在这里插入图片描述
这个info是SpringBoot内置的restful api请求，用来显示任意的应用信息，因为没有配置所以会跳转到Error Page页面，下面咱们来配置一下。

在spring-cloud-provider-userpom文件中引入actuaotrjar包，新增如下内容

  1. <!-- actuaotr服务监控-->
  2.  <dependency>
  3.      <groupId>org.springframework.boot</groupId>
  4.      <artifactId>spring-boot-starter-actuator</artifactId>
  5.  </dependency>

如果需要通过info接口来获取maven中的属性内容需要在父工程(spring-cloud-examples)添加如下配置

  1. <build>
  2.         <finalName>spring-cloud-examples</finalName>
  3.         <resources>
  4.             <resource>
  5.                 <directory>src/main/resources</directory>
  6.                 <filtering>true</filtering>
  7.             </resource>
  8.         </resources>
  9.         <plugins>
  10.             <plugin>
  11.                 <groupId>org.apache.maven.plugins</groupId>
  12.                 <artifactId>maven-resources-plugin</artifactId>
  13.                 <configuration>
  14.                     <delimiters>
  15.                         <delimit>$</delimit>
  16.                     </delimiters>
  17.                 </configuration>
  18.             </plugin>
  19.         </plugins>
  20.     </build>

修改application.yml文件，增加info信息

  1. info:
  2.   app.name: user-provider
  3.   build.artifactId: $project.artifactId$
  4.   build.version: $project.version$

重新build整个微服务工程 ，重启服务，再次访问
在这里插入图片描述
可以看到返回了一个json串，内容就是我们在application.yml中配置的

eureka自我保护

在前面我们介绍eureka的时候有说到eureka是AP的，那就说明他又一定的容错机制，也就是指的eureka有自我保护机制。
下面我们来做一下实验，启动eureka服务端和服务提供者，然后将服务提供者停掉，等几分钟访问http://localhost:7001/ 看看会出现什么
如果不出意外的话，会出现如下图所示
在这里插入图片描述
这是eureka给的警告提示，由于spring-cloud-provider-user服务注册到eureka之后，我们将服务停掉了，也就没有再给eureka发送心跳了，这个时候eureka不会立刻清理，依旧会对该微服务的信息进行保存。

默认情况下，如果EurekaServer在一定时间内没有接收到某个微服务实例的心跳，EurekaServer将会注销该实例（默认90秒）。但是当网络分区故障发生时，微服务与EurekaServer之间无法正常通信，以上行为可能变得非常危险了——因为微服务本身其实是健康的，此时本不应该注销这个微服务。Eureka通过“自我保护模式”来解决这个问题——当EurekaServer节点在短时间内丢失过多客户端时（可能发生了网络分区故障），那么这个节点就会进入自我保护模式。一旦进入该模式，EurekaServer就会保护服务注册表中的信息，不再删除服务注册表中的数据（也就是不会注销任何微服务）。当网络故障恢复后，该Eureka Server节点会自动退出自我保护模式。

在自我保护模式中，Eureka Server会保护服务注册表中的信息，不再注销任何服务实例。当它收到的心跳数重新恢复到阈值以上时，该Eureka Server节点就会自动退出自我保护模式。它的设计哲学就是宁可保留错误的服务注册信息，也不盲目注销任何可能健康的服务实例。一句话讲解：好死不如赖活着

综上，自我保护模式是一种应对网络异常的安全保护措施。它的架构哲学是宁可同时保留所有微服务（健康的微服务和不健康的微服务都会保留），也不盲目注销任何健康的微服务。使用自我保护模式，可以让Eureka集群更加的健壮、稳定。

在Spring Cloud中，可以使用eureka.server.enable-self-preservation = false配置禁用自我保护模式。

发表评论

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

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

相关阅读