【加精】SpringCloud第五篇结束版

SpringCloud系列文章同步网址点击阅读原文直达，欢迎交流探讨。

Hystrix是什么？

Hystrix是一个用于处理分布式系统的延迟和容错的开源库，在分布式系统里，许多依赖不可避免的会调用失败，比如超时、异常等，Hystrix能够保证在一个依赖出问题的情况下，不会导致整体服务失败，避免级联故障，以提高分布式系统的弹性。

“断路器”本身是一种开关装置，当某个服务单元发生故障之后，通过断路器的故障监控（类似熔断保险丝），向调用方返回一个符合预期的、可处理的备选响应（FallBack），而不是长时间的等待或者抛出调用方无法处理的异常，这样就保证了服务调用方的线程不会被长时间、不必要地占用，从而避免了故障在分布式系统中的蔓延，乃至雪崩。

服务的熔断

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

当扇出链路的某个微服务不可用或者响应时间太长时，会进行服务的降级，进而熔断该节点微服务的调用，快速返回”错误”的响应信息。当检测到该节点微服务调用响应正常后恢复调用链路。

在SpringCloud框架里熔断机制通过Hystrix实现。Hystrix会监控微服务间调用的状况，当失败的调用到一定阈值，缺省是5秒内20次调用失败就会启动熔断机制。熔断机制的注解是@HystrixCommand。

1.创建新的子工程，来演示服务熔断，子工程名为microservicecloud-provider-dept-hystrix-8001

2.在microservicecloud-provider-dept-hystrix-8001工程的pom文件里添加如下jar包：

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"
  modelVersion4.0.0/modelVersion

  parent
   groupIdcom.hhf.springcloud/groupId
   artifactIdmicroservicecloud/artifactId
   version0.0.1-SNAPSHOT/version
  /parent

  artifactIdmicroservicecloud-provider-dept-hystrix-8001/artifactId


  dependencies
   !--  hystrix --
   dependency
     groupIdorg.springframework.cloud/groupId
     artifactIdspring-cloud-starter-hystrix/artifactId
   /dependency
   !-- 引入自己定义的api通用包，可以使用Dept部门Entity --
   dependency
     groupIdcom.hhf.springcloud/groupId
     artifactIdmicroservicecloud-api/artifactId
     version${project.version}/version
   /dependency
   !-- 将微服务provider侧注册进eureka --
   dependency
     groupIdorg.springframework.cloud/groupId
     artifactIdspring-cloud-starter-eureka/artifactId
   /dependency
   dependency
     groupIdorg.springframework.cloud/groupId
     artifactIdspring-cloud-starter-config/artifactId
   /dependency
   !-- actuator监控信息完善 --
   dependency
     groupIdorg.springframework.boot/groupId
     artifactIdspring-boot-starter-actuator/artifactId
   /dependency
   dependency
     groupIdjunit/groupId
     artifactIdjunit/artifactId
   /dependency
   dependency
     groupIdmysql/groupId
     artifactIdmysql-connector-java/artifactId
   /dependency
   dependency
     groupIdcom.alibaba/groupId
     artifactIddruid/artifactId
   /dependency
   dependency
     groupIdch.qos.logback/groupId
     artifactIdlogback-core/artifactId
   /dependency
   dependency
     groupIdorg.mybatis.spring.boot/groupId
     artifactIdmybatis-spring-boot-starter/artifactId
   /dependency
   dependency
     groupIdorg.springframework.boot/groupId
     artifactIdspring-boot-starter-jetty/artifactId
   /dependency
   dependency
     groupIdorg.springframework.boot/groupId
     artifactIdspring-boot-starter-web/artifactId
   /dependency
   dependency
     groupIdorg.springframework.boot/groupId
     artifactIdspring-boot-starter-test/artifactId
   /dependency
   !-- 修改后立即生效，热部署 --
   dependency
     groupIdorg.springframework/groupId
     artifactIdspringloaded/artifactId
   /dependency
   dependency
     groupIdorg.springframework.boot/groupId
     artifactIdspring-boot-devtools/artifactId
   /dependency
  /dependencies

/project

3.参考microservicecloud-provider-dept-8001工程的java包中的类，将其microservicecloud-provider-dept-8001所有的类包都复制一份到microservicecloud-provider-dept-hystrix-8001的java包下，然后进行修改。

