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。
————————————————
版权声明:本文为CSDN博主「剽悍一小兔」的原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接及本声明。
原文链接:https://blog.csdn.net/weixin_39570751/article/details/129276432
<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。
这表示,暂时还没有微服务注册进来。
下一节,我们就会讲解如何注册微服务进来啦。