Spring Eureka 初探及集群搭建

时间  2019-11-06
标签 spring eureka 初探 集群 搭建 栏目 Spring 繁體版
原文   原文链接

本文首发于我的的公众号：Java技术大杂烩，欢迎关注共同窗习，有Spring , Mybatis, Redis, JDK 等源码分析的文章java

本文将从如下方面进行介绍git

前言
例子
搭建集群github

前言

Eureka 主要是用于进行服务的注册和发现，今天就来学习一下如何使用 Eureka，关于 Eureka的更多信息能够参考 Netflix / eureka 和 Spring-Eurekaweb

Eureka 的主要架构图以下所示：spring

Eureka 主要有三种角色，Eureka Server, Eureka Client，其中 Eureka Client 包括 Service Provider 和 Service Consumerapache

一、Eureka Server ：注册中心，提供服务注册和发现，注册中心能够搭建成集群模式来实现服务的高可用json

二、Service Provider ： 服务提供方，将自身服务注册到Eureka，从而使服务消费方可以找到浏览器

三、Service Consumer：服务消费方，从Eureka获取注册服务列表，从而可以消费服务bash

例子

接下来，根据 Spring Eureka 的  官方文档 来手动写一个例子。服务器

Eureka Server 

先来实现 Eureka Server 注册中心，首先新建 Spring 的 maven 项目， 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>

    <groupId>com.tsmyk</groupId>
    <artifactId>eureka_server</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>eureka_server</name>
    <description>Demo project for Spring Boot</description>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.6.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <properties>
        <java.version>1.8</java.version>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <spring-cloud.version>Greenwich.SR1</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.properties 配置文件中添加以下配置：

spring.application.name=spring-cloud-eureka
# 端口
server.port=8761
# IP
server.ip=localhost

#表示是否将本身注册到Eureka Server，默认为true。
eureka.client.register-with-eureka=false
#表示是否从Eureka Server获取注册信息，默认为true。
eureka.client.fetch-registry=false

#设置与Eureka Server交互的地址，查询服务和注册服务都须要依赖这个地址, 多个地址可以使用,分隔。
eureka.client.serviceUrl.defaultZone=http://${server.ip}:${server.port}/eureka/

logging.level.com.netflix.eureka=OFF
logging.level.com.netflix.discovery=OFF

由于它是一个服务注册中心，本身不须要向本身注册，也不须要中注册中心获取服务，因此须要把这两项设为false：eureka.client.register-with-eureka，eureka.client.fetch-registry

以后，在启动类上面加上注解 @EnableEurekaServer ，运行：

@EnableEurekaServer
@SpringBootApplication
public class EurekaServerApplication {

    public static void main(String[] args) {
        SpringApplication.run(EurekaServerApplication.class, args);
    }
}

在浏览器中输入：http://localhost:8761/ 显示以下页面，就表示 Eureka Server 注册中心就搭建好了：

因为咱们尚未注册任何的实例，因此在 Instances currently registered with Eureka 中显示没有可用的实例。

Eureka Client

接下来，写一个 Eureka Client ，向注册中心注册服务。

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/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.tsmyk</groupId>
    <artifactId>eureka_client_2</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>eureka_client_2</name>
    <description>Demo project for Spring Boot</description>

    <properties>
        <java.version>1.8</java.version>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <spring-cloud.version>Greenwich.SR1</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.properties 的配置以下：

#端口号
server.port=8765
#服务名
spring.application.name=eureka-client-2

#注册到eureka中心，获取到配置服务
eureka.client.service-url.defaultZone=http://localhost:8761/eureka/

#设置实例的ID为ip:port
eureka.instance.instance-id=localhost:${server.port}

# 心跳时间，即服务续约间隔时间（缺省为30s）
eureka.instance.lease-renewal-interval-in-seconds=5

# 发呆时间，即服务续约到期时间（缺省为90s）
eureka.instance.lease-expiration-duration-in-seconds=10

以后，在启动类加上注解 @EnableDiscoveryClient，运行：

@EnableDiscoveryClient
@SpringBootApplication
public class EurekaClient2Application {
    public static void main(String[] args) {
        SpringApplication.run(EurekaClient2Application.class, args);
    }
}

此时，在浏览器中输入上面的网址：http://localhost:8761/，以下：

此时能够看到，咱们的 Eureka-client 已经注册上了，状态为 UP，地址为：locahost:8765.

以上就是一个简单的服务的注册于发现的例子。

Eureka Server 集群

为了保证注册中心的高可用，Eureka Server 注册中心通常须要搭建为集群模式，如今，就来搭建三个Eureka Server注册中心实现集群模式。每一个注册中心的  eureka.client.service-url.defaultZone 须要指向其余两个 Eureka Server 注册中心地址。

新建三个Spring项目，分别为三个 Eureka Server 注册中心，代码和上面的同样，只不过配置文件有所不一样

第一个Eureka Server 注册中心的配置文件：

spring.application.name=spring-cloud-eureka
# 端口
server.port=8761
eureka.instance.hostname=eureka-server-peer1

#表示是否将本身注册到Eureka Server，默认为true。
eureka.client.register-with-eureka=true
#表示是否从Eureka Server获取注册信息，默认为true。
eureka.client.fetch-registry=true

#设置与Eureka Server交互的地址，查询服务和注册服务都须要依赖这个地址, 多个地址可以使用,分隔。
eureka.client.serviceUrl.defaultZone=http://eureka-server-peer2:8762/eureka/,http://eureka-server-peer3:8763/eureka/

logging.level.com.netflix.eureka=OFF
logging.level.com.netflix.discovery=OFF

