Hystrix入门

2018-02-02  本文已影响697人  1angxi
Hystrix Logo

1.Hystrix是什么?

hystrix对应的中文名字是“豪猪”，豪猪周身长满了刺，能保护自己不受天敌的伤害，代表了一种防御机制，这与hystrix本身的功能不谋而合，因此Netflix团队将该框架命名为Hystrix，并使用了对应的卡通形象做作为logo。

在一个分布式系统里，许多依赖不可避免的会调用失败，比如超时、异常等，如何能够保证在一个依赖出问题的情况下，不会导致整体服务失败，这个就是Hystrix需要做的事情。Hystrix提供了熔断、隔离、Fallback、cache、监控等功能，能够在一个、或多个依赖同时出现问题时保证系统依然可用。

2.用一个例子快速进入Hystrix

Hystrix的核心功能，就是在调用远程服务时的熔断机制。下面用一个简单的例子来说明Hystrix的核心功能。

1.例子基于spring-boot，所以首先新建一个空的spring-boot项目。建项目的过程此处略过。

2.添加maven依赖:

<dependency>
    <groupId>com.netflix.hystrix</groupId>
    <artifactId>hystrix-core</artifactId>
    <version>1.5.9</version>
</dependency>

<dependency>
    <groupId>com.netflix.hystrix</groupId>
    <artifactId>hystrix-metrics-event-stream</artifactId>
    <version>1.5.9</version>
</dependency>

<dependency>
    <groupId>com.netflix.hystrix</groupId>
    <artifactId>hystrix-javanica</artifactId>
    <version>1.5.9</version>
</dependency>

3.新建configuration类

package com.mogujie.marketing.hystrixTest.configuration;

import com.netflix.hystrix.contrib.javanica.aop.aspectj.HystrixCommandAspect;
import com.netflix.hystrix.contrib.metrics.eventstream.HystrixMetricsStreamServlet;
import org.springframework.boot.web.servlet.ServletRegistrationBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class HystrixConfiguration {
    @Bean
    public HystrixCommandAspect hystrixAspect() {
        return new HystrixCommandAspect();
    }

    @Bean
    public ServletRegistrationBean hystrixMetricsStreamServlet() {
        ServletRegistrationBean registration = new ServletRegistrationBean(new HystrixMetricsStreamServlet());
        registration.addUrlMappings("/hystrix.stream");
        return registration;
    }
}

4.新建RemoteService，代表依赖的远程服务。

package com.mogujie.marketing.hystrixTest.service;

import org.springframework.stereotype.Service;

@Service("remoteService")
public class RemoteService {

    public Object getUser() {
        Thread.sleep(2500);
        return "user";
    }
}

5.新建UserController，调用远程服务。

package com.mogujie.marketing.hystrixTest.controller;

import com.mogujie.marketing.hystrixTest.service.RemoteService;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixProperty;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping({"/test"})
public class UserController {

    @Autowired
    private RemoteService remoteService;

    @RequestMapping(value = "/user")
    @HystrixCommand(fallbackMethod = "fallback", threadPoolProperties = {
            @HystrixProperty(name = "coreSize", value = "30"), @HystrixProperty(name = "maxQueueSize", value = "100"),
            @HystrixProperty(name = "queueSizeRejectionThreshold", value = "20")}, commandProperties = {
            @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "3000"),
            @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold", value = "1")

    })
    public Object getUser() throws InterruptedException {
        Object user = remoteService.getUser();
        return user;
    }

    public Object fallback(Throwable e) {
        e.printStackTrace();
        return "test";
    }
}

6.浏览器调用http://127.0.0.1/test/user可以看到正常返回的结果。调整Thread.sleep的时间为3000，可以看到fallback函数返回的结果。

从上面的例子可以快速体会到Hystrix给远程服务调用带来的好处，只需要简单的配置一个注解，就能给远程服务加上超时时间&错误回调。

Hystrix可以支持RPC、DB、HTTP等远程服务的超时&错误回调，甚至可以做本地服务的超时&错误回调。刚刚的例子就是模拟本地服务执行超时的情况。

一般来说，RPC框架都有基本的超时机制，但是错误处理和功能降级往往要自己来实现，Hystrix帮我省略了这部分冗余的代码，只需要写一个回调函数，简单配置一下就完工了。

3.Hystrix的配置项

那Hystrix有哪些配置项？那些配置项又支持哪些功能？这些功能又在什么情况下被用到呢？解决这些问题是Hystrix进阶的关键。

3.1 Hystrix有哪些配置项?

官方配置项地址:配置项详解.

Execution 执行

Fallback 降级

Circuit Breaker 熔断器

Metrics 度量

Request Context 请求上下文

Collapser Properties 压缩器属性

Thread Pool Properties 线程池参数

3.2 Hystrix配置解析

4. 实现原理

Hystrix实现了熔断机制、请求超时、限流降级、结果缓存、请求合并、统计、线程池隔离等功能共同保障应用的稳定性。

先来看看官方的流程图：


Flow Chart

分为以下步骤：

1.初始化HystrixCommand
2.执行Command
3.是否需要走缓存获取结果？
4.是否已经开启了熔断？
5.信号量/线程池拒绝请求？
6.实际执行方法
7.上报结果判断是否开启熔断
8.执行失败走降级方法
9.执行成功结果返回

处理执行成功结果时使用了RxJava(观察者模式)来传递事件，流程如下图所示：


执行结果返回

参考文献

1.在项目中快速加入Netflix Hystrix特性
2.Hystrix入门指南
3.Hystrix配置简单说明（官方文档简译）
4.微服务（二）hystrix
5.Hystrix系列-5-Hystrix的资源隔离策略
6.通过HystrixCollapser合并请求提高应用吞吐量
7.How it Works

上一篇 下一篇

猜你喜欢

热点阅读