Spring Cloud 之Eureka初使用

我会带着你远行 2022-12-14 13:39 132阅读 0赞

推荐：[微服务汇总][Link 1]

## Spring Cloud 之Eureka初使用 ##

首先创建一个Spring Boot项目作为Eureka Server，毕竟Spring Cloud是基于Spring Boot的。

`pom.xml`如下:

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
    
        <groupId>com.kaven</groupId>
        <artifactId>eureka</artifactId>
        <version>0.0.1-SNAPSHOT</version>
    
        <name>eureka</name>
        <description>Demo project for Spring Boot</description>
    
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.0.6.RELEASE</version>
            <relativePath/> 
        </parent>
    
        <properties>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
            <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
            <java.version>1.8</java.version>
            <spring-cloud.version>Finchley.SR2</spring-cloud.version>
        </properties>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
        </dependencies>
    
        <dependencyManagement>
            <dependencies>
                <dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-dependencies</artifactId>
                    <version>${spring-cloud.version}</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
            </dependencies>
        </dependencyManagement>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    </project>

`application.yml`如下：

eureka:
      client:
        service-url:
          defaultZone: http://localhost:8761/eureka/
        register-with-eureka: false
      server:
        enable-self-preservation: false
    
    spring:
      application:
        name: eureka
    
    server:
      port: 8761

`register-with-eureka`是表示该服务是否需要注册到Eureka Server上（以Eureka Client的身份），因为它本身是Eureka Server，所以这里设置为`false`，实际上它也是Eureka Client，也可以提供服务。  
`enable-self-preservation`是表示该服务是否开启自我保护模式（以Eureka Server的身份），默认是开启，之后会对这个配置进行演示。

按Ctrl点击配置项，比如`service-url`，就可以看到源码如下：

/** * Map of availability zone to list of fully qualified URLs to communicate with eureka * server. Each value can be a single URL or a comma separated list of alternative * locations. * * Typically the eureka server URLs carry protocol,host,port,context and version * information if any. Example: * http://ec2-256-156-243-129.compute-1.amazonaws.com:7001/eureka/ * * The changes are effective at runtime at the next service url refresh cycle as * specified by eurekaServiceUrlPollIntervalSeconds. */
    	private Map<String, String> serviceUrl = new HashMap<>();
    
    	{ 
    		this.serviceUrl.put(DEFAULT_ZONE, DEFAULT_URL);
    	}

它是一个`Map<String, String>`型数据，`key`为`DEFAULT_ZONE`，`value`为`DEFAULT_URL`。

public static final String DEFAULT_URL = "http://localhost:8761" + DEFAULT_PREFIX
    			+ "/";
    
    	public static final String DEFAULT_ZONE = "defaultZone";

`DEFAULT_ZONE`为`"defaultZone"`。

public static final String DEFAULT_PREFIX = "/eureka";

`DEFAULT_URL`为`"http://localhost:8761/eureka"`。

所以我们这里配置`defaultZone: http://localhost:8761/eureka/`（也可以设置成其他的端口，这里只是习惯配置为8761），如果有多个`service-url`需要配置，可以这样写：

eureka:
      client:
        service-url:
          defaultZone: http://localhost:8761/eureka/,http://localhost:8762/eureka/

使用这种方式来部署多个Eureka Server，以便实现Eureka的高可用，这里就不演示了，之后的博客再详细说明。

配置项应该如何配置？就像上面一样，点进去看源码即可，其他配置项就不说明了。

启动类：

package com.kaven.eureka;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
    
    @SpringBootApplication
    @EnableEurekaServer
    public class EurekaApplication { 
    
        public static void main(String[] args) { 
            SpringApplication.run(EurekaApplication.class, args);
        }
    }

作为Eureka Server要在启动类上加`@EnableEurekaServer`注解。

这样Eureka Server就完成了，运行启动类，访问`http://localhost:8761/`，可以看到如下画面：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTYwNjAz_size_16_color_FFFFFF_t_70]  
再来创建Eureka Client。

