SpringCloud的入门学习之概念理解、Eureka入门

别先生

发布于 2019-11-26 22:24:36

4000

发布于 2019-11-26 22:24:36

文章被收录于专栏：别先生别先生

1、微服务与微服务架构。微服务概念如下所示：

　　答：微服务强调的是服务的大小，它关注的是某一个点，是具体解决某一个问题、提供落地对应服务的一个服务应用，狭意的看，可以看作Eclipse里面的一个个微服务工程/或者Module模块。

2、微服务架构是一种架构模式，微服务架构概念如下所示：

　　答：微服务架构是一种架构模式，它提倡将单一应用程序划分成一组小的服务，服务之间互相协调、互相配合，为用户提供最终价值。每个服务运行在其独立的进程中，服务与服务间采用轻量级的通信机制互相协作（通常是基于HTTP协议的RESTful API，区别于dubbo的RPC远程调用）。每个服务都围绕着具体业务进行构建，并且能够被独立的部署到生产环境、类生产环境等。另外，应当尽量避免统一的、集中式的服务管理机制，对具体的一个服务而言，应根据业务上下文，选择合适的语言、工具对其进行构建。

　　微服务和微服务架构，从技术维度理解，微服务化的核心就是将传统的一站式应用，根据业务拆分成一个一个的服务，彻底地去耦合，每一个微服务提供单个业务功能的服务，一个服务做一件事，从技术角度看就是一种小而独立的处理过程，类似进行概念，能够自行单独启动或者销毁，拥有自己独立的数据。

3、SpringCloud是什么？

　　答：1）、SpringCloud，基于SpringBoot提供了一套微服务解决方案，包括服务注册与发现，配置中心，全链路监控，服务网关，负载均衡，熔断器等组件，除了基于NetFlix的开源组件做高度抽象封装之外，还有一些选型中立的开源组件。

　　　　2）、SpringCloud利用SpringBoot的开发便利性巧妙地简化了分布式系统基础设施的开发，SpringCloud为开发人员提供了快速构建分布式系统的一些工具，包括配置管理、服务发现、断路器、路由、微代理、事件总线、全局锁、决策竞选、分布式会话等等,它们都可以用SpringBoot的开发风格做到一键启动和部署。

　　　　3）、SpringBoot并没有重复制造轮子，它只是将目前各家公司开发的比较成熟、经得起实际考验的服务框架组合起来，通过SpringBoot风格进行再封装屏蔽掉了复杂的配置和实现原理，最终给开发者留出了一套简单易懂、易部署和易维护的分布式系统开发工具包。

　　　　4）、SpringCloud等于分布式服务架构下的一站式解决方案，是各个微服务架构落地技术的集合体，俗称微服务全家桶。

4、微服务全家桶。SpringCloud集成相关优质项目推荐，这些项目是SpringCloud官方项目或者是对SpringCloud进行了有益的补充以及基于SpringCloud最佳实践。