microservicecloud-provider-dept-hystrix-8001工程修改和添加内容如下：

1).添加microservicecloud-provider-dept-hystrix-8001工程的application.yml文件内容：

sserver:
   port: 8001

 mybatis:
   config-location: classpath:mybatis/mybatis.cfg.xml  #mybatis所在路径
   type-aliases-package: com.hhf.springcloud.entities #entity别名类
   mapper-locations:
   - classpath:mybatis/mapper/**/*.xml #mapper映射文件

 spring:
    application:
     name: microservicecloud-dept
    datasource:
     type: com.alibaba.druid.pool.DruidDataSource
     driver-class-name: org.gjt.mm.mysql.Driver
     url: jdbc:mysql://localhost:3306/cloudDB01
     username: root
     password: 520hhf
     dbcp2:
       min-idle: 5
       initial-size: 5
       max-total: 5
       max-wait-millis: 200

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

 info:
   app.name: atguigu-microservicecloud
   company.name: www.hhf.com
   build.artifactId: $project.artifactId$
   build.version: $project.version$

2).修改microservicecloud-provider-dept-hystrix-8001工程下的DeptController类，把原先DeptController类里面的所有方法以及属性删除，并添加以下内容：

package com.hhf.springcloud.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

import com.hhf.springcloud.entities.Dept;
import com.hhf.springcloud.service.DeptService;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;

@RestController
public class DeptController
{
    @Autowired
    private DeptService service = null;

    @RequestMapping(value="/dept/get/{id}",method=RequestMethod.GET)
    @HystrixCommand(fallbackMethod = "processHystrix_Get")
    public Dept get(@PathVariable("id") Long id)
    {
        Dept dept =  this.service.get(id);
        if(null == dept)
        {
            throw new RuntimeException("该ID："+id+"没有没有对应的信息");
        }
        return dept;
    }

    public Dept processHystrix_Get(@PathVariable("id") Long id) {
        return new Dept().setDeptno(id).setDname("该ID："+id+"没有没有对应的信息,null--@HystrixCommand").setDb_source("no this database in MySQL");
    }
}

3).修改主启动类名，名为：DeptProvider8001_Hystrix_App并添加新注解@EnableCircuitBreaker

@SpringBootApplication
@EnableEurekaClient //本服务启动后会自动注册进eureka服务中
@EnableDiscoveryClient //服务发现
@EnableCircuitBreaker//对hystrixR熔断机制的支持
public class DeptProvider8001_Hystrix_App
{
    public static void main(String[] args)
    {
        SpringApplication.run(DeptProvider8001_Hystrix_App.class, args);
    }
}

4.测试：

1).启动3个eureka集群配置（microservicecloud-eureka-7001系列）。

2).启动microservicecloud-provider-dept-hystrix-8001的DeptProvider8001_Hystrix_App类。

3).启动microservicecloud-consumer-dept-80。

在浏览器中输入： 如果在7001页面中显示了microservicecloud-dept8001-hystrix这个服务，说明成功！！

我们再来看消费者来调用：

在浏览器再输入：http://localhost/consumer/dept/get/1 先看看能不能获取到正确的信息

如果可以，那么我们再从浏览器输入一个在数据库里面毫无id的数据，看看是不是能达到我们代码中写的效果一样：

在浏览器再输入：http://localhost/consumer/dept/get/4444

如果没有找到这个id值的信息，那么就页面就会显示一条信息，如下图所示：

这页面显示的信息，就说明我们的熔断调用成功！！！

总结：向调用方返回一个符合调用预期的，可处理的备选响应，快速返回错误的响应信息。

服务的降级

整体资源快不够了，忍痛将某些服务先关掉，待渡过难关，再开启回来。

服务降级处理是在客户端实现完成的，与服务端没有关系。

1.修改microservicecloud-api工程，service包下再创建一个类：DeptClientServiceFallbackFactory，并实现FallbackFactory这个接口。

package com.hhf.springcloud.service;

import java.util.List;

import org.springframework.stereotype.Component;

import com.hhf.springcloud.entities.Dept;

import feign.hystrix.FallbackFactory;

