关于SpringCloud集成模块介绍

比眉伴天荒 2022-05-06 06:50 125阅读 0赞

### 文章目录 ###

*   *  关于SpringCloud集成模块介绍（持续学习中）：
     *   *  Eureka 服务发现框架
         *   *  官方介绍
             *  maven
             *  SpringBoot 注解
             *  配置
         *  Ribbon 负载均衡器
         *   *  官网介绍
             *  maven
             *  SpringBoot 注解
             *  图解
         *  Feign 声明式Web Service客户端
         *   *  官方介绍
             *  maven
             *  SpringBoot 注解
             *  配置
         *  Hystrix 断路器
         *   *  官方介绍
             *  maven
             *  SpringBoot 注解
             *  配置
             *  图解
         *  Zuul -API Gateway 服务器
         *   *  官方介绍
             *  maven
             *  SpringBoot 注解
         *  待续

## 关于SpringCloud集成模块介绍（持续学习中）： ##

[官方文档-Finchley.RELEASE][-Finchley.RELEASE]

### Eureka 服务发现框架 ###

音同 ureka - ‘u rui ka’ /优瑞卡/  
英 /,jʊ(ə)'riːkə/ 美 /jʊ’rikə/

#### 官方介绍 ####

[Eureka-client][]  
[Eureka-server][]

> Eureka是Netflix开发的服务发现框架，本身是一个基于REST的服务，主要用于定位运行在AWS域中的中间层服务，以达到负载均衡和中间层服务故障转移的目的。SpringCloud将它集成在其子项目spring-cloud-netflix中，以实现SpringCloud的服务发现功能。

Eureka是Spring Cloud Netflix微服务套件中的一部分，可以与Springboot构建的微服务很容易的整合起来。

Eureka包含服务器端和客户端两个组件：**Eureka Server和Eureka Client**。

**Eureka Server**提供服务注册服务，各个节点启动后，会在Eureka Server中进行注册，这样EurekaServer中的服务注册表中将会存储所有可用服务节点的信息，服务节点的信息可以在界面中直观的看到。  
EurekaServer作为服务器端，也被称作是服务注册中心，用于提供服务的注册与发现。（**类似 zookeeper ,比它更适合做服务发现与注册服务**）

> Eureka支持高可用的配置，当集群中有分片出现故障时，Eureka就会转入自动保护模式，它允许分片故障期间继续提供服务的发现和注册，当故障分片恢复正常时，集群中其他分片会把他们的状态再次同步回来。

**Eureka Client**是一个java客户端，用于简化与Eureka Server的交互，客户端同时也就别一个内置的、使用轮询(round-robin)负载算法的负载均衡器。

> 客户端组件包含服务消费者与服务生产者。在应用程序运行时，Eureka客户端向注册中心注册自身提供的服务并周期性的发送心跳来更新它的服务租约。同时也可以从服务端查询当前注册的服务信息并把他们缓存到本地并周期性的刷新服务状态。

#### maven ####

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

#### SpringBoot 注解 ####

client:

@SpringBootApplication
    @EnableEurekaClient
    @RestController
    public class EurekaClientApplication {
    
    	public static void main(String[] args) {
    		SpringApplication.run(EurekaClientApplication.class, args);
    	}
    
    
    	@Value("${server.port}")
    	String port;
    
    	@RequestMapping("/hello")
    	public String home(@RequestParam(value = "name",defaultValue = "springCloud EurekaClient")String name){
    		return "hello， " + name + ", this port ：" + port;
    	}
    
    }

server:

@SpringBootApplication
    @EnableEurekaServer
    public class EurekaServerApplication {
    
    	public static void main(String[] args) {
    		SpringApplication.run(EurekaServerApplication.class, args);
    	}
    }

**@EnableEurekaServer和@EnableEurekaClient**

> There are multiple implementations of “Discovery Service” (eureka, consul, zookeeper). @EnableDiscoveryClient lives in spring-cloud-commons and picks the implementation on the classpath. @EnableEurekaClient lives in spring-cloud-netflix and only works for eureka. If eureka is on your classpath, they are effectively the same.

—— [enablekaclient和EnableDiscoveryClient的区别是什么?][enablekaclient_EnableDiscoveryClient]