　　1）、Spring Cloud Config，配置管理工具包，让你可以把配置放到远程服务器，集中化管理集群配置，目前支持本地存储，Git以及Subversion。　　2）、Spring Cloud Bus，事件，消息总线，用于在集群（例如，配置变化事件）中传播状态变化，可以与Spring Cloud Config联合实现热部署。　　3）、Eureka，云端服务发现，一个基于REST的服务，用于定位服务，以实现云端中间层服务发现和故障转移。　　4）、Hystrix，熔断器，容错管理工具，旨在通过熔断机制控制服务和第三方库的节点，从而对延迟和故障提供更强大的容错能力。　　5）、Zuul，Zuul是在云平台上提供动态路由，监控，弹性，安全等边缘服务的框架。Zuul相当于是设备和Netflix流应用的web网站后端所有请求的前门。　　6）、Archaius，配置管理api，包含一系列配置管理api，提供动态类型化属性，线程安全配置操作，轮询框架，回调机制等等功能。　　7）、Consul，封装了Consul操作，consul是一个服务发现于配置工具，与Docker容器可以无缝集成。　　8）、Spring Cloud for Cloud Foundry，通过Oauth2协议绑定服务到CloudFoundry，CloudFoundry是Vmware推出的开源PaaS云平台。　　9）、Spring Cloud Sleuth，日志收集工具包，封装了Dapper和log-based追踪以及Zipkin和HTrace操作，为Spring Cloud应用实现了一种分布式追踪解决方案。　　10）、Spring Cloud Data Flow，大数据操作工具，作为Spring XD替代产品，它是一个混合计算模型，结合了流数据与批量数据的处理方式。　　11）、Spring Cloud Security，基于spring security的安全工具包，为你的应用程序添加安全控制。　　12）、Spring Cloud Zookeeper，操作Zookkeper的工具包，用于使用zookeeper方式的服务发现和配置管理。　　13）、Spring Cloud Stream，数据流操作开发包，封装了与Redis，Rabbit，kafka等发送接收消息。　　14）、Spring Cloud Cli，基于Spring Boot Cli，可以让你以命令行方式快速建立云组件。　　15）、Ribbon，提供云端负载均衡，有多种负载均衡策略可供选择，可以配置服务发现和断路器的使用。　　16）、Turbine，Turbine是聚合服务器发送事件流数据的一个工具，用来监控集群下hystrix的metrics情况。　　17）、Feign，Feign是一种声明式，模板化的http客户端。　　18）、Spring Cloud Task提供云端计划任务管理，任务调度。　　19）、Spring Cloud Connectors，便于云端应用程序在各种PaaS平台连接到后端，如数据库和消息代理服务。　　20）、Spring Cloud Cluster，提供Leadership选举，如zookeeper，redis，hazelcast，consul等等常见状态模式的抽象和实现。　　21）、Spring Cloud Starters，Spring Boot式的启动项目，为Spring Cloud提供开箱即用的依赖管理。

5、SpringCloud和SpringBoot是什么关系。

　　1）、SpringBoot专注于快速方便的开发单个个体微服务。　　2）、SpringCloud是关注全局的微服务协调整理治理框架，它将SpringBoot开发的一个个单体微服务整合并管理起来，为各个微服务之间提供，配置管理、服务发现、断路器、路由、微代理、事件总线、全局锁、决策竞选、分布式会话等等集成服务。　　3）、SpringBoot可以离开SpringCloud独立使用开发项目，但是SpringCloud离不开SpringBoot，属于依赖的关系。　　4）、SpringBoot专注于快速、方便的开发单个微服务个体，SpringCloud关注全局的服务治理框架。

6、Eureka服务注册与发现。Eureka是什么？

　　答：Eureka是Netflix的一个子模块，也是核心模块之一。Eureka是一个基于REST的服务，用于定位服务，以实现云端中间层服务发现和故障转移。服务注册与发现对于微服务架构来说是非常重要的，有了服务发现与注册，只需要使用服务的标识符，就可以访问到服务，而不需要修改服务调用的配置文件了。功能类似于dubbo的注册中心，比如Zookeeper。Netflix在设计Eureka的时候遵循的就是AP原则。

Spring Cloud封装了Netflix公司开发的Eureka模块来实现服务注册和发现(请对比Zookeeper)。Eureka采用了C-S的设计架构。Eureka Server作为服务注册功能的服务器，它是服务注册中心。而系统中的其他微服务，使用 Eureka 的客户端连接到 Eureka Server并维持心跳连接。这样系统的维护人员就可以通过 Eureka Server 来监控系统中各个微服务是否正常运行。SpringCloud的一些其他模块（比如Zuul）就可以通过 Eureka Server来发现系统中的其他微服务，并执行相关的逻辑。

7、Eureka包含两个组件：Eureka Server和Eureka Client。

　　答：Eureka Server提供服务注册服务，各个节点启动后，会在EurekaServer中进行注册，这样EurekaServer中的服务注册表中将会存储所有可用服务节点的信息，服务节点的信息可以在界面中直观的看到。 EurekaClient是一个Java客户端，用于简化Eureka Server的交互，客户端同时也具备一个内置的、使用轮询(round-robin)负载算法的负载均衡器。在应用启动后，将会向Eureka Server发送心跳(默认周期为30秒)。如果Eureka Server在多个心跳周期内没有接收到某个节点的心跳，EurekaServer将会从服务注册表中把这个服务节点移除（默认90秒）。

