Spring Cloud之Hystrix

　　在微服务架构中，存在那么多的服务单元，若一个单元出现故障（由于网络原因或者自身原因），就很容易因依赖关系而引发故障的蔓延，最终导致整个系统的瘫痪，这样的架构相较传统架构更加不稳定。为了解决这样的问题，产生了断路器等一系列的服务保护机制。（A服务调用B服务，B服务由于自身处理逻辑等原因造成响应缓慢，会导致A服务线程被挂起，以等待B服务执行，在高并发情况下，这些挂起的线程会导致后面调用A服务的请求被阻塞，最终导致A服务也不可用）。

　　加入断路器后，当服务不可用时，通过断路器的故障监控，会直接执行回调函数，直接返回一串字符串，而不是等待响应超时，这样就不会使得线程调用故障服务被长时间占用不释放，从而避免了故障在分布式系统中的蔓延。

　　　　本节内容在上节内容基础上，阅读此节之前，先看上节Spring Cloud之Eureka、Ribbon

一、无断路器示例

　　启动上节的eureka-server、service-hello（8081/8082）、ribbon-consumer工程

　　在未加入断路器之前，关闭8081实例，发送GET请求到http://localhost:9000/ribbon-consumer，轮询8081/8082，当轮询到8081后（因为8081实例被关）会得到下面输出：

二、加入断路器示例

　　在ribbon-consumer工程的pom.xml引入下面依赖

        <dependency>

            <groupId>org.springframework.cloud</groupId>

            <artifactId>spring-cloud-starter-hystrix</artifactId>

        </dependency>

　　在ribbon-consumer工程的 主类ConsumerApplication中使用@EnableCircuitBreaker注解开启断路器功能

package com.stonegeek;

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.client.loadbalancer.LoadBalanced;

import org.springframework.context.annotation.Bean;

import org.springframework.web.client.RestTemplate;

/**

 * Created by StoneGeek on 2018/5/28.

 * 博客地址：http://www.cnblogs.com/sxkgeek

 */

@EnableCircuitBreaker

@EnableDiscoveryClient

@SpringBootApplication

public class RibbonConsumerApplication {

    @Bean

    @LoadBalanced

    RestTemplate restTemplate(){

        return new RestTemplate();

    }

    public static void main(String[] args) {

        SpringApplication.run(RibbonConsumerApplication.class, args);

    }

}

　　改造服务消费方式，新增HelloService类，注入RestTemplate实例，然后将在ConsumerController中对RestTemplate的使用迁移到helloService函数中，最后，在helloService函数上增加@HystrixCommand注解来指定回调方法：

package com.stonegeek.service;

import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Service;

import org.springframework.web.client.RestTemplate;

import java.util.logging.Logger;

/**

 * Created by StoneGeek on 2018/5/29.

 * 博客地址：http://www.cnblogs.com/sxkgeek

 */

@Service

public class HelloService {

    private final Logger logger =Logger.getLogger(String.valueOf(getClass()));

    @Autowired

    RestTemplate restTemplate;

    @HystrixCommand(fallbackMethod = "helloFallback")

    public String helloService(){

        //加logger更清晰的看出执行时间

        long start =System.currentTimeMillis();

        String result=restTemplate.getForEntity("http://SERVICE-HELLO/hello",String.class).getBody();

        long end=System.currentTimeMillis();

        logger.info("Spend time:"+(end-start));

        return result;

    }

    public String helloFallback(){

        return "error";

    }

}

　　修改RibbonConsumerApplication.class

package com.stonegeek.controller;

import com.stonegeek.service.HelloService;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import org.springframework.web.bind.annotation.RestController;

import org.springframework.web.client.RestTemplate;

/**

 * Created by StoneGeek on 2018/5/28.

 * 博客地址：http://www.cnblogs.com/sxkgeek

 */

@RestController

public class ConsumerController {

    /**

     * @Author: StoneGeek

     * @Date: 2018/5/29

     * @Description:之前不加断路器代码

     */

//    @Autowired

//    RestTemplate restTemplate;

//

//    @RequestMapping(value = "/ribbon-consumer",method = RequestMethod.GET)

//    public String helloConsumer(){

//        return restTemplate.getForEntity("http://SERVICE-HELLO/hello",String.class).getBody();

//    }

    /**

     * @Author: StoneGeek

     * @Date: 2018/5/29

     * @Description: 加了断路器代码

     */

    @Autowired

    HelloService helloService;

    @RequestMapping(value = "/ribbon-consumer",method = RequestMethod.GET)

    public String helloConsumer(){

        return helloService.helloService();

    }

}

　　此时重新来验证一下断路器实现的服务回调逻辑，此时断开8081实例，当服务消费者轮询到8081时，不再是之前的错误内容，Hystrix服务回调生效

三、模拟服务阻塞来验证断路器回调

　　Hystrix默认超时时间是2000毫秒

　　我们对service-hello的/hello接口做一些修改（重点是Thread.sleep()函数的使用）：

package com.stonegeek.controller;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.cloud.client.ServiceInstance;

import org.springframework.cloud.client.discovery.DiscoveryClient;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import org.springframework.web.bind.annotation.RestController;

import java.util.ArrayList;

import java.util.List;

import java.util.Random;

import java.util.logging.Logger;

/**

 * Created by StoneGeek on 2018/5/27.

 * 博客地址：http://www.cnblogs.com/sxkgeek

 */

@RestController

public class HelloController {

    private final Logger logger =Logger.getLogger(String.valueOf(getClass()));

    @Autowired

    private DiscoveryClient client;

    /**

     * @Author: StoneGeek

     * @Date: 2018/5/29

     * @Description:不加线服务塞的代码

     */

//    @RequestMapping(value = "hello",method = RequestMethod.GET)

//    public String  index(){

//        ServiceInstance instance=client.getLocalServiceInstance();

//        logger.info("/hello, host:"+instance.getHost()+", service_id:"+instance.getServiceId()+"service_port:"+instance.getPort());

//        return "hello world ";

//    }

    /**

     * @Author: StoneGeek

     * @Date: 2018/5/29

     * @Description: 加了Thread.sleep(3000)的服务阻塞代码，由于Hystrix默认超时时间为2000毫秒，

     * 所以这里采用了0至3000的随机数以让处理过程有一定概率发生超时来触发断路器

     */

    @RequestMapping(value = "/hello",method = RequestMethod.GET)

    public String  index() throws InterruptedException {

        ServiceInstance instance=client.getLocalServiceInstance();

        int sleepTime=new Random().nextInt();

        logger.info("sleepTime:"+sleepTime);

        Thread.sleep(sleepTime);

        logger.info("sleepTime:"+sleepTime+"/hello, host:"+instance.getHost()+", service_id:"+instance.getServiceId()+"service_port:"+instance.getPort());

        return "hello world ";

    }

}

　　　重新启动service-hello和ribbon-consumer模块，连续访问http://localhost:9000/ribbon-consumer几次，当RIBBON-CONSUMER的控制台输出的Spend time大于2000的时候，网页就会返回error，即服务消费者因调用的服务超时从而触发熔断请求，并调用回调逻辑返回结果

　　此时Spring Could Hystrix的断路器就配置完成了！！！