微服务实战02-EurekaServer注册中心

简介: EurekaServer ,它扮演的角色是注册中心,用于注册各种微服务,以便于其他微服务找到和访问。

1、Eureka是什么

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


Spring Cloud封装了Netflix公司开发的Eureka模块来实现服务注册和发现(请对比Zookeeper)


Eureka采用了C-S的设计架构,包含两个组件:Eureka Server 和 Eureka Client。Eureka Server作为服务注册功能的服务器,它是服务注册中心。各个节点启动后,会在Eureka Server中进行注册,这样Eureka Server中的服务注册表中将会存储所有可用服务节点的信息,服务节点的信息可以在界面中直观的看到。Eureka Client是一个Java客户端,用于简化Eureka Server的交互,客户端同时也具备一个内置的、使用轮询负载算法的负载均衡器。在应用启动后,将会向Eureka Server发送心跳(默认周期为30秒)。如果Eureka Server在多个心跳周期内没有接收到某个节点的心跳。Eureka Server将会从服务注册表中把这个服务节点移除(默认90秒)


而系统中的其他微服务,使用Eureka的客户端连接到Eureka Server并维持心跳连接。这样系统的维护人员就可以通过Eureka Server来监控系统中各个微服务是否正常运行。Spring Cloud的一些其他模块(比如Zuul)就可以通过Eureka Server来发现系统中的其他微服务,并执行相关的逻辑。


2.Eureka和Zookeeper

Zookeeper保证CP(C表示一致性)


当向注册中心查询服务列表时,我们可以容忍注册中心返回的是几分钟以前的注册信息,但不能接受服务直接down掉不可用。也就是说,服务注册功能对可用性的要求要高于一致性。但是zk会出现这样一种情况,当master节点因为网络故障与其他节点失去联系时,剩余节点会重新进行leader选举。问题在于,选举leader的时间太长,30~120s,且选举期间整个zk集群都是不可用的,这就导致在选举期间注册服务瘫痪。在云部署的环境下,因为网络问题使得zk集群失去master节点是较大概率会发生的事情,虽然服务器能最终恢复,但是漫长的选举时间导致的注册长期不可用是不能容忍的。


Eureka保证AP(A表示可用性)


Eureka看明白了这一点,因此在设计时就优先保证可用性。Eureka各个节点都是平等的,几个节点挂掉不会影响正常节点的工作,剩余的节点依然可以提供注册和查询服务。而Eureka的客户端在向某个Eureka注册时如果发现连接失败,则会自动切换至其他节点,只要有一台Eureka还在,就能保证注册服务可用(保证可用性),只不过查到的信息可能不是最新的(不保证强一致性)。除此之外,Eureka还有一种自我保护机制,如果在15分钟内超过85%的节点都没有正常的心跳,那么Eureka就认为客户端与注册中心出现了网络故障,此时会出现以下几种情况:


(1)Eureka不再从注册列表中移除因为长时间没收到心跳而应该过期的服务


(2)Eureka依然能接受新服务的注册和查询请求,但是不会被同步到其他节点上(即保证当前节点依然可用)


(3)当网络稳定时,当前实例新的注册信息会被同步到其他节点中


因此,Eureka可以很好的应对因网络故障导致部分节点失去联系的情况,而不会像Zookeeper那样使整个注册服务瘫痪。


2.快速入门

我们将对上一节的项目进行改造,引入Eureka注册中心。


直观的感受就是,加一个模块Eureka服务器,独立运行起来,作为所谓的注册中心。


2.1 父项目改造

我们首先要对父项目改造,先删掉src目录,因为父项目是一个pom工程,没有代码,自然也就不需要src了

33.png

pom.xml增加对springbootd的依赖

<parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.3.RELEASE</version>
        <relativePath/>
    </parent>

设置一些依赖的编号,用properties节点,其中包含了spring-cloud的版本,我们选用Finchley.RELEASE

<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.RELEASE</spring-cloud.version>
    </properties>

增加一个依赖,用来测试:

<dependency>
       <groupId>org.springframework.boot</groupId>
       <artifactId>spring-boot-starter-test</artifactId>
       <scope>test</scope>
</dependency>

设置给子模块继承的依赖。

<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>