　　　　Eureka的三大角色。Eureka Server提供服务的注册与发现。Service Provider服务提供方将自身服务注册到Eureka，从而使服务消费方能够找到。Service Consumer服务消费方从Eureka获取注册服务列表，从而能够消费服务。

8、构建一个聚合工程，父工程创建maven类型packaging是pom类型的，使用的jdk1.8版本，Spring Cloud版本是Dalston.SR1，SpringBoot版本是1.5.9.RELEASE。详细依赖如下所示：

  1 <project xmlns="http://maven.apache.org/POM/4.0.0"
  2     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 
  4     http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5     <modelVersion>4.0.0</modelVersion>
  6     <groupId>com.bie.springcloud</groupId>
  7     <artifactId>microservicecloud</artifactId>
  8     <version>0.0.1-SNAPSHOT</version>
  9     <packaging>pom</packaging>
 10 
 11     <properties>
 12         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 13         <maven.compiler.source>1.8</maven.compiler.source>
 14         <maven.compiler.target>1.8</maven.compiler.target>
 15         <junit.version>4.12</junit.version>
 16         <log4j.version>1.2.17</log4j.version>
 17         <lombok.version>1.16.18</lombok.version>
 18     </properties>
 19 
 20     <dependencyManagement>
 21         <dependencies>
 22             <!-- spring-cloud -->
 23             <dependency>
 24                 <groupId>org.springframework.cloud</groupId>
 25                 <artifactId>spring-cloud-dependencies</artifactId>
 26                 <version>Dalston.SR1</version>
 27                 <type>pom</type>
 28                 <scope>import</scope>
 29             </dependency>
 30             <!-- spring-boot -->
 31             <dependency>
 32                 <groupId>org.springframework.boot</groupId>
 33                 <artifactId>spring-boot-dependencies</artifactId>
 34                 <version>1.5.9.RELEASE</version>
 35                 <type>pom</type>
 36                 <scope>import</scope>
 37             </dependency>
 38             <!-- mysql -->
 39             <dependency>
 40                 <groupId>mysql</groupId>
 41                 <artifactId>mysql-connector-java</artifactId>
 42                 <version>5.0.4</version>
 43             </dependency>
 44             <!-- druid -->
 45             <dependency>
 46                 <groupId>com.alibaba</groupId>
 47                 <artifactId>druid</artifactId>
 48                 <version>1.0.31</version>
 49             </dependency>
 50             <!-- mybatis -->
 51             <dependency>
 52                 <groupId>org.mybatis.spring.boot</groupId>
 53                 <artifactId>mybatis-spring-boot-starter</artifactId>
 54                 <version>1.3.0</version>
 55             </dependency>
 56             <!-- logback -->
 57             <dependency>
 58                 <groupId>ch.qos.logback</groupId>
 59                 <artifactId>logback-core</artifactId>
 60                 <version>1.2.3</version>
 61             </dependency>
 62             <!-- junit -->
 63             <dependency>
 64                 <groupId>junit</groupId>
 65                 <artifactId>junit</artifactId>
 66                 <version>${junit.version}</version>
 67                 <scope>test</scope>
 68             </dependency>
 69             <!-- log4j -->
 70             <dependency>
 71                 <groupId>log4j</groupId>
 72                 <artifactId>log4j</artifactId>
 73                 <version>${log4j.version}</version>
 74             </dependency>
 75         </dependencies>
 76     </dependencyManagement>
 77 
 78     <build>
 79         <finalName>microservicecloud</finalName>
 80         <resources>
 81             <resource>  <!-- 允许加载src/main/resources下面的所有配置文件 --->
 82                 <directory>src/main/resources</directory>
 83                 <filtering>true</filtering>
 84             </resource>
 85         </resources>
 86         <plugins>
 87             <plugin>  <!-- 此插件负责解析和解读的，所有以$符号开头，以$符号结尾的，在上面的配置路径下面的配置文件信息，都可以读取。可以自定义添加信息。  -->
 88                 <groupId>org.apache.maven.plugins</groupId>
 89                 <artifactId>maven-resources-plugin</artifactId>
 90                 <configuration>
 91                     <delimiters>
 92                         <delimit>$</delimit>
 93                     </delimiters>
 94                 </configuration>
 95             </plugin>
 96         </plugins>
 97     </build>
 98 
 99     <!-- 父工程里面显示子模块 -->
