- 当前位置：首页 >系统运维 >隔离术之使用Hystrix实现隔离
隔离术之使用Hystrix实现隔离
发布时间：2025-11-05 13:32:01 来源：码上建站 作者：IT科技类资讯
1. Hystrix简介
Hystrix是隔离Netflix开源的一款针对分布式系统的延迟和容错库，目的术之使用x实是用来隔离分布式服务故障。它提供线程和信号量隔离，现隔以减少不同服务之间资源竞争带来的隔离相互影响;提供优雅降级机制;提供熔断机制使得服务可以快速失败，而不是术之使用x实一直阻塞等待服务响应，并能从中快速恢复。现隔Hystrix通过这些机制来阻止级联失败并保证系统弹性、隔离可用。术之使用x实下图是现隔一个典型的分布式服务实现。
首先，隔离当大多数人在使用Tomcat时，术之使用x实多个HTTP服务会共享一个线程池，现隔假设其中一个HTTP服务访问的隔离数据库响应非常慢，这将造成服务响应时间延迟增加，术之使用x实大多数线程阻塞等待数据响应返回，现隔导致整个Tomcat线程池都被该服务占用，甚至拖垮整个Tomcat。因此，如果我们能把不同HTTP服务隔离到不同的线程池，则某个HTTP服务的线程池满了也不会对其他服务造成灾难性故障。这就需要线程隔离或者信号量隔离来实现了。
使用线程隔离或信号隔离的网站模板目的是为不同的服务分配一定的资源，当自己的资源用完，直接返回失败而不是占用别人的资源。
同理，如“HTTP服务1”和“HTTP服务2”要分别访问远程的“分布式服务A”和“分布式服务B”，假设它们共享线程池，那么其中一个服务在出现问题时也会影响到另一个服务，因此，我们需要进行访问隔离，可以通过Hystrix的线程池隔离或信号量隔离来实现。
其次，“分布式服务B”依赖了“分布式服务D”和“分布式服务E”，其中“分布式服务D”是一个可降级的服务，意思是出现故障时(如超时、网络故障)可以暂时屏蔽掉或者返回缓存脏数据，如访问商品详情页时，可以暂时屏蔽掉上边的商家信息，不会影响用户下单流程。
当我们依赖的服务访问超时时，企商汇要提供降级策略。比如，返回托底数据阻止级联故障。当因为一些故障(如网络故障)使得服务可用率下降时，要能及时熔断，一是快速失败，二是可以保护远程分布式服务。
到此我们大体了解了Hystrix是用来解决什么问题的。
限制调用分布式服务的资源使用，某一个调用的服务出现问题不会影响其他服务调用，通过线程池隔离和信号量隔离实现。 Hystrix提供了优雅降级机制：超时降级、资源不足时(线程或信号量)降级，降级后可以配合降级接口返回托底数据。 Hystrix也提供了熔断器实现，当失败率达到阀值自动触发降级(如因网络故障/超时造成的失败率高)，熔断器触发的快速失败会进行快速恢复。 还提供了请求缓存、请求合并实现。接下来，我们来看下如何使用Hystrix，本书使用的版本是Hystrix- 1.5.6。
2. 隔离示例
以线程池隔离为示例，亿华云计算会为不同的服务设置不同的线程池，从而实现相互隔离。
为不同的HTTP服务设置不同的线程池，为不同的分布式服务调用设置不同的线程池。
假设我们现在要调用一个获取库存服务，通过封装一个命令GetStockServiceCommand来实现。
public class GetStockServiceCommand extends HystrixCommand<String> { private StockService stockService; public GetStockServiceCommand() { super(setter()); } private static Setter setter() { //服务分组 HystrixCommandGroupKey groupKey = HystrixCommandGroupKey.Factory. asKey("stock"); //服务标识 HystrixCommandKey commandKey =HystrixCommandKey.Factory. asKey("getStock"); //线程池名称 HystrixThreadPoolKey threadPoolKey = HystrixThreadPoolKey.Factory. asKey("stock-pool"); //线程池配置 HystrixThreadPoolProperties.Setter threadPoolProperties =HystrixThreadPoolProperties.Setter threadPoolProperties =HystrixThreadPoolProperties.Setter() .withCoreSize(10) .withKeepAliveTimeMinutes(5) .withMaxQueueSize(Integer.MAX_VALUE) .withQueueSizeRejectionThreshold(10000); //命令属性配置 HystrixCommandProperties.Setter commandProperties = HystrixCommandProperties.Setter() .withExecutionIsolationStrategy(HystrixCommandProperties.ExecutionIsolationStrategy.THREAD); return HystrixCommand.Setter .withGroupKey(groupKey) .andCommandKey(commandKey) .andThreadPoolKey(threadPoolKey) .andThreadPoolPropertiesDefaults(threadPoolProperties) .andCommandPropertiesDefaults(commandProperties); } @Override protectedString run() throws Exception { return stockService.getStock(); } }几个重要组件如下。
HystrixCommandGroupKey：配置全局唯一标识服务分组的名称，比如，库存系统就是一个服务分组。当我们监控时，相同分组的服务会聚合在一起，必填选项。 HystrixCommandKey：配置全局唯一标识服务的名称，比如，库存系统有一个获取库存服务，那么就可以为这个服务起一个名字来唯一识别该服务，如果不配置，则默认是简单类名。 HystrixThreadPoolKey：配置全局唯一标识线程池的名称，相同线程池名称的线程池是同一个，如果不配置，则默认是分组名，此名字也是线程池中线程名字的前缀。 HystrixThreadPoolProperties：配置线程池参数，coreSize配置核心线程池大小和线程池***大小，keepAliveTimeMinutes是线程池中空闲线程生存时间(如果不进行动态配置，那么是没有任何作用的)，maxQueueSize配置线程池队列***大小，queueSizeRejectionThreshold限定当前队列大小，即实际队列大小由这个参数决定，通过改变queueSizeRejectionThreshold可以实现动态队列大小调整。 HystrixCommandProperties：配置该命令的一些参数，如executionIsolationStrategy配置执行隔离策略，默认是使用线程隔离，此处我们配置为THREAD，即线程池隔离。此处可以粗粒度实现隔离，也可以细粒度实现隔离，如下所示。
服务分组+线程池：粗粒度实现，一个服务分组/系统配置一个隔离线程池即可，不配置线程池名称或者相同分组的线程池名称配置为一样。 服务分组+服务+线程池：细粒度实现，一个服务分组中的每一个服务配置一个隔离线程池，为不同的命令实现配置不同的线程池名称即可。 混合实现：一个服务分组配置一个隔离线程池，然后对重要服务单独设置隔离线程池。如上配置是在应用启动时就配置好了，在实际运行过程中，我们可能随时调整其中一些参数，如线程池大小、队列大小，此时，可以使用如下方式进行动态配置。
String dynamicQueueSizeRejectionThreshold = "hystrix.threadpool."+ "stock-pool" + ".queueSizeRejectionThreshold"; Configuration configuration = ConfigurationManager.getConfigInstance(); configuration.setProperty(dynamicQueueSizeRejectionThreshold,100);如果是改变线程池配置，则是"hystrix.threadpool."+ threadPoolKey + propertyName;如果是改变命令属性配置，则是"hystrix.command." + commandKey + propertyName。
接下来就可以通过如下方式创建命令。
GetStockServiceCommand command = new GetStockServiceCommand(newStockService());然后通过如下方式同步调用。
String result = command.execute();或者返回Future从而实现异步调用。
Future<String> future = command.queue();或者配合RxJava实现响应式编程。
Observable<String> observe =command.observe(); observe.asObservable().subscribe((result) -> { System.out.println(result); });在应用Hystrix时，首先需要把服务封装成HystrixCommand，即命令模式实现，然后就可以通过同步/异步/响应式模式来调用服务。
信号量隔离通过如下配置即可。
HystrixCommandProperties.Setter commandProperties= HystrixCommandProperties.Setter() .withExecutionIsolationStrategy(HystrixCommandProperties.ExecutionIsolationStrategy.SEMAPHORE) .withExecutionIsolationSemaphoreMaxConcurrentRequests(50);信号量隔离只是限制了总的并发数，服务使用主线程进行同步调用，即没有线程池。因此，如果只是想限制某个服务的总并发调用量或者调用的服务不涉及远程调用的话，可以使用轻量级的信号量来实现。
GetStockServiceCommand不是单例，不能重用，必须每次使用创建一个。如果觉得Hystrix太麻烦或者太重，则可以参考Hystrix思路设计自己的组件。
【本文是专栏作者张开涛的原创文章，作者微信公众号：开涛的博客( kaitao-1234567)】
戳这里，看该作者更多好文
- 电脑接线错误的危害及防范措施（避免接线错误，保护电脑正常运行）
- MySQL数据库备份的一些小妙招
- MySQL数据库的更新语句DELETE与TRUNCATE TABLE
- MySQL root 密码破解好用方案介绍
- windows之外的世界比想像中要大得多呢，几乎天天都在用ssh，却到今天才知道有sshfs这个好东西，前几天还在为ZendStudio可以远程编辑文件欣喜，惭愧啊，终于有比vi scp://hostname//path/to/file更方便的方式了。sshfs，就是可以把ssh连接到的主机资源，映射到本机的文件系统当中，然后用户可以像操作本地文件一样操作，而实际的文件改动将通过ssh传输到远程主机当中。类似于mount了一个windows共享目录，或者另外一台linux主机的samba共享，或者是nfs共享，只是“共享协议”变成了ssh通道罢了。ubuntu源中已经包含了sshfs了，以及所需的fuse包，直接apt安装就可以了，一共是三个包：“fuse-utils libfuse2 sshfs”，不大，加起来才179k。安装的时候会自动创建用户组fuse，要使用sshfs的用户需要先加到这个用户组里才行（记得完成后还要重新登录），不然会没有权限执行fusermount：fuse: failed to exec fusermount: Permission denied复制代码代码如下:复制代码代码如下:复制代码代码如下:sudo umount ~/remote_folder这个简单的命令会断开远程连接同时清空 remote_folder 目录。总结在 Linux 上有很多工具可以用于访问远程文件并挂载到本地。但是如之前所说，假如有的话，也只有很少的工具能充分利用 SSH 的强大功能。我希望在这篇指南的帮助下，也能认识到 SSHfs 是一个多么强大的工具。
- 切换淘宝最新镜像源npm
- MySQL触发器的创建与删除
- MySQL 数据库中记录不存在时如何运行？
- Hkc质量如何？探究hkc产品的质量表现（hkc质量分析，解读关键指标、用户评价与市场表现）
- 常用MySQL命令的大汇总
随便看看
- Copyright © 2025 Powered by 隔离术之使用Hystrix实现隔离,码上建站 滇ICP备2023006006号-47sitemap