十次方——SpringCloud之Eureka、Feign

悠悠 2022-02-22 15:28 238阅读 0赞

# 1 SpringCloud简介 #

### 1.1 什么是SpringCloud ###

Spring Cloud是一系列框架的有序集合。它利用Spring Boot的开发便利性巧妙地简化了分布式系统基础设施的开发，如服务发现注册、配置中心、消息总线、负载均衡、熔断器、数据监控等，都可以用Spring Boot的开发风格做到一键启动和部署。Spring并没有重复制造轮子，它只是将目前各家公司开发的比较成熟、经得起实际考验的服务框架组合起来，通过Spring Boot风格进行再封装屏蔽掉了复杂的配置和实现原理，最终给开发者留出了一套简单易懂、易部署和易维护的分布式系统开发工具包。Spring Cloud项目的官方网址：http://projects.spring.io/spring-cloud

### 1.2 SpringCloud与SpringBoot的关系 ###

Spring Boot 是 Spring 的一套快速配置脚手架，可以基于Spring Boot 快速开发单个微服务，Spring Cloud是一个基于Spring Boot实现的云应用开发工具；Spring Boot专注于快速、方便集成的单个微服务个体，Spring Cloud关注全局的服务治理框架；Spring Boot使用了默认大于配置的理念，很多集成方案已经帮你选择好了，能不配置就不配置，Spring Cloud很大的一部分是基于Spring Boot来实现，可以不基于Spring Boot吗？不可以。Spring Boot可以离开Spring Cloud独立使用开发项目，但是Spring Cloud离不开Spring Boot，属于依赖的关系。

### 1.3 SpringCloud主要框架 ###

服务发现——Netflix Eureka  
服务调用——Netflix Feign  
熔断器——Netflix Hystrix  
服务网关——Netflix Zuul  
分布式配置——Spring Cloud Config  
消息总线 —— Spring Cloud Bus

### 1.4 Spring Cloud和Dubbo对比 ###

或许很多人会说Spring Cloud和Dubbo的对比有点不公平，Dubbo只是实现了服务治理，而Spring Cloud下面有17个子项目（可能还会新增）分别覆盖了微服务架构下的方方面面，服务治理只是其中的一个方面，一定程度来说，Dubbo只是Spring Cloud  
Netflix中的一个子集。  
![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NTgyNjA0_size_16_color_FFFFFF_t_70][]

### 1.5 说说SpringCloud的版本 ###

我们目前课程采用的SpringCloud版本为Finchley.M9 。你可能会觉得这个版本怎么这么奇怪？SpringCloud由于是一系列框架组合，为了避免与包含的自框架版本产生混淆，采用伦敦地铁站的名称作为版本名，形式为版本名+里程碑号。 M9为第9个里程碑版本。以下是SpringBoot与Spring Cloud版本的对照表，大家看看有没有找到什么规律呢？  
![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NTgyNjA0_size_16_color_FFFFFF_t_70 1][]

# 2 服务发现组件 Eureka #

### 2.1 Eureka ###

Eureka是Netflix开发的服务发现框架，SpringCloud将它集成在自己的子项目spring-cloud-netflix中，实现SpringCloud的服务发现功能。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通过心跳检查、客户端缓存等机制，确保了系统的高可用性、灵活性和可伸缩性。

### 2.2 Eureka服务端开发 ###

（1）首先在父工程pom.xml中引入依赖，（定义SpringCloud版本）  
![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NTgyNjA0_size_16_color_FFFFFF_t_70 2][]

注意，这个dependencyManagement是定义在dependencies外面的

（2）创建tensquare\_eureka模块

（3）添加依赖

![20190409211231346.png][]

（3）添加application.yml

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NTgyNjA0_size_16_color_FFFFFF_t_70 3][]

（4）编写启动类

（5）运行启动类后，在浏览器输入：[http://localhost:6868/][http_localhost_6868] 就可以看到效果了

主界面中system status为系统信息 General Info为一般信息 Instances currentlyregistered with Eureka为注册到的所有微服务列表。

### 2.3 服务注册 ###

我们现在就将所有的微服务都注册到Eureka中，这样所有的微服务之间都可以互相调用了。

（1）将其他微服务模块添加依赖

<dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>

（2）修改每个微服务的application.yml，添加注册eureka服务的配置

![20190410091249265.png][]

（3）修改每个服务类的启动类，添加注解

@EnableEurekaClient

（4）启动测试：将每个微服务启动起来，会发现eureka的注册列表中可以看到这些微服务了

![20190410091610900.png][]

## ##

###    2.4 保护模式 ###

如果在Eureka Server的首页看到以下这段提示，则说明Eureka已经进入了保护模式：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NTgyNjA0_size_16_color_FFFFFF_t_70 4][]

Eureka Server在运行期间，会统计心跳失败的比例在15分钟之内是否低于85%，如果出现低于的情况（在单机调试的时候很容易满足，实际在生产环境上通常是由于网络不稳定导致），Eureka Server会将当前的实例注册信息保护起来，同时提示这个警告。保护模式主要用于一组客户端和Eureka Server之间存在网络分区场景下的保护。一旦进入保护模式，Eureka Server将会尝试保护其服务注册表中的信息，不再删除服务注册表中的数据（也就是不会注销任何微服务）。