100     <modules>
101         <module>microservicecloud-api</module>
102         <module>microservicecloud-provider-dept-8001</module>
103         <module>microservicecloud-consumer-dept-80</module>
104         <module>microservicecloud-eureka-7001</module>
105     </modules>
106 
107 </project>

创建Eureka Server注册中心模块（注意，聚合工程，这里创建的是Maven Module），引入Eureka Server的依赖包，（注意，如果是SpringBoot2.x版本，对应的Spring Cloud版本已经发生了巨大变化，引入的依赖包坐标也发生了巨大变化，请仔细，认真，对比区别）如下所示：

 1 <project xmlns="http://maven.apache.org/POM/4.0.0"
 2     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 3     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 
 4     http://maven.apache.org/xsd/maven-4.0.0.xsd">
 5     <modelVersion>4.0.0</modelVersion>
 6     <parent>
 7         <groupId>com.bie.springcloud</groupId>
 8         <artifactId>microservicecloud</artifactId>
 9         <version>0.0.1-SNAPSHOT</version>
10     </parent>
11     <artifactId>microservicecloud-eureka-7001</artifactId>
12 
13     <dependencies>
14         <!-- eureka-server服务端 -->
15         <dependency>
16             <groupId>org.springframework.cloud</groupId>
17             <artifactId>spring-cloud-starter-eureka-server</artifactId>
18         </dependency>
19         <!-- 修改后立即生效，热部署 -->
20         <dependency>
21             <groupId>org.springframework</groupId>
22             <artifactId>springloaded</artifactId>
23         </dependency>
24         <dependency>
25             <groupId>org.springframework.boot</groupId>
26             <artifactId>spring-boot-devtools</artifactId>
27         </dependency>
28     </dependencies>
29 
30 </project>

Eureka Server注册中心的配置文件application.yml，如下所示：

 1 server:
 2   port: 7001  # 端口号
 3 
 4 eureka:
 5   instance:
 6     hostname: localhost #eureka服务端的实例名称，因为注册中心安装到本机，又是单节点Eureka Server注册中心，起名为了localhost。


 7   client:
 8     register-with-eureka: false # false表示不向注册中心注册自己
 9     fetch-registry: false # false表示自己端就是注册中心,我的职责就是维护服务实例,并不需要去检索服务
10     service-url:
11       #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址。
12       defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/

Eureka Server注册中心的启动主类，如下所示：

 1 package com.bie;
 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 @SpringBootApplication
 8 @EnableEurekaServer // EurekaServer服务器端启动类,接受其它微服务注册进来
 9 public class MicroServiceCloudEurekaServerApplication {
10 
11     public static void main(String[] args) {
12         SpringApplication.run(MicroServiceCloudEurekaServerApplication.class, args);
13     }
14 
15 }

Eureka Server注册中心，主类启动以后，可以访问界面，效果如下所示：

9、Eureka Server注册中心搭建完毕以后，就可以开发服务的提供者和服务的消费者，现在将服务的提供者注册到Eureka Server注册中心。如下所示：

注意使用的Springboot的版本、SpringCloud的版本，我使用的是低版本的。不是Springboot的2.x版本。注意对比。

 1 <project xmlns="http://maven.apache.org/POM/4.0.0"
 2     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 3     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 
 4     http://maven.apache.org/xsd/maven-4.0.0.xsd">
 5     <modelVersion>4.0.0</modelVersion>
 6     <parent>
 7         <groupId>com.bie.springcloud</groupId>
 8         <artifactId>microservicecloud</artifactId>
 9         <version>0.0.1-SNAPSHOT</version>