其中，须要把 eureka.client.register-with-eureka，eureka.client.fetch-registry 设为 true，而后，eureka.client.serviceUrl.defaultZone 指向其余两个注册中心的地址。

第二个Eureka Server 注册中心的配置文件：

spring.application.name=spring-cloud-eureka

# 端口
server.port=8762
eureka.instance.hostname=eureka-server-peer2

#表示是否将本身注册到Eureka Server，默认为true。
eureka.client.register-with-eureka=true
#表示是否从Eureka Server获取注册信息，默认为true。
eureka.client.fetch-registry=true

#设置与Eureka Server交互的地址，查询服务和注册服务都须要依赖这个地址, 多个地址可以使用,分隔。
eureka.client.serviceUrl.defaultZone=http://eureka-server-peer1:8761/eureka/,http://eureka-server-peer3:8763/eureka/

#为false，关闭自我保护
eureka.server.enable-self-preservation=false
#清理间隔, 单位毫秒，默认是60*1000
eureka.server.eviction-interval-timer-in-ms=4000

logging.level.com.netflix.eureka=OFF
logging.level.com.netflix.discovery=OFF

第三个 Eureka Server 注册中心的配置文件：

spring.application.name=spring-cloud-eureka

# 端口
server.port=8763
eureka.instance.hostname=eureka-server-peer3

#表示是否将本身注册到Eureka Server，默认为true。
eureka.client.register-with-eureka=true
#表示是否从Eureka Server获取注册信息，默认为true。
eureka.client.fetch-registry=true

#设置与Eureka Server交互的地址，查询服务和注册服务都须要依赖这个地址, 多个地址可以使用,分隔。
eureka.client.serviceUrl.defaultZone=http://eureka-server-peer1:8761/eureka/,http://eureka-server-peer2:8762/eureka/

logging.level.com.netflix.eureka=OFF
logging.level.com.netflix.discovery=OFF

如今，再写两个 Eureka Clinet 分别向 eureka-server-peer1 和 eureka-server-peer3 进行注册，

第一个 Eureka Clinet 配置文件：

#端口号
server.port=8764
#服务名
spring.application.name=eureka-client-1

#注册到eureka中心，获取到配置服务
eureka.client.service-url.defaultZone=http://eureka-server-peer1:8761/eureka/

#设置实例的ID为ip:port
eureka.instance.instance-id=localhost:${server.port}

# 心跳时间，即服务续约间隔时间（缺省为30s）
eureka.instance.lease-renewal-interval-in-seconds=5

# 发呆时间，即服务续约到期时间（缺省为90s）
eureka.instance.lease-expiration-duration-in-seconds=10

eureka.client.service-url.defaultZone=http://eureka-server-peer1:8761/eureka/ 表示向第一个中注册中心进行注册。

第二个 Eureka Clinet 配置文件：

#端口号
server.port=8765
#服务名
spring.application.name=eureka-client-2

#注册到eureka中心，获取到配置服务
#eureka.client.service-url.defaultZone=http://localhost:8761/eureka/
eureka.client.service-url.defaultZone=http://eureka-server-peer3:8763/eureka/

#设置实例的ID为ip:port
eureka.instance.instance-id=localhost:${server.port}

# 心跳时间，即服务续约间隔时间（缺省为30s）
eureka.instance.lease-renewal-interval-in-seconds=5

# 发呆时间，即服务续约到期时间（缺省为90s）
eureka.instance.lease-expiration-duration-in-seconds=10

eureka.client.service-url.defaultZone=http://eureka-server-peer3:8763/eureka/ 表示向第三个中注册中心进行注册。

而后在 hosts 文件中加入以下信息：

127.0.0.1 eureka-server-peer1
127.0.0.1 eureka-server-peer2
127.0.0.1 eureka-server-peer3

如今运行这 5 个项目，浏览器中输入 ： http://localhost:8761/，以下所示：

有两个服务已经注册上来了：

注册中心的副本有两个，可用的注册中心也有两个：

当咱们把第二个注册中心停掉以后，它就会变为不可用：

当把第二个注册中心停掉以后，它并不会立马变为不可用状态，这是因为Eureka拥有自我保护机制，当其注册表里服务由于网络或其余缘由出现故障而关停时，Eureka不会立马剔除服务注册，而是等待其修复。可是能够经过参数来关闭自我保护：

#为false，关闭自我保护
eureka.server.enable-self-preservation=false
#清理无效节点的时间间隔, 单位毫秒，默认是60*1000
eureka.server.eviction-interval-timer-in-ms=4000

上述除了一些经常使用配置外，Eureka Client 还配置了 

eureka.instance.lease-renewal-interval-in-seconds=5
eureka.instance.lease-expiration-duration-in-seconds=10

eureka.instance.lease-renewal-interval-in-seconds 表示心跳时间，即服务续约间隔时间（缺省为30s）

eureka.instance.lease-expiration-duration-in-seconds 表示发呆时间，即服务续约到期时间（缺省为90s）

心跳时间的意思就是，客户端须要每隔多少时间向注册中心发下心跳来代表本身还活着，这个时间默认是 30 秒。

发呆时间的意思就是，eureka服务器在接受到实例最后一次发出的心跳后，须要等待多久才能够将此实例删除，这个时间默认是 90 秒。

此外，Eureka Client 还能够配置间隔多少时间去 Eureka Server 注册中心拉取注册信息，这个默认时间是 30 秒，经过如下参数进行配置：

eureka.client.registry-fetch-interval-seconds

 

以上就是 Spring Eureka 服务注册于发现的例子。

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程