Hystrix 的隔离策略，你用哪个？

Hystrix提供了两种主要的隔离策略，用于控制服务之间的交互，以避免一个组件的故障影响到系统的其他部分。这两种策略分别是 **线程池隔离** 和 **信号量隔离**。 ### 1. 线程池隔离 (ThreadPool) 线程池隔离是Hystrix的默认隔离策略，也是在大多数场景下推荐的方式。在该策略中，每个依赖服务的调用都会在一个独立的线程中执行。每个Hystrix命令或服务依赖有专门配置的线程池。如果线程池已满，新的请求会被立即拒绝，而不会继续等待或阻塞调用线程。 **优点**： - **任务隔离**：每个服务调用都在独立线程中执行，避免了服务间的直接影响。如果一个服务变得缓慢或无响应，只会影响到同一线程池中的其他请求。 - **限制并发**：通过设置线程池大小和队列长度，可以控制并发的请求数量，避免系统过载。 **示例代码**： ```java import com.netflix.hystrix.HystrixCommand; import com.netflix.hystrix.HystrixCommandGroupKey; import com.netflix.hystrix.HystrixCommandProperties; import com.netflix.hystrix.HystrixThreadPoolProperties; public class RemoteServiceCommand extends HystrixCommand<String> { protected RemoteServiceCommand() { super(Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("HollisExampleGroup")) .andThreadPoolPropertiesDefaults(HystrixThreadPoolProperties.Setter() .withCoreSize(10) // 核心线程数 .withMaxQueueSize(5)) // 等待队列长度 .andCommandPropertiesDefaults(HystrixCommandProperties.Setter() .withExecutionTimeoutInMilliseconds(1000))); // 执行超时 } @Override protected String run() { // 远程服务调用 return "Remote service response"; } } ``` ### 2. 信号量隔离 (Semaphore) 信号量隔离使用Java的信号量来控制并发请求的数量，而不是通过线程池来隔离每个服务调用。在这种策略下，所有的请求共享同一个线程，并且通过信号量来限制并发请求的数量。如果信号量的数量已达到上限，新的请求会被直接拒绝，而不会启动新的线程。 **优点**： - **轻量级开销**：信号量不需要额外的线程切换和线程创建，因此相比线程池的隔离策略，它的开销较小，适用于非常快速且并发较高的操作。 - **适用于短时间、低延迟的服务调用**：如内存缓存访问等。 **适用场景**： - 适用于本地服务或轻量级的操作（如内存缓存、局部计算等）。 - 如果服务的延迟非常低，且不太可能导致长时间阻塞或超时，使用信号量隔离更为合适。 **示例代码**： ```java import com.netflix.hystrix.HystrixCommand; import com.netflix.hystrix.HystrixCommandGroupKey; import com.netflix.hystrix.HystrixCommandProperties; public class LocalServiceCommand extends HystrixCommand<String> { protected LocalServiceCommand() { super(Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("HollisExampleGroup")) .andCommandPropertiesDefaults(HystrixCommandProperties.Setter() .withExecutionIsolationStrategy(HystrixCommandProperties.ExecutionIsolationStrategy.SEMAPHORE) .withExecutionIsolationSemaphoreMaxConcurrentRequests(5))); // 最大并发请求数 } @Override protected String run() { // 轻量级操作，如访问本地缓存 return "Local cache response"; } } ``` ### 总结 - **线程池隔离**：适用于99%的场景，尤其是外部服务调用，尤其是那些可能会慢或失败的服务（如外部API、数据库等）。 - **信号量隔离**：适用于轻量级、低延迟的操作，如访问本地缓存等。 在大多数应用场景中，推荐使用 **线程池隔离**，因为它可以提供更强的任务隔离，避免外部服务失败对整个系统的影响。而 **信号量隔离** 主要适用于轻量级的、非常快速的操作。