10     </parent>
11     <artifactId>microservicecloud-provider-dept-8001</artifactId>
12 
13     <dependencies>
14         <dependency><!-- 引入自己定义的api通用包，可以使用Dept部门Entity -->
15             <groupId>com.bie.springcloud</groupId>
16             <artifactId>microservicecloud-api</artifactId>
17             <version>${project.version}</version>
18         </dependency>
19         <dependency>
20             <groupId>junit</groupId>
21             <artifactId>junit</artifactId>
22         </dependency>
23         <dependency>
24             <groupId>mysql</groupId>
25             <artifactId>mysql-connector-java</artifactId>
26         </dependency>
27         <dependency>
28             <groupId>com.alibaba</groupId>
29             <artifactId>druid</artifactId>
30         </dependency>
31         <dependency>
32             <groupId>ch.qos.logback</groupId>
33             <artifactId>logback-core</artifactId>
34         </dependency>
35         <dependency>
36             <groupId>org.mybatis.spring.boot</groupId>
37             <artifactId>mybatis-spring-boot-starter</artifactId>
38         </dependency>
39         <dependency>
40             <groupId>org.springframework.boot</groupId>
41             <artifactId>spring-boot-starter-jetty</artifactId>
42         </dependency>
43         <dependency>
44             <groupId>org.springframework.boot</groupId>
45             <artifactId>spring-boot-starter-web</artifactId>
46         </dependency>
47         <dependency>
48             <groupId>org.springframework.boot</groupId>
49             <artifactId>spring-boot-starter-test</artifactId>
50         </dependency>
51         <!-- 修改后立即生效，热部署 -->
52         <dependency>
53             <groupId>org.springframework</groupId>
54             <artifactId>springloaded</artifactId>
55         </dependency>
56         <dependency>
57             <groupId>org.springframework.boot</groupId>
58             <artifactId>spring-boot-devtools</artifactId>
59         </dependency>
60         <!-- 将微服务provider侧注册进eureka -->
61         <dependency>
62             <groupId>org.springframework.cloud</groupId>
63             <artifactId>spring-cloud-starter-eureka</artifactId>
64         </dependency>
65         <dependency>
66             <groupId>org.springframework.cloud</groupId>
67             <artifactId>spring-cloud-starter-config</artifactId>
68         </dependency>
69         <!-- actuator监控信息完善,主管监控和信息配置 -->
70         <dependency>
71             <groupId>org.springframework.boot</groupId>
72             <artifactId>spring-boot-starter-actuator</artifactId>
73         </dependency>
74     </dependencies>
75 
76 </project>

修改服务提供者的配置文件application.yml。客户端注册进eureka服务列表内。

 1 server:
 2   port: 8001
 3 
 4 mybatis:
 5   config-location: classpath:mybatis/mybatis.cfg.xml        # mybatis配置文件所在路径
 6   type-aliases-package: com.bie.po                          # 所有实体类别名类所在包
 7   mapper-locations:
 8   - classpath:mybatis/mapper/**/*.xml                       # mapper映射文件  
 9   
10 spring:
11   application:
12     name: microservicecloud-provider-dept                   # 微服务的名称
13   datasource:
14     type: com.alibaba.druid.pool.DruidDataSource            # 当前数据源操作类型
15     driver-class-name: org.gjt.mm.mysql.Driver              # mysql驱动包
16     url: jdbc:mysql://localhost:3306/cloudDb                # 数据库名称
17     username: root
18     password: 123456
19     dbcp2:
20       min-idle: 5                                           # 数据库连接池的最小维持连接数
21       initial-size: 5                                       # 初始化连接数
22       max-total: 5                                          # 最大连接数
23       max-wait-millis: 200                                  # 等待连接获取的最大超时时间
24 
25 eureka:
26   client: # 客户端注册进eureka服务列表内
27     service-url:
28       defaultZone: http://localhost:7001/eureka
29   instance: 
30     instance-id: microservicecloud-provider-dept8001 # 将eureka-server注册中心的服务,显示你想看的名称
31     prefer-ip-address: true # 访问路径可以显示IP地址    
32              
33 info: # 微服务info内容显示详细信息
34   app.name: microservicecloud-provider-dept # 应用名称
35   company.name: www.baidu.com # 公司地址
36   build.artifactId: $project.artifactId$  # 构建项目artifactId
37   build.version: $project.version$ # 构建项目版本号
38

 1 package com.bie.controller;
 2 
 3 import java.util.List;
 4 
 5 import org.springframework.beans.factory.annotation.Autowired;
 6 import org.springframework.cloud.client.ServiceInstance;
 7 import org.springframework.cloud.client.discovery.DiscoveryClient;
 8 import org.springframework.web.bind.annotation.PathVariable;
 9 import org.springframework.web.bind.annotation.RequestBody;