<scope>import</scope>的意思是把父项目spring-cloud-dependencies里面的dependencyManagement导入(import)到本项目(parent)中,这种写法就不需要继承spring-cloud-dependencies了,因为本项目依据继承了spring-boot-starter-parent项目了,不能多继承吗,所以采用这种方式。


我们可以通过这种方式来实现版本号的统一。


通常工程比较庞大,模块多的时候,在pom.xml文件中,也就是父依赖中会看到dependencyManagement标签。这个标签的作用是:


①对项目所依赖jar包进行版本管理的管理器。


②使用pom.xml中的dependencyManagement元索能让所有在子模块中引用一个依赖而不用显式的列出版本号。也就是子模块不需要列出版本,子模块中的pom依赖会找到dependencyManagement所在jar包的版本,并引用这个jar对应的版本号。


③让子模块不在受繁杂的版本影响,和父pom中的依赖一致。


2.2 创建子项目eureka-server

34.png

项目 pom.xml ,增加 spring-cloud-starter-netflix-eureka-server jar 包

<dependencies>
      <dependency>
          <groupId>org.springframework.cloud</groupId>
          <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
      </dependency>
  </dependencies>

引入了spring-cloud-starter-netflix-eureka-server这个jar,但是我们没写版本号,这是因为parent项目导入了spring-cloud-dependencies里面的dependencyManagement。


spring-cloud-dependencies里面的dependencyManagement中又有一个spring-cloud-netflix-dependencies。


<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-netflix-dependencies</artifactId>
    <version>${spring-cloud-netflix.version}</version>
    <type>pom</type>
    <scope>import</scope>
   </dependency>

spring-cloud-netflix-dependencies中就有spring-cloud-starter-netflix-eureka-server这个依赖。

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
    <version>${project.version}</version>
   </dependency>

所以,当你不写版本号的话,这个版本肯定是在某个父项目中定义了。

子项目eureka-server的pom文件中,我们只需要增加 spring-cloud-starter-netflix-eureka-server jar 包即可。

2.3 EurekaServerApplication启动类


因为eureka-server本身就是一个SpringBoot项目,所以我们还是要写个启动类的,灯塔跑起来就可以注册服务了。


我们要启动服务,那么就需要加一个@SpringBootApplication,而@EnableEurekaServer 表示这是个 EurekaServer ,即注册中心。

public static void main(String[] args) {
 //8081 这个端口是默认的,就不要修改了,后面的子项目,都会访问这个端口。
 //不要写在yml文件里了,端口号可以直接在这里写死
    int port = 8081;
    //判断端口是否被占用
    if(!NetUtil.isUsableLocalPort(port)) {
        System.err.printf("端口%d被占用了,无法启动%n", port );
        System.exit(1);
    }
    //启动的时候配置端口号
    new SpringApplicationBuilder(EurekaServerApplication.class).
                properties("server.port=" + port)
                 .run(args);
}


2.4 EurekaServer配置文件

虽然我们把端口号写死在了代码中,但是这并不代表我们不需要写配置文件哈。

35.png


新建这样一个文件,内容如下:

eureka:
  instance:
    hostname: localhost
  client:
    registerWithEureka: false
    fetchRegistry: false
    serviceUrl:
      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
spring:
  application:
    name: eureka-server

hostname代表主机名称,因为我们是本地起服务,那么就是localhost。


registerWithEureka代表是否注册到服务器,EurekaServer本身就是服务器,自然是false。


fetchRegistry表示是否获取服务器的注册信息,EurekaServer本身就是服务器,自然是false。


defaultZone表示EurekaServer自己作为服务器,公布出来的地址。EurekaServer是注册中心,其他微服务要注册就需要知道往哪里注册,defaultZone就是干这个事情的。{server.port}虽然没有在yml文件中写明,但是启动的时候我们会带上,就是8081。所以地址就是http://localhost:8081/eureka/


启动EurekaServerApplication,访问http://localhost:8081/,注意,不是访问http://localhost:8081/eureka/,这个是公布出去的地址,不是EurekaServer本身的网页地址。


36.png


看到这个页面就成功了。


这就是注册中心的管理界面,主要看 :Instances currently registered with Eureka, 可以发现信息是:No instances available。


这表示,暂时还没有微服务注册进来。


下一节,我们就会讲解如何注册微服务进来啦。


