92.【SpringCloud NetFilx】（八）-阿里云开发者社区

4.服务熔断 (提供者下用)

(1).什么是服务熔断?

熔断机制是赌对应雪崩效应的一种微服务链路保护机制。

当扇出链路的某个微服务不可用或者响应时间太长时，会进行服务的降级，进而熔断该节点微服务的调用，快速返回错误的响应信息。检测到该节点微服务调用响应正常后恢复调用链路。在SpringCloud框架里熔断机制通过Hystrix实现。Hystrix会监控微服务间调用的状况，当失败的调用到一定阀值缺省是5秒内20次调用失败，就会启动熔断机制。熔断机制的注解是：@HystrixCommand。

服务熔断解决如下问题：

当所依赖的对象不稳定时，能够起到快速失败的目的；
快速失败后，能够根据一定的算法动态试探所依赖对象是否恢复。

(2).入门案列

新建springcloud-provider-dept-hystrix-8001模块并拷贝springcloud-provider-dept–8001内的pom.xml、resource和Java代码进行初始化并调整。
导入hystrix依赖

<dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-hystrix</artifactId>
            <version>1.4.6.RELEASE</version>
        </dependency>

调整yml配置文件(hystrix-8001)

server:
  port: 8081
# Mybatis的配置
mybatis:
  type-aliases-package: com.jsxs.pojo
  mapper-locations: classpath:mybatis/mapper/*.xml
  # Spring的配置
spring:
  application:
    name: SpringCloud-provider-dept
  datasource:
    url: jdbc:mysql://localhost:3306/db01?useUnicode=true&characterEncoding=utf-8
    username: root
    password: 121788
    driver-class-name: com.mysql.jdbc.Driver
    type: com.alibaba.druid.pool.DruidDataSource
 # Eureka 服务注册到哪里?
eureka:
  client:
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/
  instance:
    instance-id: jsxs-01
    prefer-ip-address: true
# info配置
info:
  app.name: jsxs-springcloud
  company.name: pdd

prefer-ip-address: false:

prefer-ip-address: true：

修改controller (hystrix-8001)

@HystrixCommand

package com.jsxs.controller;
import com.jsxs.pojo.Dept;
import com.jsxs.service.DeptService;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.List;
//  提供Restful服务
@RestController
public class DeptController {
    @Resource
    private DeptService deptService;
    @GetMapping("/dept/queryById/{id}")
    @HystrixCommand(fallbackMethod = "hystrixQueryById")   //假如出现错误，就选择备选方案的方法
    public Dept queryById(@PathVariable("id") Long id){
        Dept dept = deptService.queryById(id);
        //  抛出异常
        if(dept==null){
            throw new RuntimeException("这个id=>"+id+"不存在该用户! 或者信息不存在");
        }
        return dept;
    }
    // 备选方案
    @GetMapping("/dept/queryById/{id}")
    public Dept hystrixQueryById(@PathVariable("id") Long id){
        //  这里我们采用了链式编程，因为在API中我们设置了链式编程的注解，所以这个实体类可以进行链式编程
        return new Dept().setDeptno(id)
                         .setDname("这个id=>"+id+"不存在该用户! 或者信息不存在")
                          .setDb_source("无数据库");
    }
}

为主启动类添加对熔断的支持注解@EnableCircuitBreaker

package com.jsxs;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
//启动类
@SpringBootApplication
//  开启服务
@EnableEurekaClient
//   开启服务发现
@EnableDiscoveryClient
// 添加熔断的支持
@EnableCircuitBreaker
public class DeptProvider_Hystrix_8001 {
    public static void main(String[] args) {
        SpringApplication.run(DeptProvider_Hystrix_8001.class,args);
    }
}

为主启动类添加对熔断的支持注解@EnableCircuitBreaker

package com.jsxs;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
//启动类
@SpringBootApplication
//  开启服务
@EnableEurekaClient
//   开启服务发现
@EnableDiscoveryClient
// 添加熔断的支持
@EnableCircuitBreaker
public class DeptProvider_Hystrix_8001 {
    public static void main(String[] args) {
        SpringApplication.run(DeptProvider_Hystrix_8001.class,args);
    }
}

测试：
使用了服务熔断

查看已有的编号

查看未有的编号: 会选择备用方案。

而不使用熔断的springcloud-provider-dept–8001模块访问相同地址会出现下面状况:

5.服务降级（服务调用者下用）

(1).什么是服务降级

服务降级是指：当服务器压力剧增的情况下，根据实际业务情况及流量，对一些服务和页面有策略的不处理，或换种简单的方式处理，从而释放服务器资源以保证核心业务正常运作或高效运作。说白了，就是尽可能的把系统资源让给优先级高的服务。

资源有限，而请求是无限的。如果在并发高峰期，不做服务降级处理，一方面肯定会影响整体服务的性能，严重的话可能会导致宕机某些重要的服务不可用。所以，一般在高峰期，为了保证核心功能服务的可用性，都要对某些服务降级处理。比如当双11活动时，把交易无关的服务统统降级，如查看蚂蚁深林，查看历史订单等等以及退货。

服务降级主要用于什么场景呢？当整个微服务架构整体的负载超出了预设的上限阈值或即将到来的流量预计将会超过预设的阈值时，为了保证重要或基本的服务能正常运行，可以将一些不重要或不紧急的服务或任务进行服务的延迟使用或暂停使用。

降级的方式可以根据业务来，可以延迟服务，比如延迟给用户增加积分，只是放到一个缓存中，等服务平稳之后再执行；或者在粒度范围内关闭服务，比如关闭相关文章的推荐。

由上图可得，当某一时间内服务A的访问量暴增，而B和C的访问量较少，为了缓解A服务的压力，这时候需要B和C暂时关闭一些服务功能，去承担A的部分服务，从而为A分担压力，叫做服务降级。

(2).服务降级需要考虑的问题

1）那些服务是核心服务，哪些服务是非核心服务
2）那些服务可以支持降级，那些服务不能支持降级，降级策略是什么
3）除服务降级之外是否存在更复杂的业务放通场景，策略是什么？

(3).自动降级分类

1）超时降级：主要配置好超时时间和超时重试次数和机制，并使用异步机制探测回复情况
2）失败次数降级：主要是一些不稳定的api，当失败调用次数达到一定阀值自动降级，同样要使用异步机制探测恢复情况
3）故障降级：比如要调用的远程服务挂掉了（网络故障、DNS故障、http服务返回错误的状态码、rpc服务抛出异常），则可以直接降级。降级后的处理方案有：默认值（比如库存服务挂了，返回默认现货）、兜底数据（比如广告挂了，返回提前准备好的一些静态页面）、缓存（之前暂存的一些缓存数据）
4）限流降级：秒杀或者抢购一些限购商品时，此时可能会因为访问量太大而导致系统崩溃，此时会使用限流来进行限制访问量，当达到限流阀值，后续请求会被降级；降级后的处理方案可以是：排队页面（将用户导流到排队页面等一会重试）、无货（直接告知用户没货了）、错误页（如活动太火爆了，稍后重试）。

当服务器关闭之后，用户依然能够访问这个服务器。但是没有数据只有提示。

(4).入门案列

这里的API包相当于客户端的资源包。因为每一个Model都有三层，可以显示也可以隐藏

在springcloud-api模块下的service包中新建降级配置DeptClientServiceFallBackFactory.java

package com.jsxs.service;
import com.jsxs.pojo.Dept;
import feign.hystrix.FallbackFactory;
import org.springframework.stereotype.Service;
import java.util.List;
/***
 *  服务降级的操作
 */