10 import org.springframework.web.bind.annotation.RequestMapping;
11 import org.springframework.web.bind.annotation.RequestMethod;
12 import org.springframework.web.bind.annotation.RestController;
13 
14 import com.bie.po.Dept;
15 import com.bie.service.DeptService;
16 
17 /**
18  * 
19  *
20  * @author biehl
21  *
22  */
23 @RestController
24 public class DeptController {
25 
26     @Autowired
27     private DeptService deptService;
28 
29     // 服务的发现接口。
30     @Autowired
31     private DiscoveryClient discoveryClient;
32 
33     @RequestMapping(value = "/dept/add", method = RequestMethod.POST)
34     public boolean addDept(@RequestBody Dept dept) {
35         return deptService.addDept(dept);
36     }
37 
38     @RequestMapping(value = "/dept/get/{id}", method = RequestMethod.GET)
39     public Dept getById(@PathVariable(value = "id") Long id) {
40         Dept dept = deptService.getById(id);
41         return dept;
42     }
43 
44     @RequestMapping(value = "/dept/list", method = RequestMethod.GET)
45     public List<Dept> getAll() {
46         List<Dept> list = deptService.findAll();
47         return list;
48     }
49 
50     /**
51      * 服务的发现
52      * 
53      * @return
54      */
55     @RequestMapping(value = "/dept/discovery", method = RequestMethod.GET)
56     public Object discovery() {
57         List<String> list = discoveryClient.getServices();
58         System.out.println("**********" + list);
59 
60         List<ServiceInstance> srvList = discoveryClient.getInstances("MICROSERVICECLOUD-PROVIDER-DEPT");
61         for (ServiceInstance element : srvList) {
62             System.out.println(element.getServiceId() + "\t" + element.getHost() + "\t" + element.getPort() + "\t"
63                     + element.getUri());
64         }
65         return this.discoveryClient;
66     }
67 
68 }

修改服务提供者的主类，@EnableEurekaClient本服务启动后会自动注册进eureka服务中。

 1 package com.bie;
 2 
 3 import org.springframework.boot.SpringApplication;
 4 import org.springframework.boot.autoconfigure.SpringBootApplication;
 5 import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
 6 
 7 /**
 8  * 
 9  *
10  * @author biehl
11  *
12  */
13 @SpringBootApplication
14 @EnableEurekaClient // 本服务启动后会自动注册进eureka服务中
15 public class MicroServiceCloudProviderApplication {
16 
17     public static void main(String[] args) {
18         SpringApplication.run(MicroServiceCloudProviderApplication.class, args);
19     }
20 
21 }

先启动Eureka Server服务注册中心，再启动服务的提供者。可以看到已经将服务提供者注册到Eureka Server注册中心了。

注册到注册中心的服务名称可以进行修改的，访问信息有ip提示可以修改的，微服务info信息访问可以修改的（需要添加spring-boot-starter-actuator监控依赖，定义info配置信息）。效果如下所示：

10、什么是Eureka Server注册中心的自我保护模式？

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

　　在自我保护模式中，Eureka Server会保护服务注册表中的信息，不再注销任何服务实例。当它收到的心跳数重新恢复到阈值以上时，该Eureka Server节点就会自动退出自我保护模式。它的设计哲学就是宁可保留错误的服务注册信息，也不盲目注销任何可能健康的服务实例。

　　在Spring Cloud中，可以使用eureka.server.enable-self-preservation = false 禁用自我保护模式。建议不要禁用。切记，在Eureka-server注册中心添加该配置。

11、Eureka服务的注册与发现，Eureka服务的提供者Provider已经注册到了Eureka Server注册中心，如何进行服务的发现呢。

 1 <project xmlns="http://maven.apache.org/POM/4.0.0"
 2     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 3     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 
 4     http://maven.apache.org/xsd/maven-4.0.0.xsd">
 5     <modelVersion>4.0.0</modelVersion>
 6     <parent>
 7         <groupId>com.bie.springcloud</groupId>
 8         <artifactId>microservicecloud</artifactId>
 9         <version>0.0.1-SNAPSHOT</version>
