- 浏览: 1036552 次
- 性别:
- 来自: 成都
文章分类
最新评论
-
繁星水:
Useful!!
Object-C之(Null)与(Bool) -
pacer123:
请问注解@ApiModelProperty 在哪个jar包下面 ...
Micro Service工具集之Swagger:可测试的样式化API文档 -
sucheng2016:
这东东真的好用么/
对象转换利器之Dozer -
zzq0324:
http://git.oschina.net/zzq0324/ ...
基于Spring-WS的Restful API的集成测试 -
lrz0534:
你好,我在maven上面下载了swagger-springmv ...
Micro Service工具集之Swagger:可测试的样式化API文档
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依赖:
然后,把所有需要访问远程系统,服务和第三方库的调用都封装到HystrixCommand中,
最后,在需要调用远程服务时候,使用HystrixCommand的方法即可
运行效果如下:
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非常贴心的提供了很多工厂方法。下面就是一个涉及到上面所有配置的例子:
所以阿里后来停止了dubbo的更新。。。
难道现在用这个Hystrix了?不会吧
所以阿里后来停止了dubbo的更新。。。
在项目中使用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; } }
评论
3 楼
baungham
2016-03-15
qdujunjie 写道
powertech 写道
阿里的dubbo干的是类似的工作
所以阿里后来停止了dubbo的更新。。。
难道现在用这个Hystrix了?不会吧
2 楼
qdujunjie
2015-12-03
powertech 写道
阿里的dubbo干的是类似的工作
所以阿里后来停止了dubbo的更新。。。
1 楼
powertech
2015-02-09
阿里的dubbo干的是类似的工作
发表评论
-
关于并发的思考
2015-02-08 22:33 4339并发数 并发数和2个因 ... -
使用Hystrix守护应用(3)
2015-01-02 22:04 12876监控HystrixCommand 除了隔离依赖服务的调用外,H ... -
使用Hystrix守护应用(2)
2014-12-30 14:35 16817接上篇(http://ningandjiao.iteye.co ... -
Mac下同时安装多个版本的JDK
2014-04-14 21:42 33240JDK8 GA之后,小伙伴们喜大普奔,纷纷跃跃欲试,想体验一下 ... -
性能测试工具之Gatling
2014-01-15 19:27 17297Gatling一直是久闻其名但 ... -
JavaMail测试工具之GreenMail
2014-01-08 19:13 7367不管现在各种Mock框架的运用有多广,我个人在写单元测试的时候 ... -
定制一个Gradle Plugin --- project-structure
2014-01-03 21:23 8494最近在项目中遇到一个 ... -
Restful Spring MVC应用的Request验证
2013-12-26 15:05 23368在开放平台的时候,尤其是坐Rest服务的时候,因为用户可以给你 ... -
Spring MVC中的异常处理
2013-12-25 13:13 24166在一个良好的Rest架构的应用中,所有的异常都应该有对应的Ht ... -
Spring 4.0升级小贴士
2013-12-22 19:40 11439随着Spring4.0的发布,很多同志估计都在考虑升级的事情了 ... -
Spring4.0给我们带来什么?
2013-12-22 17:13 45031JDK8 对JDK8的支持,这个目前来说还是探索性质,毕竟Ja ... -
RESTful API版本控制策略
2013-12-15 19:51 31740做RESTful开放平台,一方面其API变动越少, 对API调 ... -
对象转换利器之Dozer
2013-12-14 22:46 19880在Java的世界中,经常会 ... -
基于Spring-WS的Restful API的集成测试
2013-11-28 19:41 9068在很多Java企业级应用中,Spring占据了非常重要的位置, ... -
TDD Of Spring JMS
2013-11-25 19:53 1760不知何时养成了习惯,在没有一个可运行的测试的时候,个人完全没有 ... -
Micro Service工具集之Swagger:可测试的样式化API文档
2013-09-28 19:55 44741在我之前的一篇博文中,介绍了Yammer开发团队贡献的开源微服 ... -
进击的Java开发
2013-07-14 20:48 5913今天在公司的邮件组中看到一组很有趣的讨论,这是我最喜欢目前公司 ... -
说说SpringBatch的领域概念
2013-06-21 20:32 3625谈到Spring Batch,会谈到 ... -
做项目时需要考虑的安全性问题
2013-04-16 20:20 4786在开发一个项目的时候,大家经常会忽略项目的安全性问题,有很多的 ... -
使用Gradle部署jar包到Maven中央库
2013-04-12 16:15 24164Maven作为目前Java界最好的Dependency管理系统 ...
相关推荐
本文将深入探讨如何在Spring Cloud项目中集成并使用Hystrix,以及如何将其与Feign客户端结合。 首先,我们需要了解Hystrix的基本原理。Hystrix通过隔离请求,防止单个服务的故障蔓延至整个系统,避免雪崩效应。断路...
4. **使用HystrixCommand**:在服务调用处使用HystrixCommand,确保服务调用被正确地封装和隔离。 5. **实现降级逻辑**:编写降级方法,当服务不可用时自动执行。 6. **集成监控**:集成Hystrix Dashboard和Turbine...
2. **线程池隔离策略**:Hystrix使用线程池来隔离命令执行,限制每个服务的并发请求量。在压力测试中,当线程池大小设置为10时,在250个并发请求下线程池已满,表明线程池设置过小。调整线程池大小至20后,250个并发...
降级逻辑可以通过HystrixCommand类中的fallbackMethod方法来指定,或者在响应式调用中使用fallback操作符。 Hystrix的入门相对简单,其提供的注解编程模型允许开发者通过极简的配置就能实现上述功能。对于开发者而...
在 `SpringCloudDemo-Hystrix` 压缩包中,通常包含了示例代码,演示了如何在 Spring Boot 应用中配置和使用 Hystrix。开发者可以通过阅读这些代码,学习如何将断路器集成到自己的服务中。 总的来说,Spring Cloud ...
1. **Hystrix 命令**: 在 Hystrix 中,服务调用被封装为命令对象,每个命令都有自己的线程池或信号量,确保在出现问题时能快速失败并进入断路器模式。 2. **断路器模式**: 当服务调用频繁失败时,断路器打开,阻止...
Spring Boot 提供了对 Hystrix 的集成,使得在 Spring Boot 应用中使用 Hystrix 变得非常方便。下面我们将详细介绍如何在 Spring Boot 项目中集成 Hystrix,并探讨不同的实现方式。 一、加入依赖 在 Maven 或 ...
1. **直接使用 Hystrix**:通过 HystrixCommand 或 HystrixObservableCommand 封装服务调用逻辑,然后配置断路器规则。 2. **通过 FeignClient**:Feign 是一个声明式的 HTTP 客户端,Spring Cloud 提供了对 Feign ...
1. **Hystrix Dashboard 功能解析**: - **实时监控**:Hystrix Dashboard 可以实时展示服务的运行情况,帮助开发者快速发现性能瓶颈和故障。 - **聚合视图**:它能将多个 Hystrix 组件的监控数据聚合在一起,提供...
Hystrix是Netflix开源的一款强大的断路器库,它适用于Java环境,并且广泛应用于Spring Cloud框架中。本教程将深入探讨如何使用Hystrix在微服务中实现断路器功能。 首先,让我们理解断路器的工作原理。断路器在正常...
本压缩包“微服务断路器hystrix应用实例java工程源码.zip”包含了一个基于Java实现的Hystrix应用实例,这个实例旨在帮助开发者理解和掌握如何在实际项目中集成和使用Hystrix。通过分析源码,我们可以深入学习以下几...
Hystrix是一个由Netflix开源的延迟和容错库,旨在隔离远程系统、服务和第三方库的访问点,停止级联失败,提供后备选项,并实现优雅降级。...这说明了使用Hystrix进行服务调用时,资源隔离与限流的重要性。
APM之hystrix的使用,改造老的项目,没有使用spring cloud全家桶的情况下如何使用
其中 `coreSize` 指定了线程池的核心线程数,`queueSizeRejectionThreshold` 设置了队列大小达到此阈值时会拒绝新任务,而 `maxQueueSize` 控制最大队列大小(若设置为 -1,则使用 SynchronousQueue;若为正整数,则...
1. **引入依赖**:在项目中添加 Hystrix Dashboard 和 Turbine 相关的 Maven 或 Gradle 依赖。 2. **配置启动类**:在启动类上添加 `@EnableHystrixDashboard` 和 `@EnableTurbine` 注解。 3. **配置文件**:配置...
【描述】提到的内容表明,这个压缩包可能包含了一个完整的示例项目,用于演示如何在Spring Cloud应用中集成和使用Hystrix Dashboard。在文章《Spring Cloud Hystrix Dashboard实战》...
1. **线程隔离**:Hystrix 将每个服务调用封装在一个单独的线程中,避免了单一服务故障导致的整个应用阻塞。 2. **熔断器模式**:当服务调用失败达到预设阈值时,Hystrix 会自动切换到熔断状态,停止进一步的服务...
"HystrixComma"可能是压缩包中的一个示例文件,它可能包含了一些Hystrix的使用代码或者配置示例。通过分析和学习这些代码,我们可以更好地理解Hystrix的用法和配置。 总结,Hystrix通过HystrixCommand实现了服务...
• 1. 服务雪崩效应 • 2. 服务雪崩应对策略 ... 使用Hystrix预防服务雪崩 • 4. 预售中Hystrix的运用 • 5. Hystrix的实现 • 6. Hystrix的运维 • 7. 题外话: Netflix的技术栈 • 8. 题外话: 响应式编程
Hystrix源码分析1 Hystrix是一个流行的熔断器工具,用于防止服务雪崩效应。它通过对方法的AOP拦截来实现熔断和降级。下面是Hystrix源码分析的主要知识点: 1. HystrixCommandAspect类 HystrixCommandAspect是...