1、是什么
Eureka是Netflix的一个子模块,也是核心模块之一。Eureka是一个基于 REST 服务,用于定位服劳,以实现云端中间层服务发现和故障转移。服务注册与发现对于微服务架构来说是非常重要的,有了服务发现与注册,只需要使用服务的标识符,就可以访问到服务,而不需要修改服务调用的配置文件了。功能类似于dubbo的注册中心,比如 Zookeeper。
Netflix在设计Eureka是遵循的就是AP原则
分布式系统的CAP理论:理论首先把分布式系统中的三个特性进行了如下归纳:
● 一致性(C):在分布式系统中的所有数据备份,在同一时刻是否同样的值。(等同于所有节点访问同一份最新的数据副本)
● 可用性(A):在集群中一部分节点故障后,集群整体是否还能响应客户端的读写请求。(对数据更新具备高可用性)
● 分区容错性(P):以实际效果而言,分区相当于对通信的时限要求。系统如果不能在时限内达成数据一致性,就意味着发生了分区的情况,必须就当前操作在C和A之间做出选择。
CAP原则只能三选二
最多只能同时较好的满足两个。
CAP 理论的核心足:一个分布式系统不可能同时很好的满足一致性,可用性和分区容错性这止个需求,因此,根据 CAP 原理将 NOSQL 数据库分成了满足 CA 原则、满足 CP 原则和满足 AP 原则三大类:
CA 单点集群,满足一致性,可川性的系统,通常在可扩展性上不太强大。
CP 满足一致性,分区容忍必的系统,通常性能不是特别高。
AP 满足可用统,通常可能对一致性要求低一些。
Eureka遵守AP 原则
zookeeper遵守CP原则
双11、618只能用AP
2、原理讲解
2.1、Rureka的基本架构
SpringCloud 封装了 Netflix 公司开发的 Eureka 模块来实现服务注册和发现(请对比 Zookeeper )。
Eureka 采用了C-S的设计架构。Eureka Server 作为服务注册功能的服务器,它是服务注册中心。
而系统中的其他微服务,使用 Eureka 的客户端连接到Eureka Server并维持心路连接。这样系统的维护人员就可以通过 Eureka Server来监控系统中各个微服务是否正常运行。SpringCloud 的一些其他模块(比如Zuul)就可以通过 Eureka Server来发现系统中的其他微服务,并执行相关的逻辑。
Eureka包含两个组件: Eureka Server 和 Eureka Client
Eureka Server 提供服务注册服务:各个节点启动后,会在Eureka Server中进行注册,这样 Eureka Server中的服务注册表中将会存储所有可用服务节点的信息,服务节点的信息可以在界面中直观的看到。
EurekaClient 是一个Java客户端,用于简化Eureka Server的交互,客户端同时也具备一个内置的、使用轮询(round-robin)法的负载均衡器。在应用启动后,将会向 Eureka Server 发送心跳(默认周期为 30 秒)。如果 Eureka Server在多个心跳周期内没有接收到某个节点的心跳,Eureka Server 将会从服务注册表中把这个服务节点移除(默认 90 秒)。
2.2、三大角色
Eureka Server提供服务注册和发现
Server Provider服务提供方将自身服务注册到Eureka,从而使服务消费方能够找到Server Provider服务提供方将自身服务注册到Eureka,从而使服务消费方能够找到
Server Consumer 服务消费方从Eureka获取注册服务列表,从而能够消费服务Server Consumer 服务消费方从Eureka获取注册服务列表,从而能够消费服务
2.3、现在搭建的工程情况
|- 父工程
|- 通用模块api
|- 服务提供者Peovider - 8001
|- 服务消费者Consumer - 80
3、构建步骤
3.1、新建一个工程 microservicecloud-eureka-7001
pom.xml
<?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"> <parent> <artifactId>microservicecloud</artifactId> <groupId>cn.hfbin.springcloud</groupId> <version>0.0.1-SNAPSHOT</version> </parent> <modelVersion>4.0.0</modelVersion> <artifactId>microservicecloud-eureka-7001</artifactId> <dependencies> <!--eureka-server服务端 --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-eureka-server</artifactId> </dependency> <!-- 修改后立即生效,热部署 --> <dependency> <groupId>org.springframework</groupId> <artifactId>springloaded</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-devtools</artifactId> </dependency> </dependencies> </project>
application.yml
server: port: 7001 eureka: instance: hostname: eureka7001.com #eureka服务端的实例名称 client: register-with-eureka: false #false表示不向注册中心注册自己。 fetch-registry: false #false表示自己端就是注册中心,我的职责就是维护服务实例,并不需要去检索服务 service-url: #单机 defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/ #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址(单机)。 defaultZone: http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/
3.2 、编写主启动类 EurekaServer7001_App
@SpringBootApplication @EnableEurekaServer public class EurekaServer7001_App { public static void main(String[] args) { SpringApplication.run(EurekaServer7001_App.class, args); } }
3.3、测试
启动应用程序,在浏览器输入http://localhost:7001/ ,看到下面页面说明
3.4、将microservicecloud-provider-dept-8001入驻到Euerka中
在 microservicecloud-provider-dept-8001 中pom.xml加入
<!-- 将微服务provider侧注册进eureka --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-eureka</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-config</artifactId> </dependency>
application.yml加入
eureka: client: #客户端注册进eureka服务列表内 service-url: defaultZone: http://localhost:7001/eureka
在启动类加入注解 @EnableEurekaClient
3.5、入驻到Euerka中测试
1、先启动 Euerka-Server
2、再启动 microservicecloud-provider-dept-8001
3、在浏览器中打开http://localhost:7001
当启动时间久了Euerka界面会提示一串红色内容
这个是Euerka的自我保护!!!不是报错
3.6、actuator与注册微服务信息完善
1)主机名称:服务名称修改
默认:
在microservicecloud-provider-dept-8001 YML中加入
eureka: instance: instance-id: microservicecloud-dept8001
修改后,查看页面:
2)访问信息有IP信息提示
在microservicecloud-provider-dept-8001 YML中加入
eureka: instance: prefer-ip-address: true #访问路径可以显示IP地址
修改后,查看页面:
3)微服务info内容详情
默认:
POM中加入
<!-- actuator监控信息完善 --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-actuator</artifactId> </dependency>
父工程POM
<build> <finalName>microservicecloud</finalName> <resources> <resource> <!----> <directory>src/main/resources</directory> <filtering>true</filtering> </resource> </resources> <plugins> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-resources-plugin</artifactId> <configuration> <delimiters> <delimit>$</delimit> </delimiters> </configuration> </plugin> </plugins> </build>
YML
info: app.name: hfbin-microservicecloud company.name: www.hfbin.cn build.artifactId: $project.artifactId$ build.version: $project.version$
3.7、 Eureka的自我保护
一句话:某时刻某一个微服务不可用了,Eureka不会立即清理,依旧会对微服务的信息进行保护。
导致原因:
3.8、microservicecloud-provider-dept-8001服务发现Discovery
1、对于注册进Euerka里面的微服务,可以通过服务发现来获得该服务的信息。
2、在microservicecloud-provider-dept-8001的DeptController.java中加入下面内容:
@Autowired private DiscoveryClient client; @RequestMapping(value = "/dept/discovery", method = RequestMethod.GET) public Object discovery() { List<String> list = client.getServices(); System.out.println("**********" + list); List<ServiceInstance> srvList = client.getInstances("MICROSERVICECLOUD-DEPT"); for (ServiceInstance element : srvList) { System.out.println(element.getServiceId() + "\t" + element.getHost() + "\t" + element.getPort() + "\t" + element.getUri()); } return this.client; }
3、在启动类中加入 @EnableDiscoveryClient 注解
4、集群配置
新建工程microservicecloud-eureka-7002、microservicecloud-eureka-7003
复制7001的POM到7002、7003下
将住主启动类复制到7002、7003下
7001 YML
server: port: 7001 eureka: instance: hostname: eureka7001.com #eureka服务端的实例名称 client: register-with-eureka: false #false表示不向注册中心注册自己。 fetch-registry: false #false表示自己端就是注册中心,我的职责就是维护服务实例,并不需要去检索服务 service-url: #单机 #defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/ #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址(单机)。 defaultZone: http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/
7002 YML
server: port: 7002 eureka: instance: hostname: eureka7002.com #eureka服务端的实例名称 client: register-with-eureka: false #false表示不向注册中心注册自己。 fetch-registry: false #false表示自己端就是注册中心,我的职责就是维护服务实例,并不需要去检索服务 service-url: #单机 #defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/ #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址(单机)。 defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7003.com:7003/eureka/
7003 YML
server: port: 7003 eureka: instance: hostname: eureka7003.com #eureka服务端的实例名称 client: register-with-eureka: false #false表示不向注册中心注册自己。 fetch-registry: false #false表示自己端就是注册中心,我的职责就是维护服务实例,并不需要去检索服务 service-url: #单机 #defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/ #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址(单机)。 defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/
microservicecloud-provider-dept-8001 的YML 要弄成集群版
eureka: client: #客户端注册进eureka服务列表内 service-url: defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/ instance: instance-id: microservicecloud-dept8001 prefer-ip-address: true #访问路径可以显示IP地址
在自己的host中加入端口映射
127.0.0.1 eureka7001.com 127.0.0.1 eureka7002.com 127.0.0.1 eureka7003.com
测试:
5、作为服务注册中心,Eureka比zookeeper好在哪