本篇文章是继上一篇SpringCloud入门（二）之Eureka（上）之后的，因此目录也是从之下的第五开始

文章目录

五，Eureka自我保护机制
六，服务发现
七，Eureka集群配置
八，Eureka和Zookeeper比较
- 8.1 CAP
- 8.2 Eureka和Zookeeper

五，Eureka自我保护机制

自我保护机制：某时刻某一个微服务不可用了，eureka不会立刻清理，依旧会对该微服务的信息进行保存。

默认情况下，如果EurekaServer在一定时间内没有接收到某个微服务实例的心跳，EurekaServer将会注销该实例（默认90秒）。但是当网络分区故障发生时，微服务与EurekaServer之间无法正常通信，以上行为可能变得非常危险了，因为微服务本身是健康的，此时本不应该注销这个微服务，Eureka通过“自我保护机制”来解决这个问题：当EurekaServer节点在短时间内丢失过多客户端时（可能发生了网络分区故障），那么这个节点就会进入自我保护模式。一旦进入该模式，EurekaServer就会变回服务注册表总的信息，不再删除服务注册表中的数据（也就是不会注销任何微服务）。当网络故障恢复后，该EurekaServer节点会自动退出自我保护模式。

自我保护模式是一种应对网络异常的安全保护措施，它的架构哲学是宁可同时保留所有微服务（健康和不健康都会保留），也不盲目注销任何健康的微服务。使用自我保护模式，可以让Eureka集群更加的健壮和稳定。

在Spring Cloud中，可以使用以下配置来禁用自我保护模式：

eureka.server.enable-self-preservation = false

但是不推荐禁用。

六，服务发现

由于注册服务只有在Eureka服务中心才能看到，对于服务消费者是屏蔽的，因此需要对消费者公开一个接口访问。

6.1 controller（1）

在服务提供者的controller中注入DiscoveryClient，然后新增访问接口：

@Autowired
private DiscoveryClient client;


@RequestMapping(value="/dept/discovery",method=RequestMethod.GET)
	  public Object discovery(){
		  //获取Eureka服务中心的微服务
		  List<String> list = client.getServices();
		  System.out.println("====" + list + "====");
		  //从client中获取名为SERVICECLOUD-DEPT的微服务
		  List<ServiceInstance> srvList = client.getInstances("SERVICECLOUD-DEPT");
		  for(ServiceInstance e : srvList) {
			  System.out.println(e.getServiceId() + "\t" + e.getHost());
		  }
		  return this.client;
	  }

6.2 启动类

在服务提供者的启动类新增服务发现注解@EnableDiscoveryClient：

package com.lmc.springcloud;

import org.mybatis.spring.annotation.MapperScan;
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;
import org.springframework.context.annotation.ComponentScan;


@SpringBootApplication
@EnableEurekaClient //本服务启动后会自动注册进eureka服务中
@EnableDiscoveryClient  //服务注册发现
@ComponentScan("com.lmc.springcloud.*")
@MapperScan("com.lmc.springcloud.dao")
public class DeptProvider8001_App {

	public static void main(String[] args) {
		SpringApplication.run(DeptProvider8001_App.class, args);

	}

}

6.3 controller（2）

在服务消费者的controller新增调用接口：

/**
	 * 服务发现
	 * @return
	 */
	@RequestMapping(value = "/consumer/discovery")
	public Object discovery(){
		return restTemplate.getForObject(REST_URL_PREFIX + "/dept/discovery", Object.class);
	}

6.4 测试

http://localhost/consumer/discovery

七，Eureka集群配置

7.1 pom.xml

新建servicecloud-eureka-7002/和servicecloud-eureka-7003项目，pom.xml文件按照7001为模板进行复制

<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">
  <modelVersion>4.0.0</modelVersion>
  <parent>
    <groupId>com.lmc</groupId>
    <artifactId>servicecloud</artifactId>
    <version>0.0.1-SNAPSHOT</version>
  </parent>
  <artifactId>servicecloud-eureka-7002</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>

7.2 启动类

复制7001的启动类到7002和7003，修改类名以便于区分：

package com.lmc.springcloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;


@SpringBootApplication
@EnableEurekaServer//EurekaServer服务器端启动类,接受其它微服务注册进来
public class EurekaServer7002_App{
	
  public static void main(String[] args){
	  SpringApplication.run(EurekaServer7002_App.class, args);
  }
  
}

7.3 修改映射配置

找到C:\Windows\System32\drivers\etc路径下的hosts文件，修改映射配置添加进hosts文件

127.0.0.1  eureka7001.com
127.0.0.1  eureka7002.com
127.0.0.1  eureka7003.com

7.4 application.yml（1）

修改三台服务器的application.yml配置文件

7001：

server: 
  port: 7001

eureka:
  instance:
    hostname: eureka7001.com 		#eureka服务端的实例名称
  client:
    register-with-eureka: false #false表示不向注册中心注册自己。
    fetch-registry: false 		#false表示自己端就是注册中心，我的职责就是维护服务实例，并不需要去检索服务
    service-url:
      defaultZone: http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/
      #单机模式  defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/        #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址。

7002：

server: 
  port: 7002

eureka:
  instance:
    hostname: eureka7002.com 		#eureka服务端的实例名称
  client:
    register-with-eureka: false #false表示不向注册中心注册自己。
    fetch-registry: false 		#false表示自己端就是注册中心，我的职责就是维护服务实例，并不需要去检索服务
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7003.com:7003/eureka/
      #单机模式  defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/        #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址。