# 3 Feign实现服务间的调用 #

### 3.1 Feign简介 ###

Feign是简化Java HTTP客户端开发的工具（java-to-httpclient-binder），它的灵感来自于Retrofit、JAXRS-2.0和WebSocket。Feign的初衷是降低统一绑定Denominator到HTTP API的复杂度，不区分是否为restful。

### 3.2 快速体验 ###

我们现在在**问答微服务（qa）**调用**基础微服务（base）**的方法（根据ID查询标签），如下图

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NTgyNjA0_size_16_color_FFFFFF_t_70 5][]

主要步骤如下

（1）首先将两个微服务都注册到Feign里面（参考2.3节）

（2）在tensquare\_qa模块添加依赖

<dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-openfeign</artifactId>
    </dependency>

（3）修改tensquare\_qa模块的启动类，添加下列注解

@EnableDiscoveryClient
    @EnableFeignClients

（4）在tensquare\_qa模块创建 com.tensquare.qa.client包，包下创建接口（仔细对比该接口与上图）

package com.tensquare.qa.client;
    
    //jar省略
    
    @Component
    @FeignClient("tensquare-base")
    public interface BaseClient {
    
        @RequestMapping(value="/label/{labelId}" ,method = RequestMethod.GET)
        public Result findById(@PathVariable("labelId") String labelId);
    }

@FeignClient注解用于指定从哪个服务中调用功能 ，注意 里面的名称与被调用的服务名保持一致，并且不能包含下划线。

@RequestMapping注解用于对被调用的微服务进行地址映射。注意 @PathVariable注解一定要指定参数名称，否则出错。

@Component标签可加可不加，反正它是通过网络调用base模块的方法。如果不加下图中的baseClient会爆红，但是不影响运行。

（5）在tensquare\_qa模块中的ProblemController类中调用接口

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NTgyNjA0_size_16_color_FFFFFF_t_70 6][]

（6）测试：http://localhost:9003/problem/label/1 能看到标签的信息

# 四 交友微服务开发 #

### 4.1 需求分析 ###

好友表  
![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NTgyNjA0_size_16_color_FFFFFF_t_70 7][]

非好友表

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NTgyNjA0_size_16_color_FFFFFF_t_70 8][]

交友微服务本身的功能:

（1）当用户登陆后在推荐好友列表中点击“心”，表示喜欢此人 ，在数据库tb\_friend表中插入一条数据，islike 为0

（2）当你点击了喜欢过的人，也喜欢了你 , 表示互粉成功！也向tb\_friend表中插入一条数据，islike为1 ，并且将你喜欢她的数据islike也修改为1

（3）当你点击了不喜欢某人（点击了叉），向tb\_nofriend添加记录.

（4）当两个人互粉后，其中一人不喜欢对方了，删除好友表中的记录 ，向非好友表中添加记录

**什么场景下使用springCloud呢？**

我们来看用户表，有两列： fanscount 表示粉丝数 ，followcount表示关注数

（1）当用户点击了喜欢：比如小宝关注了楚楚，小宝的followcount（关注数）加1 ， 楚楚的fanscount （粉丝数）加1

（2）当用户删除了好友：比如楚楚删除了好友小宝，小宝的fanscount （粉丝数）减1 ，楚楚的followcount（关注数）减1

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NTgyNjA0_size_16_color_FFFFFF_t_70]: /images/20220222/e6eb4a700edc437dbc7a91449b34acb6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NTgyNjA0_size_16_color_FFFFFF_t_70 1]: /images/20220222/22833b6cce3141dea643237de2021128.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NTgyNjA0_size_16_color_FFFFFF_t_70 2]: /images/20220222/852c5ed65d044a86a04fe48b7f65fd27.png
[20190409211231346.png]: /images/20220222/c45003d4acf04103b3a24201a539c9a8.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NTgyNjA0_size_16_color_FFFFFF_t_70 3]: /images/20220222/362bca34f1ca41298b656d4590184f83.png
[http_localhost_6868]: http://localhost:6868/
[20190410091249265.png]: /images/20220222/b0c2abfad0474dc79c9830fdcb0491f8.png
[20190410091610900.png]: /images/20220222/a71982fe3c2e453b892a2be1d7a727c1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NTgyNjA0_size_16_color_FFFFFF_t_70 4]: /images/20220222/bd2e7fd0131a4048b682a07fb0549d57.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NTgyNjA0_size_16_color_FFFFFF_t_70 5]: /images/20220222/b6406b597d5245a59edd6cf96b943828.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NTgyNjA0_size_16_color_FFFFFF_t_70 6]: /images/20220222/5c580d7ca71948d88ccf00acc6ebb49e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NTgyNjA0_size_16_color_FFFFFF_t_70 7]: /images/20220222/6017f371f8e645e999d66c752f9726ac.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2NTgyNjA0_size_16_color_FFFFFF_t_70 8]: /images/20220222/f42551983edf4d5e974ee54b8fb03ecf.png