`pom.xml`如下:

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
    
        <groupId>com.kaven</groupId>
        <artifactId>eureka-client</artifactId>
        <version>0.0.1-SNAPSHOT</version>
    
        <name>eureka-client</name>
        <description>Demo project for Spring Boot</description>
    
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.0.6.RELEASE</version>
            <relativePath/> 
        </parent>
    
        <properties>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
            <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
            <java.version>1.8</java.version>
            <spring-cloud.version>Finchley.SR2</spring-cloud.version>
        </properties>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
        </dependencies>
    
        <dependencyManagement>
            <dependencies>
                <dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-dependencies</artifactId>
                    <version>${spring-cloud.version}</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
            </dependencies>
        </dependencyManagement>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    </project>

`application.yml`如下：

eureka:
      client:
        service-url:
          defaultZone: http://localhost:8761/eureka/
    
    spring:
      application:
        name: eureka-client
    
    server:
      port: 8080

启动类：

package com.kaven.eureka;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    
    @SpringBootApplication
    @EnableDiscoveryClient
    public class EurekaClientApplication { 
    
        public static void main(String[] args) { 
            SpringApplication.run(EurekaClientApplication.class, args);
        }
    
    }

作为Eureka Client要在启动类上加`@EnableDiscoveryClient`注解。

再运行Eureka Client的启动类，再等一小会就可以看到如下画面：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTYwNjAz_size_16_color_FFFFFF_t_70 1]

再将Eureka Server的配置文件`application.yml`修改一下：

eureka:
      client:
        service-url:
          defaultZone: http://localhost:8761/eureka/
        register-with-eureka: false
      server:
        enable-self-preservation: true
    
    spring:
      application:
        name: eureka
    
    server:
      port: 8761

就是将`enable-self-preservation`设置为`true`，之前说过要演示一下这个配置。

再去看一下界面，警告是不是没有了。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTYwNjAz_size_16_color_FFFFFF_t_70 2]  
我们停止Eureka Client，再等一段时间。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTYwNjAz_size_16_color_FFFFFF_t_70 3]  
Eureka Server进入自我保护模式，并且发出警告了，但Eureka Client并没有被删除（不管多久）。

Eureka Server和Eureka Client之间每隔30秒会进行一次心跳通信，以便告诉Eureka Server，这个Eureka Client还活着。

当Eureka Server在短时间内丢失了过多Eureka Client的连接时（比如网络故障或频繁的启动关闭Eureka Client），那么Eureka Server就会进入自我保护模式，一旦进入到该模式，Eureka Server就会保护服务注册表中的信息，不再删除服务注册表中的数据（即不会注销任何微服务），当网络故障恢复后，该Ereaka Server就会自动退出自我保护模式。

关闭自我保护模式后（`enable-self-preservation`为`false`），如果Ereaka Server在一段时间内没有接受到某个微服务（Eureka Client）的心跳，便会注销该实例（默认90秒），而一旦进入自我保护模式，那么即使你关闭了某个微服务，仍然会发现Ereaka Server的注册实例中会存在被关闭的微服务。

`enable-self-preservation`为`false`时，关闭Eureka Client后一段时间，Eureka Client会被Ereaka Server注销，如下图：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTYwNjAz_size_16_color_FFFFFF_t_70_pic_center]

Spring Cloud的Eureka初使用就到这里。

写博客是博主记录自己的学习过程，如果有错误，请指正，谢谢！

[Link 1]: https://kaven.blog.csdn.net/article/details/109063924
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTYwNjAz_size_16_color_FFFFFF_t_70]: /images/20221123/e4c6d305f4b84653a049a8e0cca64474.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTYwNjAz_size_16_color_FFFFFF_t_70 1]: /images/20221123/093b97afbdbb4cd783e0ff2add713318.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTYwNjAz_size_16_color_FFFFFF_t_70 2]: /images/20221123/f483fec834674134a2c5c81c304831fb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTYwNjAz_size_16_color_FFFFFF_t_70 3]: /images/20221123/cd1bda2ee6ec4324b48eef2233517d34.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTYwNjAz_size_16_color_FFFFFF_t_70_pic_center]: /images/20221123/a0a6f8b535734d59af9e77105a1988f0.png