- 浏览: 1030082 次
- 性别:
- 来自: 成都
文章分类
最新评论
-
繁星水:
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 4271并发数 并发数和2个因 ... -
使用Hystrix守护应用(3)
2015-01-02 22:04 12826监控HystrixCommand 除了隔离依赖服务的调用外,H ... -
使用Hystrix守护应用(2)
2014-12-30 14:35 16762接上篇(http://ningandjiao.iteye.co ... -
Mac下同时安装多个版本的JDK
2014-04-14 21:42 33120JDK8 GA之后,小伙伴们喜大普奔,纷纷跃跃欲试,想体验一下 ... -
性能测试工具之Gatling
2014-01-15 19:27 17225Gatling一直是久闻其名但 ... -
JavaMail测试工具之GreenMail
2014-01-08 19:13 7324不管现在各种Mock框架的运用有多广,我个人在写单元测试的时候 ... -
定制一个Gradle Plugin --- project-structure
2014-01-03 21:23 8414最近在项目中遇到一个 ... -
Restful Spring MVC应用的Request验证
2013-12-26 15:05 23301在开放平台的时候,尤其是坐Rest服务的时候,因为用户可以给你 ... -
Spring MVC中的异常处理
2013-12-25 13:13 24103在一个良好的Rest架构的应用中,所有的异常都应该有对应的Ht ... -
Spring 4.0升级小贴士
2013-12-22 19:40 11395随着Spring4.0的发布,很多同志估计都在考虑升级的事情了 ... -
Spring4.0给我们带来什么?
2013-12-22 17:13 44961JDK8 对JDK8的支持,这个目前来说还是探索性质,毕竟Ja ... -
RESTful API版本控制策略
2013-12-15 19:51 31607做RESTful开放平台,一方面其API变动越少, 对API调 ... -
对象转换利器之Dozer
2013-12-14 22:46 19787在Java的世界中,经常会 ... -
基于Spring-WS的Restful API的集成测试
2013-11-28 19:41 8918在很多Java企业级应用中,Spring占据了非常重要的位置, ... -
TDD Of Spring JMS
2013-11-25 19:53 1703不知何时养成了习惯,在没有一个可运行的测试的时候,个人完全没有 ... -
Micro Service工具集之Swagger:可测试的样式化API文档
2013-09-28 19:55 44658在我之前的一篇博文中,介绍了Yammer开发团队贡献的开源微服 ... -
进击的Java开发
2013-07-14 20:48 5851今天在公司的邮件组中看到一组很有趣的讨论,这是我最喜欢目前公司 ... -
说说SpringBatch的领域概念
2013-06-21 20:32 3579谈到Spring Batch,会谈到 ... -
做项目时需要考虑的安全性问题
2013-04-16 20:20 4725在开发一个项目的时候,大家经常会忽略项目的安全性问题,有很多的 ... -
使用Gradle部署jar包到Maven中央库
2013-04-12 16:15 24085Maven作为目前Java界最好的Dependency管理系统 ...
相关推荐
详细讲解了如何在Spring Cloud中使用Hystrix,如何将Hystrix整合到Feign中
spring-cloud-netflix-hystrix应用
08-Hystrix源码分析1
APM之hystrix的使用,改造老的项目,没有使用spring cloud全家桶的情况下如何使用
hystrix
• 1. 服务雪崩效应 • 2. 服务雪崩应对策略 ... 使用Hystrix预防服务雪崩 • 4. 预售中Hystrix的运用 • 5. Hystrix的实现 • 6. Hystrix的运维 • 7. 题外话: Netflix的技术栈 • 8. 题外话: 响应式编程
在公司内部做的一次分享,生产环境使用hystrix来进行调用dubbo服务的超时、熔断、重试、限流的Netflix框架
feign中包含了hystrix以及ribbon,即feign在不导入hystrix和ribbon的依赖下也能完成他们所能实现的功能,当然,如果想使用hystrix和ribbon自带的注解以及配置,必须导入依赖才可以,feign结合hystrix实现熔断+降级,...
微服务断路器hystrix应用实例java工程源码
springboot集成hystrix熔断器加入依赖 加入注解在启动类加入熔断注解使用在controller类里使用注解 @HystrixCommand(fal
spring cloud hystrix通过服务隔离、熔断、降级等手段控制依赖服务的延迟与失败。
Hystrix Dashboard的使用博文中,优化后的服务消费者和服务提供者,Hystrix Dashboard工程、Turbine工程,以及Eureka Server、父级工程的源代码
HystrixDashboard的基础使用
HystrixCommand及配置实例,亲测可用,有参数配置说明
Hystrix源码_可以跑起来Hystrix源码_可以跑起来Hystrix源码_可以跑起来Hystrix源码_可以跑起来
此应用程序演示了 PCF 和 PWS 上的 Hystrix 流问题。 使用以下命令构建应用程序: $ ./gradlew assemble 使用以下命令在本地运行应用程序(假设java在路径上): $ java -jar build/libs/hystrix-sample.jar ...
Hystrix 熔断,降级
SpringCloud -Hystrix监控面板及数据聚合(Turbine)介绍与使用示例 今天我们就将讲解下Hystrix Dashboard和Turbine.其中Hystrix Dashboard是一款针对Hystrix进行实时监控的工具,通过Hystrix Dashboard我们可以在直观...
netflix官方提供的监控hystrix-dashboard的war包,可以直接拷贝到web服务下运行,方便大家下载学习,该版本为1.5.12
Spring Cloud断路器Hystrix上文讲到我们服务间调用使用Feign——声明式Web服务客户端,在分布式系统中,一个服务很可能会调用多个其他微服务,