@Service
public class DeptClientServerFallback implements FallbackFactory {
    @Override
    public DeptClientServer create(Throwable throwable) {
        return new DeptClientServer() {   // 因为不能new一个接口,所以我们应该new接口的实现类
            @Override
            public boolean addDept(Dept dept) {
                return false;
            }
            @Override
            public Dept queryById(Long deptno) {
                return new Dept()
                            .setDeptno(deptno)
                            .setDb_source("无数据库")
                            .setDname("id=>"+deptno+"没有用户的信息，客户端提供了降级的服务,这个服务已关闭");
            }
            @Override
            public List<Dept> all() {
                return null;
            }
        };
    }
}

在DeptClientService中指定降级配置类DeptClientServiceFallBackFactory

@FeignClient(value = "SpringCloud-provider-dept",fallbackFactory = DeptClientServerFallback.class)   //feign接口，里面的值是微服务的服务提供者ID名 ,绑定服务降级

package com.jsxs.service;
import com.jsxs.pojo.Dept;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import java.util.List;
@FeignClient(value = "SpringCloud-provider-dept",fallbackFactory = DeptClientServerFallback.class)   //feign接口，里面的值是微服务的服务提供者ID名 ,绑定服务降级
public interface DeptClientServer {   //接口
    @GetMapping("/dept/add")
    public boolean addDept(Dept dept);
    @GetMapping("/dept/get/{id}")
    public Dept queryById(@PathVariable("id") Long deptno);
    @GetMapping("/dept/all")
    public List<Dept> all();
}

在springcloud-consumer-dept-feign-80模块(Feign客户端)中开启降级：

server:
  port: 80
# Eureka
eureka:
    client:
      register-with-eureka: false  # 我们不向Eureka中注册自己，因为我们是消费者,默认是注册
      service-url:  #
        defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/
# 开启服务降级  feign.hystrix
feign:
  hystrix:
    enabled: true

92.【SpringCloud NetFilx】（八）

4.服务熔断 (提供者下用)

(1).什么是服务熔断?

(2).入门案列

5.服务降级（服务调用者下用）

(1).什么是服务降级

(2).服务降级需要考虑的问题

(3).自动降级分类

(4).入门案列

热门文章

最新文章

相关课程

相关电子书

探索云世界

热门

云计算

大数据

云原生

人工智能

数据库

开发与运维

活动广场

任务中心

训练营

直播

乘风者计划

下载

镜像站

技术资料

92.【SpringCloud NetFilx】（八）

4.服务熔断 (提供者下用)

(1).什么是服务熔断?

(2).入门案列

5.服务降级 （服务调用者下用）

(1).什么是服务降级

(2).服务降级需要考虑的问题

(3).自动降级分类

(4).入门案列

热门文章

最新文章

相关课程

相关电子书

5.服务降级（服务调用者下用）