@EnableEurekaServer:  
启动一个服务注册中心提供给其他应用进行对话。

@EnableEurekaClient  
提供多种方法获取应用集合和 应用实例信息集合。

如果是使用Eureka作为注册中心就使用@EnableEurekaClient比较好，如果是其他的注册中心推荐用@EnableDiscoveryClient

#### 配置 ####

配置服务（注册中心）：  
properties方式：

server.port=9000
    
    spring.application.name=eurka-server
    
    eureka.instance.hostname=localhost
    eureka.client.registerWithEureka=false
    eureka.client.fetchRegistry=false
    eureka.client.serviceUrl.defaultZone=http://${eureka.instance.hostname}:${server.port}/eureka/

yml方式:

server:
      port: 9000
      
    spring:
      application:
        name: eurka-server
    
    eureka:
      instance:
        hostname: localhost
      client:
        registerWithEureka: false
        fetchRegistry: false
        serviceUrl:
          defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/

配置eureka client（服务提供者）：  
properties方式：

server.port=9000
    
    spring.application.name=service-a
    
    eureka.client.serviceUrl.defaultZone=http://localhost:9001/eureka/

yml方式:

server:
      port: 9001
    
    spring:
      application:
        name: service-a
    
    eureka:
      client:
        serviceUrl:
          defaultZone: http://localhost:9000/eureka/

--------------------

### Ribbon 负载均衡器 ###

ribbon 音同 ‘ruiben’ /瑞本/  
英\[ˈrɪbən\] 美\[ˈrɪbən\]

服务消费者，负载均衡器，Spring cloud有两种服务调用方式，一种是Ribbon+restTemplate，另一种是Feign（Feign默认集成了Ribbon）。

> Ribbon是Netflix发布的负载均衡器，它有助于控制HTTP和TCP的客户端的行为。为Ribbon配置服务提供者地址后，Ribbon就可基于某种负载均衡算法，自动地帮助服务消费者去请求。Ribbon默认为我们提供了很多负载均衡算法，例如轮询、随机等。当然，我们也可为Ribbon实现自定义的负载均衡算法。

#### 官网介绍 ####

> Ribbon is a client side load balancer which gives you a lot of control over the behaviour of HTTP and TCP clients. Feign already uses Ribbon, so if you are using @FeignClient then this section also applies.  
> 译：  
> Ribbon是一个客户端负载均衡器，它可以让你更好地控制HTTP和TCP客户端的行为。Feign已经使用Ribbon，所以如果你使用@FeignClient，这个部分也适用。

文档：[ Client Side Load Balancer: Ribbon][Client Side Load Balancer_ Ribbon]

在SpringCould中ribbon配合Eureka使用，可以自动从Eurka中获取服务地址列表，配置负载均衡，基于负载均衡提供服务实例。

#### maven ####

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

#### SpringBoot 注解 ####

*  直接使用Eureka注解，但是需要在启动类中注入bean以便使用：

@SpringBootApplication
    @EnableDiscoveryClient
    @EnableEurekaClient
    @EnableHystrix
    public class ServiceRibbonApplication {
    
    	public static void main(String[] args) {
    		SpringApplication.run(ServiceRibbonApplication.class, args);
    	}
    	
    	//注入bean，通过@LoadBalanced注解表示当前的restTemplate开启负载均衡
    	@Bean
    	@LoadBalanced
    	RestTemplate restTemplate(){
    		return new RestTemplate();
    	}
    
    
    }

#### 图解 ####

Eureka为注册中心，注册有ABCD四个服务，当通调用D服务的时候因为ribbon进行了负载均衡，这时候会根据默认的负载均衡配置去轮询调用ABC三个服务

restTemplate

serverA

Eureka

serverB

serverC

service-ribbon

serverD

配置同client一样，需要端口和服务名；  
yml:

server:
      port: xxxx
    
    spring:
      application:
        name: service-ribbon
    
    eureka:
      client:
        serviceUrl:
          defaultZone: http://localhost:xxxx/eureka/

--------------------

### Feign 声明式Web Service客户端 ###

Feign 音同 /非in/  
英 /feɪn/ 美 /fen/