相关文章
|
4月前
|
监控 Java API
Spring Boot 3.2 结合 Spring Cloud 微服务架构实操指南 现代分布式应用系统构建实战教程
Spring Boot 3.2 + Spring Cloud 2023.0 微服务架构实践摘要 本文基于Spring Boot 3.2.5和Spring Cloud 2023.0.1最新稳定版本,演示现代微服务架构的构建过程。主要内容包括: 技术栈选择:采用Spring Cloud Netflix Eureka 4.1.0作为服务注册中心,Resilience4j 2.1.0替代Hystrix实现熔断机制,配合OpenFeign和Gateway等组件。 核心实操步骤: 搭建Eureka注册中心服务 构建商品
826 3
|
2月前
|
Cloud Native Serverless API
微服务架构实战指南:从单体应用到云原生的蜕变之路
🌟蒋星熠Jaxonic,代码为舟的星际旅人。深耕微服务架构,擅以DDD拆分服务、构建高可用通信与治理体系。分享从单体到云原生的实战经验,探索技术演进的无限可能。
微服务架构实战指南:从单体应用到云原生的蜕变之路
|
2月前
|
监控 Cloud Native Java
Spring Boot 3.x 微服务架构实战指南
🌟蒋星熠Jaxonic,技术宇宙中的星际旅人。深耕Spring Boot 3.x与微服务架构,探索云原生、性能优化与高可用系统设计。以代码为笔,在二进制星河中谱写极客诗篇。关注我,共赴技术星辰大海!(238字)
Spring Boot 3.x 微服务架构实战指南
|
6月前
|
缓存 负载均衡 监控
微服务架构下的电商API接口设计:策略、方法与实战案例
本文探讨了微服务架构下的电商API接口设计,旨在打造高效、灵活与可扩展的电商系统。通过服务拆分(如商品、订单、支付等模块)和标准化设计(RESTful或GraphQL风格),确保接口一致性与易用性。同时,采用缓存策略、负载均衡及限流技术优化性能,并借助Prometheus等工具实现监控与日志管理。微服务架构的优势在于支持敏捷开发、高并发处理和独立部署,满足电商业务快速迭代需求。未来,电商API设计将向智能化与安全化方向发展。
450 102
|
4月前
|
负载均衡 监控 Java
微服务稳定性三板斧:熔断、限流与负载均衡全面解析(附 Hystrix-Go 实战代码)
在微服务架构中,高可用与稳定性至关重要。本文详解熔断、限流与负载均衡三大关键技术,结合API网关与Hystrix-Go实战,帮助构建健壮、弹性的微服务系统。
543 1
微服务稳定性三板斧:熔断、限流与负载均衡全面解析(附 Hystrix-Go 实战代码)
|
设计模式 Java API
微服务架构演变与架构设计深度解析
【11月更文挑战第14天】在当今的IT行业中,微服务架构已经成为构建大型、复杂系统的重要范式。本文将从微服务架构的背景、业务场景、功能点、底层原理、实战、设计模式等多个方面进行深度解析,并结合京东电商的案例,探讨微服务架构在实际应用中的实施与效果。
690 6
|
设计模式 Java API
微服务架构演变与架构设计深度解析
【11月更文挑战第14天】在当今的IT行业中,微服务架构已经成为构建大型、复杂系统的重要范式。本文将从微服务架构的背景、业务场景、功能点、底层原理、实战、设计模式等多个方面进行深度解析,并结合京东电商的案例,探讨微服务架构在实际应用中的实施与效果。
332 1
|
安全 应用服务中间件 API
微服务分布式系统架构之zookeeper与dubbo-2
微服务分布式系统架构之zookeeper与dubbo-2
|
负载均衡 Java 应用服务中间件
微服务分布式系统架构之zookeeper与dubbor-1
微服务分布式系统架构之zookeeper与dubbor-1
|
Java 开发者 微服务
从单体到微服务:如何借助 Spring Cloud 实现架构转型
**Spring Cloud** 是一套基于 Spring 框架的**微服务架构解决方案**,它提供了一系列的工具和组件,帮助开发者快速构建分布式系统,尤其是微服务架构。
1058 69
从单体到微服务:如何借助 Spring Cloud 实现架构转型

热门文章

最新文章