`

使用Hystrix守护应用(1)

 
阅读更多
Hystrix(https://github.com/Netflix/Hystrix)是Netflix(https://www.netflix.com/global)的一个开源项目,主要作用是通过控制那些访问远程系统、服务和第三方库的节点,从而对延迟和故障提供更强大的容错能力。 其可以看做是Netflix团队对分布式系统运维的各种理念和实践的总结。值得一提的是在ThoughtWorks最新的Tech Radar 2014(http://www.thoughtworks.com/radar/#/tools)中,Hystrix的评级已从评估(Assess)上升到试用(Trial),即其已经完善到可以在产品环境中试用了,相信会有越来越多的公司采用该类库来提升自己系统的容错能力,我所在的部门刚刚把Hystrix加入了工具箱,并已在某几个项目中实践了Hystrix。

在项目中使用Hystrix
Hystrix本质上是一个基于JVM的类库,Netflix团队已经把其发布到Maven中央库中,因此只要你的项目是基于JVM的,那么在项目中使用Hystrix就非常容易了。本文中将以Gradle为构建脚本的Spring MVC Web项目为例(代码已托管到github:https://github.com/xianlinbox/HystrixDemo),在该示例项目中,构建了一个Customer Service,该customer service会依赖另外的2个web service(Contact Service和Address Service, 示例中我使用moco(https://github.com/dreamhead/moco)模拟了这2个服务)。如下图:

在Customer Service模块中使用Hystrix把对Contact Service和Address Service的依赖隔离开,可以防止一个服务的故障影响到另外一个服务。

首先,为项目添加Hystrix依赖:
'com.netflix.hystrix:hystrix-core:1.3.8',

然后,把所有需要访问远程系统,服务和第三方库的调用都封装到HystrixCommand中,
public class AddressHystrixCommand extends HystrixCommand<Address> {
    private Logger logger = LoggerFactory.getLogger(AddressHystrixCommand.class);
    private String customerId;

    public AddressHystrixCommand(String customerId) {
        super(HystrixCommandGroupKey.Factory.asKey("Address"));
        this.customerId = customerId;
    }

    @Override
    public Address run() throws Exception {
        logger.info("Get address for customer {}", customerId);
        String response = Request.Get("http://localhost:9090/customer/" + customerId + "/address")
                .connectTimeout(1000)
                .socketTimeout(1000)
                .execute()
                .returnContent()
                .asString();

        return new ObjectMapper().readValue(response, Address.class);
    }
}

public class ContactHystrixCommand extends HystrixCommand<Contact> {
    private Logger logger = LoggerFactory.getLogger(ContactHystrixCommand.class);
    private String customerId;

    public ContactHystrixCommand(String customerId) {
        super(HystrixCommandGroupKey.Factory.asKey("Contact"));
        this.customerId = customerId;
    }

    @Override
    public Contact run() throws Exception {
        logger.info("Get contact for customer {}", customerId);
        String response = Request.Get("http://localhost:9090/customer/" + customerId + "/contact")
                .connectTimeout(1000)
                .socketTimeout(1000)
                .execute()
                .returnContent()
                .asString();

        return new ObjectMapper().readValue(response, Contact.class);
    }
}

最后,在需要调用远程服务时候,使用HystrixCommand的方法即可
customer.setContact(new ContactHystrixCommand(customerId).execute());
customer.setAddress(new AddressHystrixCommand(customerId).execute());

运行效果如下:
21:01:11.117 [373380609@qtp-1421210709-0] INFO  c.x.h.s.CustomerService - Get Customer 1234
21:01:11.163 [373380609@qtp-1421210709-0] WARN  c.n.c.s.URLConfigurationSource - No URLs will be polled as dynamic configuration sources.
21:01:11.207 [hystrix-Contact-1] INFO  c.x.h.d.ContactHystrixCommand - Get contact for customer 1234
21:01:11.378 [hystrix-Address-1] INFO  c.x.h.d.AddressHystrixCommand - Get address for customer 1234

从日志中,我们可以看到HystrixCommand封装的服务分别运行在单独的线程中。上面只是最简单的Hystrix用法,Netflix在Hystrix中加入了非常细致的配置和灵活的使用方法,以帮助用户灵活的得到自己想要的控制效果。下面就来看一看具体有哪些配置和用法。

配置HystrixCommand
HystxixCommand支持如下的配置:
GroupKey:该命令属于哪一个组,可以帮助我们更好的组织命令。
CommandKey:该命令的名称
ThreadPoolKey:该命令所属线程池的名称,同样配置的命令会共享同一线程池,若不配置,会默认使用GroupKey作为线程池名称。
CommandProperties:该命令的一些设置,包括断路器的配置,隔离策略,降级设置,以及一些监控指标等。
ThreadPoolProerties:关于线程池的配置,包括线程池大小,排队队列的大小等。

为了方便大家的配置,Hystrix非常贴心的提供了很多工厂方法。下面就是一个涉及到上面所有配置的例子:
public class EchoCommand extends HystrixCommand<String> {
    private String input;

    protected EchoCommand(String input) {
        super(Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("EchoGroup"))
                .andCommandKey(HystrixCommandKey.Factory.asKey("Echo"))
                .andThreadPoolKey(HystrixThreadPoolKey.Factory.asKey("EchoThreadPool"))
                .andCommandPropertiesDefaults(HystrixCommandProperties.Setter()
                        .withExecutionIsolationStrategy(HystrixCommandProperties.ExecutionIsolationStrategy.THREAD))
                .andThreadPoolPropertiesDefaults(HystrixThreadPoolProperties.Setter()
                        .withCoreSize(10))
        );
        this.input = input;
    }

    @Override
    protected String run() throws Exception {
        return "Echo: " + input;
    }	
}

  • 大小: 39.9 KB
4
0
分享到:
评论
3 楼 baungham 2016-03-15  
qdujunjie 写道
powertech 写道
阿里的dubbo干的是类似的工作


所以阿里后来停止了dubbo的更新。。。

难道现在用这个Hystrix了?不会吧
2 楼 qdujunjie 2015-12-03  
powertech 写道
阿里的dubbo干的是类似的工作


所以阿里后来停止了dubbo的更新。。。
1 楼 powertech 2015-02-09  
阿里的dubbo干的是类似的工作

相关推荐

    15.Spring Cloud中使用Hystrix

    本文将深入探讨如何在Spring Cloud项目中集成并使用Hystrix,以及如何将其与Feign客户端结合。 首先,我们需要了解Hystrix的基本原理。Hystrix通过隔离请求,防止单个服务的故障蔓延至整个系统,避免雪崩效应。断路...

    spring-cloud-netflix-hystrix应用

    4. **使用HystrixCommand**:在服务调用处使用HystrixCommand,确保服务调用被正确地封装和隔离。 5. **实现降级逻辑**:编写降级方法,当服务不可用时自动执行。 6. **集成监控**:集成Hystrix Dashboard和Turbine...

    Hystrix是如何保护应用验证1

    2. **线程池隔离策略**:Hystrix使用线程池来隔离命令执行,限制每个服务的并发请求量。在压力测试中,当线程池大小设置为10时,在250个并发请求下线程池已满,表明线程池设置过小。调整线程池大小至20后,250个并发...

    spring cloud hystrix原理介绍及使用

    降级逻辑可以通过HystrixCommand类中的fallbackMethod方法来指定,或者在响应式调用中使用fallback操作符。 Hystrix的入门相对简单,其提供的注解编程模型允许开发者通过极简的配置就能实现上述功能。对于开发者而...

    springcloud hystrix 断路由

    在 `SpringCloudDemo-Hystrix` 压缩包中,通常包含了示例代码,演示了如何在 Spring Boot 应用中配置和使用 Hystrix。开发者可以通过阅读这些代码,学习如何将断路器集成到自己的服务中。 总的来说,Spring Cloud ...

    Hystrix Dashboard的使用-代码部分.zip

    1. **Hystrix 命令**: 在 Hystrix 中,服务调用被封装为命令对象,每个命令都有自己的线程池或信号量,确保在出现问题时能快速失败并进入断路器模式。 2. **断路器模式**: 当服务调用频繁失败时,断路器打开,阻止...

    springboot集成hystrix1

    Spring Boot 提供了对 Hystrix 的集成,使得在 Spring Boot 应用中使用 Hystrix 变得非常方便。下面我们将详细介绍如何在 Spring Boot 项目中集成 Hystrix,并探讨不同的实现方式。 一、加入依赖 在 Maven 或 ...

    25-Spring Cloud断路器Hystrix1

    1. **直接使用 Hystrix**:通过 HystrixCommand 或 HystrixObservableCommand 封装服务调用逻辑,然后配置断路器规则。 2. **通过 FeignClient**:Feign 是一个声明式的 HTTP 客户端,Spring Cloud 提供了对 Feign ...

    hystrix-dashboar1.5.12

    1. **Hystrix Dashboard 功能解析**: - **实时监控**:Hystrix Dashboard 可以实时展示服务的运行情况,帮助开发者快速发现性能瓶颈和故障。 - **聚合视图**:它能将多个 Hystrix 组件的监控数据聚合在一起,提供...

    断路器hystrix实现.rar

    Hystrix是Netflix开源的一款强大的断路器库,它适用于Java环境,并且广泛应用于Spring Cloud框架中。本教程将深入探讨如何使用Hystrix在微服务中实现断路器功能。 首先,让我们理解断路器的工作原理。断路器在正常...

    微服务断路器hystrix应用实例java工程源码.zip

    本压缩包“微服务断路器hystrix应用实例java工程源码.zip”包含了一个基于Java实现的Hystrix应用实例,这个实例旨在帮助开发者理解和掌握如何在实际项目中集成和使用Hystrix。通过分析源码,我们可以深入学习以下几...

    hystrix公司内部分享ppt

    Hystrix是一个由Netflix开源的延迟和容错库,旨在隔离远程系统、服务和第三方库的访问点,停止级联失败,提供后备选项,并实现优雅降级。...这说明了使用Hystrix进行服务调用时,资源隔离与限流的重要性。

    APM之hystrix的使用

    APM之hystrix的使用,改造老的项目,没有使用spring cloud全家桶的情况下如何使用

    hystrix简介

    其中 `coreSize` 指定了线程池的核心线程数,`queueSizeRejectionThreshold` 设置了队列大小达到此阈值时会拒绝新任务,而 `maxQueueSize` 控制最大队列大小(若设置为 -1,则使用 SynchronousQueue;若为正整数,则...

    SpringCloud -Hystrix监控面板及数据聚合(Turbine)介绍与使用示例

    1. **引入依赖**:在项目中添加 Hystrix Dashboard 和 Turbine 相关的 Maven 或 Gradle 依赖。 2. **配置启动类**:在启动类上添加 `@EnableHystrixDashboard` 和 `@EnableTurbine` 注解。 3. **配置文件**:配置...

    hystrix-dashboard.zip

    【描述】提到的内容表明,这个压缩包可能包含了一个完整的示例项目,用于演示如何在Spring Cloud应用中集成和使用Hystrix Dashboard。在文章《Spring Cloud Hystrix Dashboard实战》...

    Hystrix-dashboard+turbine-web+说明文档

    1. **线程隔离**:Hystrix 将每个服务调用封装在一个单独的线程中,避免了单一服务故障导致的整个应用阻塞。 2. **熔断器模式**:当服务调用失败达到预设阈值时,Hystrix 会自动切换到熔断状态,停止进一步的服务...

    Hystrix 熔断、降级实例

    "HystrixComma"可能是压缩包中的一个示例文件,它可能包含了一些Hystrix的使用代码或者配置示例。通过分析和学习这些代码,我们可以更好地理解Hystrix的用法和配置。 总结,Hystrix通过HystrixCommand实现了服务...

    熔断器Hystrix的使用与原理.pdf

    • 1. 服务雪崩效应 • 2. 服务雪崩应对策略 ... 使用Hystrix预防服务雪崩 • 4. 预售中Hystrix的运用 • 5. Hystrix的实现 • 6. Hystrix的运维 • 7. 题外话: Netflix的技术栈 • 8. 题外话: 响应式编程

    08-Hystrix源码分析1

    Hystrix源码分析1 Hystrix是一个流行的熔断器工具,用于防止服务雪崩效应。它通过对方法的AOP拦截来实现熔断和降级。下面是Hystrix源码分析的主要知识点: 1. HystrixCommandAspect类 HystrixCommandAspect是...

Global site tag (gtag.js) - Google Analytics