#### 官方介绍 ####

[官方文档 - Spring Cloud OpenFeign][- Spring Cloud OpenFeign]

> Feign is a declarative web service client. It makes writing web service clients easier. To use Feign create an interface and annotate it. It has pluggable annotation support including Feign annotations and JAX-RS annotations. Feign also supports pluggable encoders and decoders. Spring Cloud adds support for Spring MVC annotations and for using the same HttpMessageConverters used by default in Spring Web. Spring Cloud integrates Ribbon and Eureka to provide a load balanced http client when using Feign.

有道翻译：  
Feign是一个声明式web服务客户机。它使编写web服务客户机变得更容易。要使用Feign，请创建一个接口并对其进行注释。它具有可插入注释支持，包括假装注释和JAX-RS注释。Feign还支持可插入的编码器和解码器。Spring Cloud增加了对Spring MVC注释和使用Spring Web默认使用的httpmessageconverter的支持。Spring Cloud集成了Ribbon和Eureka，在使用佯攻时提供了一个负载均衡的http客户端。

> Feign是一个声明式的Web Service客户端，我们只需要使用Feign来创建一个接口并用注解来配置它既可完成。Feign最初是为了降低统一绑定Denominator到HTTP API的复杂度，不区分是否支持Restful。Feign旨在通过最少的资源和代码来实现和HTTP API的连接。通过可定制的解码器和错误处理，可以编写任意的HTTP API。

工作机制

> Feign通过配置注入一个模板化请求进行工作。只需在发送之前关闭它，参数就可以被直接的运用到模板中。然而这也限制了Feign，只支持文本形式的API，它可以在响应请求方面来简化系统。了解了这一点，这也非常容易进行你的单元测试转换。

SpringCloud集成了Feign。Feign默认集成ribbon，也整合了Hystrix，具有熔断的能力。

#### maven ####

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

#### SpringBoot 注解 ####

@EnableFeignClients //springBoot启动类加上FeignClients注解开启Feign功能
    @FeignClient(value = "serviceX") //在interface上注解，指定调用的服务

然后在需要的地方调用interface：

@Autowired
    FeignClientService feignClient;

#### 配置 ####

properties：
    //禁用/启用feign
    spring.sleuth.feign.enabled=false
    //禁用/启用FeignBeanPostProcessor，如果将其设置为false，则Spring Cloud Sleuth不会检测任何自定义Feign组件。但是，所有默认检测仍然存在。
    spring.sleuth.feign.processor.enabled=false
    
    yml：参考上面写

--------------------

### Hystrix 断路器 ###

Hystrix /hi streaks/ 音同 /嗨~斯醉克斯/ヾ(。￣□￣)ﾂ゜゜゜

\*断路器（熔断）：在某个服务提供者无法提供服务的时候通过fallback直接返回一个固定值。

#### 官方介绍 ####

[官方文档 - Hystrix][- Hystrix]

#### maven ####

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

#### SpringBoot 注解 ####

//启动类添加注解开启Hystrix
    @EnableHystrix
    
    //配置fallback方法
    @HystrixCommand(fallbackMethod = "MethodName")

Feign中使用：  
配置(Feign自带，直接配置开启即可)

feign.hystrix.enabled=true

然后在接口中配置fallback指定类

//接口
    @FeignClient(value = "servicea",fallback = FeignServiceHystric.class)
    public interface FeignService {
        @RequestMapping(value = "/feign")
        String sayHiFromClient(@RequestParam(value = "name") String name);
    }
    //指定断路调用类
    @Component
    public class FeignServiceHystric implements FeignService{
        @Override
        public String sayHiFromClient(String name) {
            return "sorry , " + name + ", This's Error , From FeignServiceHystric";
        }
    }

#### 配置 ####

feign.hystrix.enabled=true

#### 图解 ####

fallback

API

serverA

serverB

serverC

这里如果sercerC不可用的时候就会调用fallbcak来调用对应的方法返回一个固定值

--------------------

### Zuul -API Gateway 服务器 ###

#### 官方介绍 ####

官方文档链接参见：[zuul - 官方介绍 ][zuul - _]

