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

news2025/1/13 17:39:50

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了

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

项目 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配置文件

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

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

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本身的网页地址。

看到这个页面就成功了。

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

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

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

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/379383.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

AUTOSAR为啥要开发新的社区商业模式?

总目录链接>> AutoSAR入门和实战系列总目录 文章目录1 自适应平台架构中的集群更新1.1 ara::diag 服务&#xff08;诊断&#xff09;更新1.2 信号到服务映射和自动驾驶接口让我们讨论一下信号到服务映射服务:Automated Driving Interface:2 车载应用商店概念本文介绍Re…

【RabbitMQ笔记09】消息队列RabbitMQ之常见方法的使用

这篇文章&#xff0c;主要介绍消息队列RabbitMQ之常见方法的使用。 目录 一、消息队列常见方法 1.1、连接工厂ConnectionFactory 1.2、连接Connection 1.3、通道Channel 1.4、交换机相关方法 &#xff08;1&#xff09;exchangeDeclare()声明交换机 1.5、队列相关方法 …

算法训练营 day58 动态规划 判断子序列 不同的子序列

算法训练营 day58 动态规划 判断子序列 不同的子序列 判断子序列 392. 判断子序列 - 力扣&#xff08;LeetCode&#xff09; 给定字符串 s 和 t &#xff0c;判断 s 是否为 t 的子序列。 字符串的一个子序列是原始字符串删除一些&#xff08;也可以不删除&#xff09;字符而…

03、SVN 建立版本库

SVN 建立版本库1 版本库2 版本库的建立步骤2.1 创建版本库的根目录2.2 创建子目录2.3 通过命令创建版本库2.4 生成目的介绍1 版本库 Subversion 是将文件数据信息保存到版本库中进行管理的Subversion 允许用户对版本库目录进行定制 2 版本库的建立步骤 2.1 创建版本库的根目…

引用数据类型和基本数据类型

1.基本数据类型&#xff1a; byte&#xff1a;字节类型&#xff0c;Java中最小的数据类型&#xff0c;1个字节&#xff0c;取值范围-128~127&#xff0c;默认值0 char&#xff1a;字符型&#xff0c;用于存储单个字符&#xff0c;2个字节&#xff0c;取值范围0~65535&#xf…

Redis使用,AOF、RDB

前言 如果有人问你&#xff1a;"你会把 Redis 用在什么业务场景下&#xff1f;" 我想你大概率会说&#xff1a;"我会把它当作缓存使用&#xff0c;因为它把后端数据库中的数据存储在内存中&#xff0c;然后直接从内存中读取数据&#xff0c;响应速度会非常快。…

“速通“ 老生常谈的HashMap [实现原理源码解读]

&#x1f473;我亲爱的各位大佬们好&#x1f618;&#x1f618;&#x1f618; ♨️本篇文章记录的为 HashMap 实现原理&&源码解读 相关内容&#xff0c;适合在学Java的小白,帮助新手快速上手,也适合复习中&#xff0c;面试中的大佬&#x1f649;&#x1f649;&#x1f…

RocketMQ动态增加NameServer

前言 通过HTTP服务来设置NameServer地址&#xff0c;是唯一支持动态增加NameServer的方式&#xff0c;无需重启其它组件 网上搜了下没看到有兄弟们演示这块&#xff0c;所以刚才自己试了试&#xff0c;做个笔记 本文有详细的演示过程 都知道NameServer有4种配置方式&#xff0…

simulink入门指南

系列文章目录 文章目录系列文章目录常用操作技巧项目练习 - 动态系统二阶系统建模比例积分控制燕子俯冲系统建模滤波位操作总结常用操作技巧 画面缩放 空格键 鼠标左键: 拖拽空格键: fit屏幕 信号操作 双击signal可添加标签, 鼠标右键拖拽可给信号添加分支同一分支上的sig…

【并发基础】线程,进程,协程的详细解释

目录 一、什么是进程和线程 1.1 进程是什么呢&#xff1f; 1.2 线程又是什么呢&#xff1f; 1.3 线程和进程之间的关系 操作系统、进程、线程之间的关系图&#xff1a; 进程与线程的模型图&#xff1a; 下面来思考这样一个问题&#xff1a;为什么程序计数器、虚拟机栈和本地方法…

QNX7.1 交叉编译开源库

