SpringCloud笔记六：Hystrix - HelloWorld开发者社区

[TOC]

Hystrix是什么？

Hystrix是一个断路器，主要作用是服务熔断。

我举个例子，比如我想访问服务A，但是服务A依赖服务B，服务B依赖服务C...这种多个服务之间依赖调用称为扇出(就像一把折扇缓缓打开一样)

倘若某个服务反应的时间很长，或者服务不可用了，那么对服务A的调用会占用系统越来越多的资源，直至系统崩溃。

这就是所谓的，当发生雪崩时，没有一片雪花是无辜的。

我们当然不能允许这种情况的发生，当某个服务出现问题的时候，我必须进行服务熔断，这个时候我们的断路器Hystrix诞生了。

Hystrix服务熔断

新建Hystrix项目

我们现在的provider项目有三个，分别是8001,8002,8003.我们当然可以在provider已有的项目上直接加上hystrix功能，但是我还是想做一个对比，所以我们新建一个项目吧，就叫provider-hystrix-8001，对比一下

新建项目过程不多叙述，然后把provider-8001的内容，Java代码，yml，pom文件复制过来即可。稍微修改一点

修改yml

复制过来的yml，我们只需要修改instance-id，就是自定义的那个status的名称，我们改成

 instance-id: provider-hystrix-8001  #这个是修改Eureka界面的Status名称

Maven的pom.xml添加hystrix引用

在provider-hystrix-8001项目的pom文件中，加入hystrix的引用

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

修改Controller

修改一个Controller的代码

package com.atguigu.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.atguigu.springcloud.entities.Dept;
import com.atguigu.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调用类中的指定方法
    @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");
    }
}

这里的Controller代码删了其他的，只保留了一个get方法，加了一个@HystrixCommand(fallbackMethod = "processHystrix_Get")注解，意思在在抛出异常的时候会去找processHystrix_Get这个方法解决，运行eureka集群，运行Hystrix提供者，测试一下

SpringCloud笔记六：Hystrix

我们胡乱输入数字，在没有数据的情况下，果然去找了Hystrix断路器指定的方法，这样很快就返回了一个数据，起码不会报错，异常，或者加载很久没答案。

Hystrix服务降级

所谓的服务降级，就是为了保证一个访问量很高的服务的正常运行，暂时让一些不重要的服务暂停。而暂停的服务在有用户访问的时候要给出提示，这样用户就不会一直去访问已经暂停的服务，也就不会有大的服务器压力了。

说一个我们上面写的服务熔断的代码，如下图，很明显，我们写了一个get方法就加了一个Hystrix的注解，那我写了100个方法，加100次注解？这很麻烦，所以我们要使用Spring的AOP面向切面编程，解决这个问题

SpringCloud笔记六：Hystrix

注意：服务降级是客户端的事，和服务端没什么关系

修改api项目

在api项目下新建一个service包，然后建一个接口，如下：

package com.atguigu.springcloud.service;

import java.util.List;

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.atguigu.springcloud.entities.Dept;


/**
 * 
 * @Description: api工程，根据已经有的DeptClientService接口

新建

一个实现了FallbackFactory接口的类DeptClientServiceFallbackFactory
 */
//@FeignClient(value = "MICROSERVICECLOUD-DEPT")
@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 List<Dept> list();

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

再新建一个类，用于服务降级的提示

package com.atguigu.springcloud.service;

import java.util.List;

import org.springframework.stereotype.Component;

import com.atguigu.springcloud.entities.Dept;

import feign.hystrix.FallbackFactory;

@Component 
public class DeptClientServiceFallbackFactory implements FallbackFactory<DeptClientService>
{
    @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 List<Dept> list()
            {
                return null;
            }

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

修改客户端的yml文件

服务降级是客户端的事，所以找到consumer-feign-80子项目，修改yml文件，添加如下内容：

feign: 
  hystrix: 
    enabled: true

测试服务降级

启动eureka集群，启动provider随意一个服务都行，启动consumer-feign-80，然后在客户端我们输入已有的数据的时候是正常的

SpringCloud笔记六：Hystrix

现在，我把provider服务关闭，只剩下eureka和consumer，再访问试试

SpringCloud笔记六：Hystrix

我访问的地址没变，很明显，我的服务降级之后是有提示的，这样客户端就知道服务降级，目前这个服务暂时关闭了，就不会去一直刷新服务，也不会去投诉了。对服务器的压力也小了。

Hystrix Dashboard

Hystrix Dashboard各种配置

Hystrix Dashboard是一个监控系统，能反映出我们的微服务调用的次数

我们新建一个项目，用来对微服务进行监控，项目名就叫：

consumer-hystrix-dashboard-9001

监控项目的yml文件，指定个端口号就行

server:
  port: 9001

项目的主方法，要加上@EnableHystrixDashboard注解

最后是Maven的pom文件，我们需要引入的相关的内容如下：

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

Hystrix Dashboard测试安装是否成功

现在可以直接运行这个监控项目，看看有没有成功的安装，运行浏览器输入

http://localhost:9001/hystrix 你会发现出来一个头戴刺帽儿的白熊logo，这就表明了，我们安装是成功了的

SpringCloud笔记六：Hystrix

Hystrix Dashboard使用

安装成功了，接下来使用Hystrix Dashboard来监控我们的服务

想要监控其他的项目，其他的项目必须有下面的引用，这个就是监控所需要的

    <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>

我们启动eureka集群，启动provider-dept-hystrix-8001，启动consumer-hystrix-dashboard