@Component
public class DeptClientServiceFallbackFactory implements FallbackFactoryDeptClientService
{
    @Override
    public DeptClientService create(Throwable throwable)
    {
        return new DeptClientService() {
            @Override
            public Dept get(long id)
            {
                return new Dept().setDeptno(id)
                        .setDname("该ID："+id+"没有没有对应的信息,Consumer客户端提供的降级信息,此刻服务Provider已经关闭")
                        .setDb_source("no this database in MySQL");
            }

            @Override
            public ListDept list()
            {
                return null;
            }

            @Override
            public boolean add(Dept dept)
            {
                return false;
            }
        };
    }
}

2.再修改microservicecloud-api工程，在DeptClientService接口的注解@FeignClient中添加fallbackFactory属性值

import org.springframework.cloud.netflix.feign.FeignClient;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;

import com.hhf.springcloud.entities.Dept;

import java.util.List;


@FeignClient(value = "MICROSERVICECLOUD-DEPT",fallbackFactory=DeptClientServiceFallbackFactory.class)
public interface DeptClientService {

    @RequestMapping(value = "/dept/get/{id}",method = RequestMethod.GET)
    public Dept get(@PathVariable("id") long id);

    @RequestMapping(value = "/dept/list",method = RequestMethod.GET)
    public ListDept list();

    @RequestMapping(value = "/dept/add",method = RequestMethod.POST)
    public boolean add(Dept dept);

}

3.在microservicecloud-consumer-dept-feign工程下添加application.yml文件内容

添加内容为：（而其他内容不变）

feign: 
  hystrix: 
    enabled: true

4.测试：

1).启动3个eureka集群配置（microservicecloud-eureka-7001系列）。

2).microservicecloud-provider-dept-8001启动。

3).microservicecloud-consumer-dept-feign启动。

4).在浏览器中输入：http://localhost/consumer/dept/get/1 进行测试。

效果图：

5).故意关闭微服务microservicecloud-provider-dept-8001。

6).再浏览器中输入：http://localhost/consumer/dept/get/1 进行重新测试。

效果图：

此时服务端provider已经down了，但是我们做了服务降级处理，让客户端在服务端不可用时也会获得提示信息而不会挂起耗死服务器。

服务监控hystrixDashboard

除了隔离依赖服务的调用以外，Hystrix还提供了准实时的调用监控（Hystrix Dashboard），Hystrix会持续地记录所有通过Hystrix发起的请求的执行信息，并以统计报表和图形的形式展示给用户，包括每秒执行多少请求多少成功，多少失败等。

Netflix通过hystrix-metrics-event-stream项目实现了对以上指标的监控。Spring Cloud也提供了Hystrix Dashboard的整合，对监控内容转化成可视化界面。

1.在总父工程microservicecloud下新建工程microservicecloud-consumer-hystrix-dashboard子工程。

2.在microservicecloud-consumer-hystrix-dashboard工程下的pom文件里面添加jar包：

?xml version="1.0" encoding="UTF-8"?
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"
    parent
        artifactIdmicroservicecloud/artifactId
        groupIdcom.hhf.springcloud/groupId
        version0.0.1-SNAPSHOT/version
    /parent
    modelVersion4.0.0/modelVersion

    artifactIdmicroservicecloud-consumer-hystrix-dashboard/artifactId

    dependencies
        !-- 自己定义的api --
        dependency
            groupIdcom.hhf.springcloud/groupId
            artifactIdmicroservicecloud-api/artifactId
            version${project.version}/version
        /dependency
        dependency
            groupIdorg.springframework.boot/groupId
            artifactIdspring-boot-starter-web/artifactId
        /dependency
        !-- 修改后立即生效，热部署 --
        dependency
            groupIdorg.springframework/groupId
            artifactIdspringloaded/artifactId
        /dependency
        dependency
            groupIdorg.springframework.boot/groupId
            artifactIdspring-boot-devtools/artifactId
        /dependency
        !-- Ribbon相关 --
        dependency
            groupIdorg.springframework.cloud/groupId
            artifactIdspring-cloud-starter-eureka/artifactId
        /dependency
        dependency
            groupIdorg.springframework.cloud/groupId
            artifactIdspring-cloud-starter-ribbon/artifactId
        /dependency
        dependency
            groupIdorg.springframework.cloud/groupId
            artifactIdspring-cloud-starter-config/artifactId
        /dependency
        !-- feign相关 --
        dependency
            groupIdorg.springframework.cloud/groupId
            artifactIdspring-cloud-starter-feign/artifactId
        /dependency
        !-- hystrix和 hystrix-dashboard相关--
        dependency
            groupIdorg.springframework.cloud/groupId
            artifactIdspring-cloud-starter-hystrix/artifactId
        /dependency
        dependency
            groupIdorg.springframework.cloud/groupId
            artifactIdspring-cloud-starter-hystrix-dashboard/artifactId
        /dependency
    /dependencies
