Spring Cloud Eureka是Spring Cloud Netflix微服务中的一部分,它基于NetFlix Sureka做了二次封装,主要负责完成微服务架构中的服务治理功能。
服务治理是微服务架构中最为核心和基础的模块。它主要用来实现各个微服务实例的自动化注册与发现。
为了解决微服务架构中的服务实例维护问题,产生了大量的服务治理框架和产品,这下框架和产品的实现都围绕着服务注册与服务发现机制来完成对微服务应用实例的自动化管理。
在服务治理框架中,通常都会构建一个注册中心,每个服务单元向注册中心登记自己提供的服务,将主机与端口号、版本号、通信协议等一些附加信息告知注册中心,注册中心按服务名分类组织服务清单。比如,我们有两个提供服务A的进程分别用于192.168.0.100:8080和192.168.1.101:8080位置上,另外还有三个提供服务B的进程分别运行于192.168.0.100:9090、192.168.0.101:9090、192.168.0.102:9090位置上,当这些线程均启动、并向注册中心注册自己的服务之后,注册中会就会维护类型如下非服务清单。另外,服务注册中心还需要以心跳的方式去监测清单中的服务是否可用,若不可用需要从服务清单中剔除,达到排除故障服务的效果。
由于在服务治理框架下运作,服务间的调用不再需要通过指定具体的实例地址来实现,而是通过向服务名发起请求调用实现,所以,服务调用方在调用服务提供方的时候,并不知道具体的服务实例位置。因此,调用方需要向服务注册中心咨询服务,并获取所有服务的实例清单,以实现对具体服务实例的访问。比如:现有服务C希望调用服务A,服务C就需要向注册中心发起咨询服务请求,服务注册中心就会将服务A的位置清单返回给服务C,如按上例服务A的情况。服务C便获得了服务A的两个可用位置192.168.0.100:8080和192.168.1.101:8080。当服务C要发起调用的时候便从该清单中以某种轮询策略取出一个位置来进行服务调用,这就是后续我们将要介绍的负载均衡,
Spring Cloud Eureka,使用Netflix Eureka来实现服务注册与发现,它既包含 服务端组件,也包含了客户端组件,并且服务端与客户端组件均采用java编写,所以Eureka主要使用于通过java实现的分布式系统,或是与JVM兼容语言构建的系统,但是由于Eureka服务端的服务治理机制提供了完备的RESTful API,所以它也支持非java语言构建的微服务应用纳入Eureka的服务治理体系中来,只是在使用其他语言平台的时候需要租户来实现Eureka的客户端程序。
Eureka服务端,我们也称为服务注册中心,它通其他服务注册中心一样,支持高可用配置。它依托于强一致性提供良好的服务实例可用性,可以应对多种不同的故障场景。如果Eureka以集群模式部署,当集群中有分片出现故障时,那么Eureka就转入自我保护模式,它允许在分片故障期间继续提供服务的发行和注册,当故障分片回复运行时,集群中的其他分片会把他们的状态再次同步回来。以在AWS上的实践为例,Netflix推荐每个可用的区域运营一个Eureka服务端,通过它来形成集群。不同可用区域的服务注册中心通过异步模式互相复制格子的状态,这意味着在任何给定的时间点每个实例关于所有服务的状态是有细微差别的。
Eureka客户端。主要处理服务的注册与发现。客户端服务通过注册和参数配置的方式,嵌入在客户端应用程序的代码中,在应用程序运行时,Eureka客户端向注册中心注册自身提供的服务并周期性的发生心跳来更新它的服务租约。同时,它也能从服务端查询当前注册的服务消息并把他们缓存到本地并周期性的刷新服务状态。
1 "1.0" encoding="UTF-8"?> 2"http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 3 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> 4 4.0.0 5 6com.slp 7eureka-server 80.0.1-SNAPSHOT 9jar 10 11eureka-server 12Demo project for Spring Boot 13 1415 20 21org.springframework.boot 16spring-boot-starter-parent 171.3.7.RELEASE 1819 22 26 27UTF-8 23UTF-8 241.8 2528 48 4929 32org.springframework.boot 30spring-boot-starter 3133 36org.springframework.boot 34spring-boot-starter-web 3537 41 42org.springframework.boot 38spring-boot-starter-test 39test 4043 46 47org.springframework.cloud 44spring-cloud-starter-eureka-server 4550 57 5851 5652 55org.springframework.boot 53spring-boot-maven-plugin 5459 76 7760 67spring-snapshots 61Spring Snapshots 62https://repo.spring.io/snapshot 6364 66true 6568 75spring-milestones 69Spring Milestones 70https://repo.spring.io/milestone 7172 74false 7378 95 9679 86spring-snapshots 80Spring Snapshots 81https://repo.spring.io/snapshot 8283 85true 8487 94spring-milestones 88Spring Milestones 89https://repo.spring.io/milestone 9091 93false 9297 98 10999 100 108101 107org.springframework.cloud 102spring-cloud-dependencies 103Brixton.SR5 104pom 105import 106
1 package com.slp.eurekaserver; 2 3 import org.springframework.boot.SpringApplication; 4 import org.springframework.boot.autoconfigure.SpringBootApplication; 5 import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer; 6 7 /** 8 * 通过@EnableEurekaServer注解启动一个服务注册中心提供给其他应用进行注册 9 */ 10 @EnableEurekaServer 11 @SpringBootApplication 12 public class EurekaServerApplication { 13 14 public static void main(String[] args) { 15 SpringApplication.run(EurekaServerApplication.class, args); 16 } 17 }
application.properties
server.port=1111 eureka.instance.hostname=localhost eureka.client.register-with-eureka=false eureka.client.fetch-registry=false eureka.client.serviceUrl.defaultZone=http://${eureka.instance.hostname}:${server.port}/eureka/
eureka.client.register-with-eureka:设置为false表示不向注册中心注册自己
eureka.client.fetch-registry:注册中的职责是维护服务实例,它不需要去检索服务,所以设置为false
现在Instance currently registed with Eureka还是空的,说明目前该注册中心还没有注册任何服务。
在完成上述的服务中心注册之后,我们尝试加入之前的项目到服务治理体系中去。
1 "1.0" encoding="UTF-8"?> 2"http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 3 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> 4 4.0.0 5 6com.slp 7springBoot 80.0.1-SNAPSHOT 9jar 10 11springBoot 12Demo project for Spring Boot 13 1415 16 21 22org.springframework.boot 17spring-boot-starter-parent 181.3.7.RELEASE 1920 23 27 28UTF-8 24UTF-8 251.8 2629 52 5330 31 34 35org.springframework.boot 32spring-boot-starter-web 3336 37 41org.springframework.boot 38spring-boot-starter-test 39test 4042 43 46 47org.springframework.boot 44spring-boot-starter-actuator 4548 51org.springframework.cloud 49spring-cloud-starter-eureka 5054 55 6656 57 6558 64org.springframework.cloud 59spring-cloud-dependencies 60Brixton.SR5 61pom 62import 6367 74 75 7668 7369 72org.springframework.boot 70spring-boot-maven-plugin 71
package com.slp.web; import com.slp.service.UserService; import org.apache.log4j.Logger; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.cloud.client.ServiceInstance; import org.springframework.cloud.client.discovery.DiscoveryClient; import org.springframework.stereotype.Controller; import org.springframework.ui.ModelMap; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; /** * @author sanglp * @create 2018-06-28 8:39 * @desc 第一个 controller **/ @Controller public class HelloController { private final Logger logger = Logger.getLogger(getClass()); @Autowired private DiscoveryClient client; @RequestMapping(value = "helloindex",method = RequestMethod.GET) public String helloindex(ModelMap map){ ServiceInstance instance = client.getLocalServiceInstance(); logger.info("/hello ,host:"+instance.getHost()+", service_id:"+instance.getServiceId()); return "helloindex"; } }
package com.slp; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.client.discovery.EnableDiscoveryClient; /** * 在主类中通过加上@EnableDiscoveryClient注解,激活Eureka中的DiscoveryClient实现(自动化配置,创建DiscoveryClient接口针对Eureka客户端的EurekaDiscoveryClient实例) */ @EnableDiscoveryClient @SpringBootApplication public class Application { public static void main(String[] args) { //jar包包含Tomcat SpringApplication.run(Application.class, args); } }
1 spring.application.name=hello-service 2 eureka.client.serviceUrl.defaultZOne=http://localhost:1111/eureka/
注册提供者控制台:
1 2018-07-10 09:11:29.163 INFO 17484 --- [nfoReplicator-0] com.netflix.discovery.DiscoveryClient : DiscoveryClient_HELLO-SERVICE/windows10.microdone.cn:hello-service - registration status: 204
注册中心控制台:
1 2018-07-10 09:11:29.154 INFO 18928 --- [io-1111-exec-10] c.n.e.registry.AbstractInstanceRegistry : Registered instance HELLO-SERVICE/windows10.microdone.cn:hello-service with status UP (replication=false)