@TOC
一、Eureka 简介
1、什么 Eureka？
Netflix 在涉及 Eureka 时，遵循的就是 API 原则.Eureka 是 Netflix 的有个子模块，也是核心模块之一。Eureka 是基于 REST 的服务，用于定位服务，以实现云端中间件层服务发现和故障转移，服务注册与发现对于微服务来说是非常重要的，有了服务注册与发现，只需要使用服务的标识符，就可以访问到服务，而不需要修改服务调用的配置文件了，功能类似于 Dubbo 的注册中心，比如 Zookeeper.
2、Eureka 的原理
Eureka 包含两个组件：Eureka Server 和 Eureka Client。Eureka Server 提供服务注册服务，各个节点启动后，会在 Eureka Server 中进行注册，这样 EurekaServer 中的服务注册表中将会存储所有可用服务节点的信息，服务节点的信息可以在界面中直观的看到。Eureka Client 是一个 java 客户端，用于简化与 Eureka Server 的交互，客户端同时也就是一个内置的、使用轮询(round-robin)负载算法的负载均衡器。在应用启动后，将会向 Eureka Server 发送心跳,默认周期为 30 秒，如果 Eureka Server 在多个心跳周期内没有接收到某个节点的心跳，Eureka Server 将会从服务注册表中把这个服务节点移除(默认 90 秒)。Eureka Server 之间通过复制的方式完成数据的同步，Eureka 还提供了客户端缓存机制，即使所有的 Eureka Server 都挂掉，客户端依然可以利用缓存中的信息消费其他服务的 API。综上，Eureka 通过心跳检查、客户端缓存等机制，确保了系统的高可用性、灵活性和可伸缩性。
3、EureKa 自我保护机制：好死不如赖活着
某时刻某一个微服务不可用，eureka 不会立即清理，依旧会对该微服务的信息进行保存！
默认情况下，当 eurekaserver 在一定时间内没有收到实例的心跳，便会把该实例从注册表中删除（默认是 90 秒），但是，如果短时间内丢失大量的实例心跳，便会触发 eurekaserver 的自我保护机制，比如在开发测试时，需要频繁地重启微服务实例，但是我们很少会把 eurekaserver 一起重启（因为在开发过程中不会修改 eureka 注册中心），当一分钟内收到的心跳数大量减少时，会触发该保护机制。可以在 eureka 管理界面看到 Renewsthreshold 和 Renews(lastmin)，**当后者（最后一分钟收到的心跳数）小于前者（心跳阈值）**的时候，触发保护机制，会出现红色的警告：EMERGENCY!EUREKAMAY BE INCORRECTLY CLAIMING INSTANCES ARE UP WHEN THEY'RENOT.RENEWALS ARE LESSER THAN THRESHOLD AND HENCE THE INSTANCES ARENOT BEGING EXPIRED JUST TO BESAFE.从警告中可以看到，eureka 认为虽然收不到实例的心跳，但它认为实例还是健康的，eureka 会保护这些实例，不会把它们从注册表中删掉。
该保护机制的目的是避免网络连接故障，在发生网络故障时，微服务和注册中心之间无法正常通信，但服务本身是健康的，不应该注销该服务，如果 eureka 因网络故障而把微服务误删了，那即使网络恢复了，该微服务也不会重新注册到 eurekaserver 了，因为只有在微服务启动的时候才会发起注册请求，后面只会发送心跳和服务列表请求，这样的话，该实例虽然是运行着，但永远不会被其它服务所感知。所以，eurekaserver 在短时间内丢失过多的客户端心跳时，会进入自我保护模式，该模式下，eureka 会保护注册表中的信息，不在注销任何微服务，当网络故障恢复后，eureka 会自动退出保护模式。自我保护模式可以让集群更加健壮。但是我们在开发测试阶段，需要频繁地重启发布，如果触发了保护机制，则旧的服务实例没有被删除，这时请求有可能跑到旧的实例中，而该实例已经关闭了，这就导致请求错误，影响开发测试。所以，在开发测试阶段，我们可以把自我保护模式关闭，只需在 eurekaserver 配置文件中加上如下配置即可：eureka.server.enable-self-preservation=false【不推荐关闭自我保护机制】
4、Eureka 和 Zookeeper 的区别
1、回顾 CAP 原则
这涉及到了流行数据库采用的原则问题。其中（Relational Database Management System：RDBMS）关系数据库管理系统采用 ACID 原则，包括 SqlServer、oracle、mysql。非关系型的数据库（non-relational），采用 CAP 原则，包括 Redis、MongoDB
2、ACID 原则
A: 事务的原子性(Atomicity)：是指一个事务要么全部执行，要么不执行，也就是说一个事务不可能只执行了一半就停止了。比如你从取款机取钱，这个事务可以分成两个步骤：1 划卡，2 出钱。不可能划了卡，而钱却没出来。这两步必须同时完成，要么就不完成。
C: 事务的一致性(Consistency)：是指事务的运行并不改变数据库中数据的一致性。例如，完整性约束了 a+b=10，一个事务改变了 a，那么 b 也应该随之改变。
I: 独立性(Isolation）：事务的独立性也称作隔离性，是指两个以上的事务不会出现交错执行的状态。因为这样可能会导致数据不一致，更加具体的来讲，就是事务之间的操作是独立的。
D: 持久性(Durability）：事务的持久性是指事务执行成功以后，该事务对数据库所作的更改便是持久的保存在数据库之中，不会无缘无故的回滚。
3、CAP 原则
CAP 原则又称 CAP 定理，指的是在一个分布式系统中， Consistency（一致性）、 Availability（可用性）、Partition tolerance（分区容错性），三者不可得兼，最多只能得到两个。
一致性（C）：在分布式系统中的所有数据备份，在同一时刻是否同样的值。（等同于所有节点访问同一份最新的数据副本）
可用性（A）：保证每个请求不管成功或者失败都有响应。
分区容忍性（P）：系统中任意信息的丢失或失败不会影响系统的继续运作。
4、Eureka 和 Zookeeper 的区别
Zookeeper 保证的是 CP
当向注册中心查询服务列表时，我们可以容忍注册中心返回的是几分钟以前的注册信息，但不能接收服务直接 down 掉不可用。也就是说，服务注册功能对可用性的要求要高于一致性。但 zookeeper 会出现这样一种情况，当 master 节点因为网络故障与其他节点失去联系时，剩余节点会重新进行 leader 选举。问题在于，选举 leader 的时间太长，30-120s，且选举期间整个 zookeeper 集群是不可用的，这就导致在选举期间注册服务瘫痪。在云部署的环境下，因为网络问题使得 zookeeper 集群失去 master 节点是较大概率发生的事件，虽然服务最终能够恢复，但是，漫长的选举时间导致注册长期不可用，是不可容忍的。
Eureka 保证的是 AP
Eureka 看明白了这一点，因此在设计时就优先保证可用性。Eureka 各个节点都是平等的，几个节点挂掉不会影响正常节点的工作，剩余的节点依然可以提供注册和查询服务。而 Eureka 的客户端在向某个 Eureka 注册时，如果发现连接失败，则会自动切换至其他节点，只要有一台 Eureka 还在，就能保住注册服务的可用性，只不过查到的信息可能不是最新的，除此之外，Eureka 还有之中自我保护机制，如果在 15 分钟内超过 85%的节点都没有正常的心跳，那么 Eureka 就认为客户端与注册中心出现了网络故障，此时会出现以下几种情况：
Eureka 不在从注册列表中移除因为长时间没收到心跳而应该过期的服务
Eureka 仍然能够接受新服务的注册和查询请求，但是不会被同步到其他节点上 (即保证当前节点依然可用)
当网络稳定时，当前实例新的注册信息会被同步到其他节点中
因此，Eureka 可以很好的应对因网络故障导致部分节点失去联系的情况，而不会像 zookeeper 那样使整个注册服务瘫痪
二、Eureka 实战
配置 Eureka-Server
1、 新建一个 Eureka 的 module
2、配置 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>springcloud-demo2</artifactId> <groupId>com.you</groupId> <version>1.0-SNAPSHOT</version> </parent> <modelVersion>4.0.0</modelVersion>
<artifactId>springcloud-eureka-7001</artifactId> <dependencies> <!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-eureka-server --> <!--Eureka Server--> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-eureka-server</artifactId> <version>1.4.6.RELEASE</version> </dependency> <!--热部署--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-devtools</artifactId> </dependency> </dependencies>
</project>
复制代码
3、配置 application.yml 文件
#端口号server: port: 7001
#Eureka的配置eureka: instance: hostname: localhost #Eureka服务端的名字 client: register-with-eureka: false #表示是否向注册中心 注册自己 fetch-registry: false #如果非false，则表示自己为注册中心 service-url: #监控页面 defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
复制代码
4、配置启动类
EurekaServer_7001.java
package com.you;
import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
@SpringBootApplication@EnableEurekaServer/*主启动类，可以接受别人注册进来*/public class EurekaServer_7001 { public static void main(String[] args) { SpringApplication.run(EurekaServer_7001.class,args);
}}
复制代码
配置 Eureka-client
1、配置 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>springcloud-demo2</artifactId> <groupId>com.you</groupId> <version>1.0-SNAPSHOT</version> </parent> <modelVersion>4.0.0</modelVersion>
<artifactId>springcloud-provider-dept-8001</artifactId> <dependencies> <!--mysql--> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> </dependency> <!--Spring web--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> <version>2.7.3</version> </dependency> <!--spring boot 启动--> <dependency> <groupId>org.mybatis.spring.boot</groupId> <artifactId>mybatis-spring-boot-starter</artifactId> </dependency> <dependency> <groupId>org.apache.isis.viewer</groupId> <artifactId>junit</artifactId> <version>0.2.0-incubating</version> </dependency> <dependency> <groupId>log4j</groupId> <artifactId>log4j</artifactId> </dependency> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> </dependency> <!--热部署--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-devtools</artifactId> </dependency> <dependency> <groupId>com.you</groupId> <artifactId>springcloud-api</artifactId> <version>1.0-SNAPSHOT</version> <scope>compile</scope> </dependency> <!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-eureka --> <!--引入Eureka的依赖--> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-eureka</artifactId> <version>1.4.6.RELEASE</version> </dependency> <!--完善监控信息--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-actuator</artifactId> </dependency> </dependencies>
</project>
复制代码
2、配置 application.yml
#端口号server: port: 8001
#配置数据库spring: datasource: url: jdbc:mysql:///dp80?serverTimezone=UTC username: root password: 200201203332 driver-class-name: com.mysql.jdbc.Driver application: name: springcloud-provider-dept-8001debug: true
#配置Eureka的配置eureka: client: service-url: defaultZone: http://localhost:7001/eureka/ instance: instance-id: springcloud-provider-8001
#info配置info: app.name: youtanzhi-springcloud company.name: blog.youtanzhi.com
复制代码
3、配置 Mapper
DeptMapper.interface
package com.you.mapper;
import com.you.pojo.Dept;import org.apache.ibatis.annotations.Mapper;import org.apache.ibatis.annotations.Select;import org.springframework.stereotype.Repository;
import java.util.List;@Mapper@Repositorypublic interface DeptMapper { @Select("select * from Dept where deptno = #{id}") public Dept finaDeptOfId(Long id);}
复制代码
4、配置 Controller
DeptController.java
package com.you.Controller;
import com.you.mapper.DeptMapper;import com.you.pojo.Dept;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.cloud.client.ServiceInstance;import org.springframework.cloud.client.discovery.DiscoveryClient;import org.springframework.stereotype.Component;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.PathVariable;import org.springframework.web.bind.annotation.ResponseBody;import org.springframework.web.bind.annotation.RestController;
import java.util.List;
@RestController@ResponseBody@Componentpublic class DeptController { @Autowired DeptMapper deptMapper;
@Autowired private DiscoveryClient client; @GetMapping("/dept/aDept/{id}") public Dept getDeptOfId(@PathVariable("id") Long id) { return deptMapper.finaDeptOfId(id); } /*注册进来的微服务~ 获取一些消息*/ @GetMapping("/dept/discover") public Object discover() { /*获取微服务列表清单*/ List<String> clientServices = client.getServices(); System.out.println("discover=>services"+clientServices); /*得到一个具体的微服务信息，通过具体的微服务id，ApplicationName*/ List<ServiceInstance> instances = client.getInstances("SPRINGCLOUD-PROVIDER-DEPT"); for (ServiceInstance instance : instances) { System.out.println(instance.getHost()+"/t"+ instance.getUri()+"/t"+ instance.getPort()+"/t"+ instance.getInstanceId()); } return this.client;
}
}
复制代码
5、配置启动类
package com.you;
import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.client.discovery.EnableDiscoveryClient;import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
@SpringBootApplication@EnableEurekaClient@EnableDiscoveryClientpublic class DeptApplication { public static void main(String[] args) { SpringApplication.run(DeptApplication.class,args); }}
复制代码
三、Eureka 集群
这篇文章！！！！
评论