1.下载QNX7.1 SDK并解压 ITL:~/work/tiqnx710$ ls -l 总用量 16 drwxrwxr-x 4 xxx4096 1月 28 13:38 host -rwxrwxr-x 1 xxx 972 1月 28 13:38 qnxsdp-env.bat -rwxrwxr-x 1 xxx 1676 1月 28 13:38 qnxsdp-env.sh drwxrwxr-x 3 xxx 4096 1月 28 13:38 target xxxITL:~/work/ti…

NetApp SnapCenter 备份管理 ——借助应用程序一致的数据备份管理,简化混合云操作

NetApp SnapCenter 简单、可扩展、赋权&#xff1a;跨 Data Fabric 的企业级数据保护和克隆管理 主要优势 • 利用与应用程序集成的工作流和预定义策略简化备份、恢复和克隆管理。 • 借助基于存储的数据管理功能提高性能和可用性&#xff0c;并缩短测试和开发用时。 • 提供基…

干货 | 浅谈机器人强化学习--从仿真到真机迁移

“对于机器人的运动控制&#xff0c;强化学习是广受关注的方法。本期技术干货&#xff0c;我们邀请到了小米工程师——刘天林&#xff0c;为大家介绍机器人&#xff08;以足式机器人为主&#xff09;强化学习中的sim-to-real问题及一些主流方法。”一、前言设计并制造可以灵活运…

【靶机】vulnhub靶机cybox1

Vulnhub靶机Cybox下载地址 Cybox: 1.1 ~ VulnHub 信息搜集 首先进行靶机ip的发现。 sudo arp-scan -l 接着使用nmap扫描开放的端口&#xff0c;这里使用扫描全部端口和详细信息太慢了&#xff0c;分开检测 命令&#xff1a;nmap -p 21,25,80,110,143,443 -sV -A 192.168.174…

CentOS救援模式(Rescue Mode)及紧急模式(Emergency Mode)

当CentOS操作系统崩溃&#xff0c;无法正常启动时&#xff0c;可以通过救援模式或者紧急模式进行系统登录。启动CentOS, 当出现下面界面时&#xff0c;按e进入编辑界面。在编辑界面里&#xff0c;加入参数&#xff1a;systemd.unitrescue.target &#xff0c;然后Ctrl-X启动进入…

Linux服务器上传文件到阿里云oss对象存储的两种方法ossutil、curl

ossutil支持在Windows、Linux、macOS等系统中运行&#xff0c;您可以根据实际环境下载和安装合适的版本。安装过程中&#xff0c;需要使用解压工具&#xff08;unzip、7z&#xff09;解压软件包&#xff0c;请提前安装其中的一个解压工具。yum -y install unzipLinux系统一键安…

正点原子第一期

ZYNQ是一个fpga用来硬件编程&#xff0c;外加一个软件编程 FPGA是可通过编程来修改其逻辑功能的数字集成电路 第三篇语法篇 第七章 verilog HDL语法 Verilog的简介 可编程逻辑电路&#xff1a;允许用户自行修改内部连接的集成电路&#xff0c;其内部的电路结构可以通过编程数…

ADAS-CIS相机关键参数综述

引言 “ CIS传感器关键参数是工程师选型参考的依据&#xff0c;抛开镜头&#xff0c;本文介绍CIS可见光传感器关键参数之CRA、QE、CFA、Shutter、SNR等。” 关键参数 CRA CFA(Chief Ray Angle)主光角&#xff0c;在上一篇可见光相机的介绍中我们介绍了Sensor的叠层结构&am…

leecode+剑指offer

1.算法入门14天 1.704二分查找&#xff1a; 题目描述&#xff1a;给定一个 n 个元素有序的&#xff08;升序&#xff09;整型数组 nums 和一个目标值 target &#xff0c;写一个函数搜索 nums 中的 target&#xff0c;如果目标值存在返回下标&#xff0c;否则返回 -1。 思路…

Matlab进阶绘图第3期—方块热图

方块热图是一种特殊的热图&#xff08;Heatmap&#xff09;。 与传统热图相比&#xff0c;方块热图通过不同颜色、不同大小的正方形以表示数据/特征的大小&#xff0c;能够更加直观地对数据分布情况进行分析&#xff0c;也因此可以在一些顶级期刊中看到它的身影&#xff0c;比…