10     </parent>
11     <artifactId>microservicecloud-consumer-dept-80</artifactId>
12 
13     <dependencies>
14         <!-- 自己定义的api -->
15         <dependency>
16             <groupId>com.bie.springcloud</groupId>
17             <artifactId>microservicecloud-api</artifactId>
18             <version>${project.version}</version>
19         </dependency>
20         <dependency>
21             <groupId>org.springframework.boot</groupId>
22             <artifactId>spring-boot-starter-web</artifactId>
23         </dependency>
24         <!-- 修改后立即生效，热部署 -->
25         <dependency>
26             <groupId>org.springframework</groupId>
27             <artifactId>springloaded</artifactId>
28         </dependency>
29         <dependency>
30             <groupId>org.springframework.boot</groupId>
31             <artifactId>spring-boot-devtools</artifactId>
32         </dependency>
33         <!-- 将微服务provider侧注册进eureka -->
34         <dependency>
35             <groupId>org.springframework.cloud</groupId>
36             <artifactId>spring-cloud-starter-eureka</artifactId>
37         </dependency>
38         <dependency>
39             <groupId>org.springframework.cloud</groupId>
40             <artifactId>spring-cloud-starter-config</artifactId>
41         </dependency>
42     </dependencies>
43 
44 </project>

配置服务发现的Consumer的配置文件application.yml。

1 server:
2   port: 80
3  
4 eureka:
5   client: # 客户端注册进eureka服务列表内
6     service-url:
7       defaultZone: http://localhost:7001/eureka

RestTemplate提供了多种便捷访问远程Http服务的方法, 是一种简单便捷的访问restful服务模板类,是Spring提供的用于访问Rest服务的客户端模板工具集

 1 package com.bie.config;
 2 
 3 import org.springframework.context.annotation.Bean;
 4 import org.springframework.context.annotation.Configuration;
 5 import org.springframework.web.client.RestTemplate;
 6 
 7 /**
 8  * 
 9  *
10  * @author biehl
11  * 
12  *         RestTemplate提供了多种便捷访问远程Http服务的方法, 是一种简单便捷的访问restful服务模板类,
13  *         是Spring提供的用于访问Rest服务的客户端模板工具集
14  * 
15  */
16 @Configuration
17 public class ConfigBean {
18 
19     @Bean
20     public RestTemplate getRestTemplate() {
21         return new RestTemplate();
22     }
23 }

如何进行服务的发现呢，开发消费者的控制层，然后可以使用Spring封装好的RestTemplate进行访问。

 1 package com.bie.controller;
 2 
 3 import java.util.List;
 4 
 5 import org.springframework.beans.factory.annotation.Autowired;
 6 import org.springframework.web.bind.annotation.PathVariable;
 7 import org.springframework.web.bind.annotation.RequestBody;
 8 import org.springframework.web.bind.annotation.RequestMapping;
 9 import org.springframework.web.bind.annotation.RestController;
10 import org.springframework.web.client.RestTemplate;
11 
12 import com.bie.po.Dept;
13 
14 /**
15  * 
16  * RestTemplate提供了多种便捷访问远程Http服务的方法, 是一种简单便捷的访问RESTFul服务模板类,
17  * 是Spring提供的用于访问Rest服务的客户端模板工具集
18  *
19  * 使用restTemplate访问restful接口非常的简单粗暴无脑。 (url, requestMap,
20  * ResponseBean.class)这三个参数分别代表 REST请求地址、请求参数、HTTP响应转换被转换成的对象类型。
21  * 
22  * 
23  * @author biehl
24  *
25  */
26 @RestController
27 public class DeptControllerConsumer {
28 
29     private static final String REST_URL_PREFIX = "http://localhost:8001";
30     // private static final String REST_URL_PREFIX = "http://MICROSERVICECLOUD-DEPT";
31 
32     @Autowired
33     private RestTemplate restTemplate;
34 
35     /**
36      * 
37      * @param dept
38      * @return
39      */
40     @RequestMapping(value = "/consumer/dept/add")
41     public boolean addDept(@RequestBody Dept dept) {
42 
43         return restTemplate.postForObject(REST_URL_PREFIX + "/dept/add", dept, Boolean.class);
44     }
45 
46     /**
47      * 注意,从路径中获取到参数值,使用注解@PathVariable
48      * 
49      * @param id
50      * @return
51      */
52     @RequestMapping(value = "/consumer/dept/get/{id}")
53     public Dept getById(@PathVariable(value = "id") Long id) {
54 
55         return restTemplate.getForObject(REST_URL_PREFIX + "/dept/get/" + id, Dept.class);
56     }
57 
58     /**
59      * 
60      * @return
61      */
62     @SuppressWarnings("unchecked")
63     @RequestMapping(value = "/consumer/dept/list")
64     public List<Dept> list() {
65 
66         return restTemplate.getForObject(REST_URL_PREFIX + "/dept/list", List.class);
67     }
68     
69     // 测试@EnableDiscoveryClient,消费端可以调用服务发现
70     @RequestMapping(value = "/consumer/dept/discovery")
71     public Object discovery() {
72         return restTemplate.getForObject(REST_URL_PREFIX + "/dept/discovery", Object.class);
73     }
74 
75 }