7003：

server: 
  port: 7003

eureka:
  instance:
    hostname: eureka7003.com 		#eureka服务端的实例名称
  client:
    register-with-eureka: false #false表示不向注册中心注册自己。
    fetch-registry: false 		#false表示自己端就是注册中心，我的职责就是维护服务实例，并不需要去检索服务
    service-url:
      defaultZone: http://eureka7002.com:7002/eureka/,http://eureka7001.com:7001/eureka/
      #单机模式  defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/        #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址。

7.5 application.yml（2）

由于microservicecloud-provider-dept-8001微服务要发布到上面3台eureka集群配置中，因此要修改向Eureka服务中心注册的服务提供者的配置文件application.yml：

defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/

修改完文件如下：

server:
  port: 8001
  
mybatis:
  config-location: classpath:mybatis/mybatis.cfg.xml        # mybatis配置文件所在路径
  type-aliases-package: com.lmc.springcloud.entities    # 所有Entity别名类所在包
  mapper-locations: classpath*:mybatis/mapper/**/*.xml     # mapper映射文件
    
spring:
    application:
       name: servicecloud-dept 
    datasource:
       type: com.alibaba.druid.pool.DruidDataSource            # 当前数据源操作类型
       driver-class-name: com.mysql.jdbc.Driver              # mysql驱动包
       url: jdbc:mysql://localhost:3306/clouddb01              # 数据库名称
       username: root
       password: root
    dbcp2:
      min-idle: 5                                           # 数据库连接池的最小维持连接数
      initial-size: 5                                       # 初始化连接数
      max-total: 5                                          # 最大连接数
      max-wait-millis: 200                                  # 等待连接获取的最大超时时间

eureka:
   client: 
      service-url: 
         defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/
         # defaultZone: http://localhost:7001/eureka		#客户端注册进eureka服务列表内
   instance:
      instance-id: servicecloud-dept8001				#自定义服务名称信息
      prefer-ip-address: true     						#访问路径可以显示IP地址

info:
   app.name: lmc-servicecloud
   company.name: www.lmc.com
   build.artifactId: $project.artifactId$
   build.version: $project.version$

7.6 验证

http://eureka7001.com:7001/

http://eureka7002.com:7002/

http://eureka7003.com:7003/

当打开集群的一个服务中心时，DS Replied会展示集群中的其他服务中心，如下图打开7003后展示了7001和7002的服务中心。

八，Eureka和Zookeeper比较

8.1 CAP

传统的关系型数据库系统（ RDBMS ）要遵守的原则：ACID

A(Atomicity)原子性
C(Consistency)一致性
I(Isolation)独立性
D(Durability)持久性

系统要遵守的原则：CAP，但最多只能同时满足其中两个，这就是CAP的3进2，但对于分布式系统中，网络硬件经常会出现丢包等的问题，因此P是必须要的，分区容错性是我们必须要实现的，所以只能选择CP或AP

C(Consistency)强一致性
A(Availability)可用性
P(Partition tolerance)分区容错性

满足CAP的三大类：

CA-单点集群，满足一致性，可用性的系统，通常在可扩展性上不太强大
CP-满足一致性，分区容错的系统，通常性能不是特别高
AP-满足可用性，分区容错性的系统，通常可能对一致性要求低一些

CAP原则图如下所示：

8.2 Eureka和Zookeeper

对于CAP原则，Zookeeper保证的是CP，而Eureka保证的是AP

Zookeeper：当向注册中心查询服务列表时，我们可用容忍注册中心返回的是几分钟以前的注册信息，但不能接受服务直接down掉不可用。也就是说，服务注册功能对可用性的要求要高于一致性。但是zk会出现这样一种情况，当master节点因为网络故障与其他节点时区联系时，剩余节点会重新进行leader选举。问题在于，选举leader的事件太长，30-120s，且选举期间整个zk集群都是不可用的，这就导师在选举期间注册服务瘫痪。在云部署的环境下，因网络问题使得zk集群时区master节点时较大概率会发生的事，虽然服务能够最终恢复，但是漫长的选举时间导致的注册长期不可用是不能容忍的。
Eureka：Eureka看明白了这一点，因此在设计时就优先保证可用性。Eureka各个节点都是平等的，几个节点挂掉不会影响正常节点的工作，剩余的节点依然可用提供注册和查询服务。而Eureka的客户端在向某个Eureka注册如果有时发生连接失败，则会自动切换至其它节点，只要有一台Eureka还在，救恩那个保证注册服务可用（保证可用性），只不过查到的信息可能不是最新的（不保证强一致性）。除此之外，Eureka还有一种自我保护机制，如果在15分钟内超过85%的节点都没有正常的心跳，那么Eureka就认为客户端与注册中心出现了网络故障，此时出现以下几种情况：
1. Eureka不再从注册列表中移除因为长时间没收到心跳而应该过期的服务
2. Eureka仍然能够接受新服务的注册和查询请求，但是不会被通过不到其他节点上（即保证当前节点依然可用）
3. 当网络稳定，当前实例新的注册信息会被同步到其他节点中

因此，Eureka可以很好的应对因网络故障导致部分节点失去联系的情况，而不会像zookeeper那样使整个服务瘫痪。

文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/81644.html