/project

3.在microservicecloud-consumer-hystrix-dashboard工程下的application.yml文件里面添加配置：

server:
  port: 9001

4.创建主启动类，名为：DeptConsumer_DashBoard_App 并在方法上添加注解@EnableHystrixDashboard

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

好，我们开始进行测试：

1).启动microservicecloud-consumer-hystrix-dashboard该微服务监控消费端。

在浏览器中输入：http://localhost:9001/hystrix 进行测试。

效果图： 出现以下效果说明成功！！！

2).启动3个eureka集群配置（microservicecloud-eureka-7001系列）。

3).启动microservicecloud-provider-dept-hystrix-8001。

1.在浏览器中输入：http://localhost:8001/dept/get/1 进行测试

2.再从浏览器中输入：http://localhost:8001/hystrix.stream 进行测试

效果图：

3).我们把上面的效果图以图形化的界面进行展示，那么我们回到

http://localhost:9001/hystrix页面中。

然后在Hystrix Dashboard下面的一个框里输入

http://localhost:8001/hystrix.stream 这个网址。

效果图1： 然后点击那个按钮进入一个图形化界面.

效果图2： 目前我们9001工程监控8001工程。

然后我们来使用这个监控页面，在页面的左边有一个1圈和1线和7色的图，我们来试着狂刷新http://localhost:8001/dept/get/1这个页面，然后再回到图形化监控页面的变化。

说明：实心圆：共有两种含义。它通过颜色的变化代表了实例的健康程度，它的健康度从绿色黄色橙色红色递减。该实心圆除了颜色的变化之外，它的大小也会根据实例的请求流量发生变化，流量越大该实心圆就越大。所以通过该实心圆的展示，就可以在大量的实例中快速的发现故障实例和高压力实例。

曲线：用来记录2分钟内流量的相对变化，可以通过它来观察到流量的上升和下降趋势。

效果图1：狂刷新以后就再迅速回到图形化监控页面来查看变化。

效果图2：看到监控页面的变化了吧？

zuul路由网关

**Zuul包含了对请求的路由和过滤两个最主要的功能： **
其中路由功能负责将外部请求转发到具体的微服务实例上，是实现外部访问统一入口的基础而过滤器功能则负责对请求的处理过程进行干预，是实现请求校验、服务聚合等功能的基础。

Zuul和Eureka进行整合，将Zuul自身注册为Eureka服务治理下的应用，同时从Eureka中获得其他微服务的消息，也即以后的访问微服务都是通过Zuul跳转后获得。

注意：Zuul服务最终还是会注册进Eureka。

提供=代理+路由+过滤三大功能。

Zuul路由网关的工程构建

1.新建子工程Module模块microservicecloud-zuul-gateway-9527。

2.在microservicecloud-zuul-gateway-9527工程的pom文件添加jar包。

