专栏首页Java技术大杂烩Spring Eureka 初探及集群搭建

Spring Eureka 初探及集群搭建

本文首发于个人公众号 Java 技术大杂烩,欢迎关注

前言

Eureka 主要是用于进行服务的注册和发现,今天就来学习一下如何使用 Eureka

关于 Eureka的更多信息可以参考 Netflix / eureka (https://github.com/Netflix/eureka/wiki/Building-Eureka-Client-and-Server) 和 Spring-Eureka (https://spring.io/guides/gs/service-registration-and-discovery/)

Eureka 的主要架构图如下所示:

Eureka 主要有三种角色,Eureka Server, Eureka Client,其中 Eureka Client 包括 Service ProviderService Consumer

  1. Eureka Server :注册中心,提供服务注册和发现,注册中心可以搭建成集群模式来实现服务的高可用
  2. Service Provider :服务提供方,将自身服务注册到Eureka,从而使服务消费方能够找到
  3. Service Consumer:服务消费方,从Eureka获取注册服务列表,从而能够消费服务

例子

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

官方文档: https://spring.io/guides/gs/service-registration-and-discovery/

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-eurekaeureka.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 注册中心,代码和上面的一样,只不过配置文件有所不同

  1. 第一个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-eurekaeureka.client.fetch-registry 设为 true,然后,eureka.client.serviceUrl.defaultZone 指向其他两个注册中心的地址。

  1. 第二个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
  1. 第三个 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-peer1eureka-server-peer3 进行注册,

  1. 第一个 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/ 表示向第一个中注册中心进行注册。

  1. 第二个 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 服务注册于发现的例子。

本文分享自微信公众号 - Java技术大杂烩(tsmyk0715),作者:TSMYK

原文出处及转载信息见文内详细说明,如有侵权,请联系 yunjia_community@tencent.com 删除。

原始发表时间:2019-07-02

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • Redis 初探-安装与使用

    Redis是一个使用ANSI C编写的开源、支持网络、基于内存、可选持久性的键值对存储数据库。从2015年6月开始,Redis的开发由Redis Labs赞助,...

    Java技术大杂烩
  • Spring 事务提交回滚源码解析

    在上篇文章 Spring 事务初始化源码分析 中分析了 Spring 事务初始化的一个过程,当初始化完成后,Spring 是如何去获取事务,当目标方法异常后,...

    Java技术大杂烩
  • Mybatis 类型转换源码分析

    JDBC 提供的数据类型和Java的数据类型并不是完全对应的,当 Mybatis 在解析 SQL ,使用 PreparedStatement 来为 SQL 设置...

    Java技术大杂烩
  • SpringCloud教程(Finchley版本)-08:eureka集群搭建

    在eureka的服务治理设计中,所有的节点既是服务提供方,也是服务消费方,注册中心也不例外。eureka server的高可用集群,其实就是将自己作为服务向其他...

    IT云清
  • Spring Cloud Eureka:服务注册与发现

    在微服务架构中往往会有一个注册中心,每个微服务都会向注册中心去注册自己的地址及端口信息,注册中心维护着服务名称与服务实例的对应关系。每个微服务都会定时从注册中心...

    macrozheng
  • eureka配置账号密码才能访问

    如果配置好了eureka server,默认情况下我们就直接直接访问到eureka的界面了。如果不想让所有人都能访问到eureka的界面,可以加上权限认证,输入...

    天涯泪小武
  • 原创 | Eureka搭建分布式SpringCloud项目

    Spring Cloud是一系列框架的有序集合。它利用Spring Boot的开发便利性巧妙地简化了分布式系统基础设施的开发,如服务发现注册、配置中心、消息总线...

    润森
  • Istio 运维实战系列(3):让人头大的『无头服务』-下

    作者赵化冰,腾讯云高级工程师,Istio contributor,ServiceMesher管理委员,热衷于开源、网络和云计算。目前主要从事服务网格的开源和研...

    腾讯云原生
  • Spring Cloud系列勘误

    Spring Cloud系列已经写完了,这是一系列的学习笔记,由于写作匆忙,难免会有出错的文字或者代码,实在抱歉。 目前作者已经发现了几处有错误的地方,为了小伙...

    江南一点雨
  • Spring cloud系列教程第五篇-Eureka单机版配置

    在上一篇我们对eurek做了介绍。知道了eureka两个组件:服务端和客户端。本篇咱们就来做单机版的配置。

    凯哥Java

扫码关注云+社区

领取腾讯云代金券