效果如下所示：

12、Eureka Server注册中心的集群配置。

　　新建microservicecloud-eureka-7002、microservicecloud-eureka-7003，再加上microservicecloud-eureka-7001可以配置成三台节点的Eureka Server注册中心集群。将microservicecloud-eureka-7001节点的pom.xml配置复制到microservicecloud-eureka-7002、microservicecloud-eureka-7003，这里省略，修改microservicecloud-eureka-7001、microservicecloud-eureka-7002、microservicecloud-eureka-7003三个主启动类的名称，避免启动的时候出现重复。修改C:\Windows\System32\drivers\etc\host的映射地址，如下所示：

1 127.0.0.1       eureka7001.com
2 127.0.0.1       eureka7002.com
3 127.0.0.1       eureka7003.com

修改三个节点的配置文件application.yml，microservicecloud-eureka-7001如下所示：

 1 server:
 2   port: 7001
 3 
 4 eureka:
 5   server:
 6     enable-self-preservation: false
 7   instance: 
 8     hostname: eureka7001.com #eureka服务端的实例名称
 9   client:
10     register-with-eureka: false # false表示不向注册中心注册自己
11     fetch-registry: false # false表示自己端就是注册中心,我的职责就是维护服务实例,并不需要去检索服务
12     service-url:
13       #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址。
14       # defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/        
15       defaultZone: http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/    
16       
17     
18

microservicecloud-eureka-7002如下所示：

 1 server:
 2   port: 7002
 3 
 4 eureka:
 5   server:
 6     enable-self-preservation: false
 7   instance: 
 8     hostname: eureka7002.com #eureka服务端的实例名称
 9   client:
10     register-with-eureka: false # false表示不向注册中心注册自己
11     fetch-registry: false # false表示自己端就是注册中心,我的职责就是维护服务实例,并不需要去检索服务
12     service-url:
13       #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址。
14       # defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/        
15       defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7003.com:7003/eureka/      
16       
17     
18

microservicecloud-eureka-7003如下所示：

 1 server:
 2   port: 7003
 3 
 4 eureka:
 5   server:
 6     enable-self-preservation: false
 7   instance: 
 8     hostname: eureka7003.com #eureka服务端的实例名称
 9   client:
10     register-with-eureka: false # false表示不向注册中心注册自己
11     fetch-registry: false # false表示自己端就是注册中心,我的职责就是维护服务实例,并不需要去检索服务
12     service-url:
13       #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址。
14       # defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/        
15       defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/
16     
17

修改服务提供者microservicecloud-provider-dept-8001的application.yml配置文件，如下所示：

 1 server:
 2   port: 7003
 3 
 4 eureka:
 5   server:
 6     enable-self-preservation: false
 7   instance: 
 8     hostname: eureka7003.com #eureka服务端的实例名称
 9   client:
10     register-with-eureka: false # false表示不向注册中心注册自己
11     fetch-registry: false # false表示自己端就是注册中心,我的职责就是维护服务实例,并不需要去检索服务
12     service-url:
13       #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址。
14       # defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/        
15       defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/
16     
17

启动microservicecloud-eureka-7001、microservicecloud-eureka-7002、microservicecloud-eureka-7003、microservicecloud-provider-dept-8001注册中心和服务提供者，可以看到监控界面，如下所示：