Spring Cloud Hystrix 服务降级限流策略详解

什么是 Hystrix

Hystrix 是 Netflix 开源的一个容错框架，用于处理分布式系统中的延迟和容错问题。它实现了断路器模式，是微服务架构中的重要组件。

通过 Hystrix，可以对服务调用进行隔离、限流、降级和熔断处理。

服务降级

当我们系统的某个服务出现故障或响应时间过长时，为了避免资源被耗尽，我们需要对该服务进行降级处理，即提供一个简化版的服务或返回默认值。

通过 Hystrix，我们可以对服务进行降级处理，当服务出现故障或响应时间过长时，Hystrix 会返回预设的降级响应或默认值。

@Service
public class UserServiceImpl implements UserService {

    @Override
    @HystrixCommand(fallbackMethod = "getUserByIdFallback")
    public User getUserById(Long id) {
        // 正常服务调用
    }

    private User getUserByIdFallback(Long id) {
        // 降级处理
    }
}

在上述例子中，通过 @HystrixCommand 注解的 fallbackMethod 属性，指定了服务降级时要调用的方法。

服务限流

当服务出现故障或资源短缺时，我们需要对服务进行限流，以避免过多的请求导致系统崩溃。常见的限流方法有令牌桶和漏桶算法。

通过 Hystrix，我们可以使用令牌桶算法对服务进行限流处理。令牌桶算法中，令牌桶随时间周期性地增加令牌，当请求到达时，如果有令牌，就可以通过，否则就被拒绝。

hystrix:
  threadpool:
    default:
      coreSize: 10
      maxQueueSize: 20
  command:
    default:
      execution:
        isolation:
          strategy: SEMAPHORE
          semaphore:
            maxConcurrentRequests: 100
      circuitBreaker:
        requestVolumeThreshold: 20
        errorThresholdPercentage: 50
        sleepWindowInMilliseconds: 5000
      metrics:
        rollingStats:
          timeInMilliseconds: 10000
          numBuckets: 10

在上述配置中，我们可以通过 hystrix.command.default.execution.isolation.semaphore.maxConcurrentRequests 属性指定最大并发请求数量，超出该数量的请求将被拒绝。

示例说明

服务降级示例

假设我们的服务需要调用一个远程服务获取用户信息，但该远程服务响应时间较长或出现故障时，我们需要对服务进行降级处理，以保证系统的稳定性。

@Service
public class UserServiceImpl implements UserService {

    @Autowired
    private RemoteUserService remoteUserService;

    @Override
    @HystrixCommand(fallbackMethod = "getUserByIdFallback")
    public User getUserById(Long id) {
        return remoteUserService.getUserById(id);
    }

    private User getUserByIdFallback(Long id) {
        return new User(id, "default");
    }
}

在上述例子中，当远程服务出现故障或响应时间过长时，getUserByIdFallback() 方法将会被调用，返回一个默认的用户对象。

服务限流示例

假设我们的服务需要同时处理大量的请求，为了避免过多的请求导致系统崩溃，我们需要对服务进行限流处理。

@RestController
public class UserController {

    @Autowired
    private UserService userService;

    @RequestMapping("/users/{id}")
    public User getUserById(@PathVariable Long id) {
        return userService.getUserById(id);
    }
}

hystrix:
  threadpool:
    default:
      coreSize: 10
      maxQueueSize: 20
  command:
    default:
      execution:
        isolation:
          strategy: SEMAPHORE
          semaphore:
            maxConcurrentRequests: 100
      circuitBreaker:
        requestVolumeThreshold: 20
        errorThresholdPercentage: 50
        sleepWindowInMilliseconds: 5000
      metrics:
        rollingStats:
          timeInMilliseconds: 10000
          numBuckets: 10

在上述例子中，我们通过 hystrix.command.default.execution.isolation.strategy 属性指定隔离策略为 SEMAPHORE，然后通过 hystrix.command.default.execution.isolation.semaphore.maxConcurrentRequests 属性指定最大并发请求数量为 100，超过该数量的请求将被拒绝。