?xml version="1.0" encoding="UTF-8"?
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"
    parent
        artifactIdmicroservicecloud/artifactId
        groupIdcom.hhf.springcloud/groupId
        version0.0.1-SNAPSHOT/version
    /parent
    modelVersion4.0.0/modelVersion

    artifactIdmicroservicecloud-zuul-gateway-9527/artifactId


    dependencies
        !-- zuul路由网关 --
        dependency
            groupIdorg.springframework.cloud/groupId
            artifactIdspring-cloud-starter-zuul/artifactId
        /dependency
        dependency
            groupIdorg.springframework.cloud/groupId
            artifactIdspring-cloud-starter-eureka/artifactId
        /dependency
        !-- actuator监控 --
        dependency
            groupIdorg.springframework.boot/groupId
            artifactIdspring-boot-starter-actuator/artifactId
        /dependency
        !--  hystrix容错--
        dependency
            groupIdorg.springframework.cloud/groupId
            artifactIdspring-cloud-starter-hystrix/artifactId
        /dependency
        dependency
            groupIdorg.springframework.cloud/groupId
            artifactIdspring-cloud-starter-config/artifactId
        /dependency
        !-- 日常标配 --
        dependency
            groupIdcom.hhf.springcloud/groupId
            artifactIdmicroservicecloud-api/artifactId
            version${project.version}/version
        /dependency
        dependency
            groupIdorg.springframework.boot/groupId
            artifactIdspring-boot-starter-jetty/artifactId
        /dependency
        dependency
            groupIdorg.springframework.boot/groupId
            artifactIdspring-boot-starter-web/artifactId
        /dependency
        dependency
            groupIdorg.springframework.boot/groupId
            artifactIdspring-boot-starter-test/artifactId
        /dependency
        !-- 热部署插件 --
        dependency
            groupIdorg.springframework/groupId
            artifactIdspringloaded/artifactId
        /dependency
        dependency
            groupIdorg.springframework.boot/groupId
            artifactIdspring-boot-devtools/artifactId
        /dependency
    /dependencies

/project

3.在microservicecloud-zuul-gateway-9527工程的resources资源文件包下创建application,yml文件并添加以下内容：

server: 
  port: 9527

spring: 
  application:
    name: microservicecloud-zuul-gateway

eureka: 
  client: 
    service-url: 
      defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka,http://eureka7003.com:7003/eureka  
  instance:
    instance-id: gateway-9527.com
    prefer-ip-address: true 


info:
  app.name: hhf-microcloud
  company.name: www.hhf.com
  build.artifactId: $project.artifactId$
  build.version: $project.version$

4.在我们电脑的hosts文件里面添加如下域名：

127.0.0.1  myzuul.com

5.在java包下创建主启动类，名为：Zuul_9527_StartSpringCloudApp

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

6.测试：

1).启动3个eureka（microservicecloud-eureka-7001系列）。

2).启动microservicecloud-provider-dept-8001工程。

3).启动microservicecloud-zuul-gateway-9527工程。

在浏览器输入：http://eureka7001.com:7001/ 来看看初步的配置

效果图1：

4).先不用路由来测试，在浏览器输入：http://localhost:8001/dept/get/2

5).启动路由来测试，在浏览器输入：http://myzuul.com:9527/microservicecloud-dept/dept/get/2

通过网关也可以访问到我们的微服务。

Zuul路由访问映射规则

我们对http://myzuul.com:9527/microservicecloud-dept/dept/get/2这个页面做一下路由访问映射的规则

在microservicecloud-zuul-gateway-9527工程下修改以下内容：

1.在application.yml文件里面添加以下内容（其他不变）

zuul: 
  routes: 
    mydept.serviceId: microservicecloud-dept
    mydept.path: /mydept/**

然后我们来测试一下能不能用：

1).重新启动microservicecloud-zuul-gateway-9527工程

2).在浏览器输入： http://myzuul.com:9527/mydept/dept/get/1 进行测试

最终结果还是能访问成功（这里就不截图了）。

3).再从浏览器中输入：http://myzuul.com:9527/microservicecloud-dept/dept/get/2 进行测试

microservicecloud-dept这个名字结果也还是能访问成功，那么这个就有点不太安全了，那么最好是单入口单出口。那么我们用代理名字来对外暴露该服务。

2).在application.yml文件里面的zuul下面再添加一句内容（其他不变）

ignored-services: microservicecloud-dept 

完整配置：
    zuul:
  ignored-services: microservicecloud-dept     #只是添加了这一句！！
  routes:
    mydept.serviceId: microservicecloud-dept
    mydept.path: /mydept/**

我们再测试一下：

1).重新启动microservicecloud-zuul-gateway-9527工程

2).在浏览器输入： http://myzuul.com:9527/mydept/dept/get/1 进行测试

最终结果还是能访问成功（这里就不截图了）。

3).再从浏览器中输入：

http://myzuul.com:9527/microservicecloud-dept/dept/get/2 

进行测试

结果却访问不到了，原因是原路径已经被我们封了！！！

效果图：

推荐大而全的【后端技术精选】