Zuul 是netflix开源的一个API Gateway 服务器, 本质上是一个web servlet应用。

Zuul可以通过加载动态过滤机制，从而实现以下各项功能：

> 验证与安全保障: 识别面向各类资源的验证要求并拒绝那些与要求不符的请求。  
> 审查与监控: 在边缘位置追踪有意义数据及统计结果，从而为我们带来准确的生产状态结论。  
> 动态路由: 以动态方式根据需要将请求路由至不同后端集群处。  
> 压力测试: 逐渐增加指向集群的负载流量，从而计算性能水平。  
> 负载分配: 为每一种负载类型分配对应容量，并弃用超出限定值的请求。  
> 静态响应处理: 在边缘位置直接建立部分响应，从而避免其流入内部集群。  
> 多区域弹性: 跨越AWS区域进行请求路由，旨在实现ELB使用多样化并保证边缘位置与使用者尽可能接近。

zuul的核心是一系列的filters, 其作用可以类比Servlet框架的Filter，或者AOP。

zuul定义的几种标准的过滤器类型：

(1) PRE：这种过滤器在请求被路由之前调用。我们可利用这种过滤器实现身份验证、在集群中选择请求的微服务、记录调试信息等。  
(2) ROUTING：这种过滤器将请求路由到微服务。这种过滤器用于构建发送给微服务的请求，并使用Apache HttpClient或Netfilx Ribbon请求微服务。  
(3) POST：这种过滤器在路由到微服务以后执行。这种过滤器可用来为响应添加标准的HTTP Header、收集统计信息和指标、将响应从微服务发送给客户端等。  
(4) ERROR：在其他阶段发生错误时执行该过滤器。  
如：

@Component
    public class MyFilter extends ZuulFilter {
    
        private static Logger logger = LoggerFactory.getLogger(MyFilter.class);
    
        @Override
        public String filterType() {
            return "pre";
        }
    
        @Override
        public int filterOrder() {
            return 0;
        }
    
        @Override
        public boolean shouldFilter() {
            return true;
        }
    
        @Override
        public Object run() throws ZuulException {
            return null;
        }
    }

#### maven ####

<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-netflix-zuul</artifactId>
    			<version>2.0.0.RELEASE</version>
    		</dependency>

#### SpringBoot 注解 ####

*  启动类上添加@EnableZuulProxy

@SpringBootApplication
    @EnableZuulProxy
    @EnableEurekaClient
    @EnableDiscoveryClient
    public class ZuulApplication {
    	public static void main(String[] args) {		
    		SpringApplication.run(ZuulApplication.class, args);	
    	}
    }

……

参考：  
[方志鹏的博客-cpringCould-zuul][-cpringCould-zuul]

### 待续 ###

[-Finchley.RELEASE]: http://cloud.spring.io/spring-cloud-static/Finchley.RELEASE/single/spring-cloud.html
[Eureka-client]: http://cloud.spring.io/spring-cloud-static/Finchley.RELEASE/single/spring-cloud.html#_service_discovery_eureka_clients
[Eureka-server]: http://cloud.spring.io/spring-cloud-static/Finchley.RELEASE/single/spring-cloud.html#spring-cloud-eureka-server
[enablekaclient_EnableDiscoveryClient]: https://stackoverflow.com/questions/31976236/whats-the-difference-between-enableeurekaclient-and-enablediscoveryclient
[Client Side Load Balancer_ Ribbon]: http://cloud.spring.io/spring-cloud-static/Finchley.RELEASE/single/spring-cloud.html#spring-cloud-ribbon
[- Spring Cloud OpenFeign]: http://cloud.spring.io/spring-cloud-static/Finchley.RELEASE/single/spring-cloud.html#_spring_cloud_openfeign
[- Hystrix]: http://cloud.spring.io/spring-cloud-static/Finchley.RELEASE/single/spring-cloud.html#_circuit_breaker_hystrix_clients
[zuul - _]: http://cloud.spring.io/spring-cloud-static/Finchley.RELEASE/single/spring-cloud.html#_router_and_filter_zuul
[-cpringCould-zuul]: https://www.fangzhipeng.com/springcloud/2018/08/30/sc-f5-zuul/