如何创建动态hystrixcommand threadPoolKey

Question

我正在使用hystrix在我的springboot服务中实现断路器概念。我在需要在发生阈值故障数的情况下节流外部服务调用的方法上使用的HystrixCommand注释如下所示：

 @HystrixCommand(commandKey = "myCommandKey",
            groupKey = "myGroupKey",
            threadPoolKey = "myThreadPoolKey")
    public String myHystrixMethod(String someParam) { ....}

现在，myHystrixMethod驻留的服务由不同的客户端调用。根据调用服务的客户机的类型，有一个逻辑来调用为该特定客户机指定的后端服务。

我想做的是将特定客户机调用的所有线程（请求）注册到它自己的hystrix线程池中。这意味着,来自客户机A的请求将在hystrix线程池中为客户机A注册,而对于客户机B的请求将在hystrix线程池中仅为客户机B注册。这将确保客户端B对我的服务的请求不会因为客户端A中的故障而被抑制。

为此，我可以为每个客户机创建单独的服务方法（如上所示），并相应地命名hystrix线程池。然而，使用这种方法，每当有一个新的客户端时，我将不得不修改源代码以添加它的服务方法。

有没有一种方法可以基于参数（在本例中为客户端ID）动态创建@HystrixCommand注释中的选项？

Answer 1

我不知道用Hystrix库做这件事的任何方法，但由于您已经要求任何其他电路断路器实现可以做这件事，这里是基于Resilience4J库的解决方案。

在应用程序上下文中，您可以使用客户端的默认配置注册circuitbreakerregistrybean。

@Bean
public CircuitBreakerRegistry circuitBreakerRegistry() {
    CircuitBreakerConfig config = CircuitBreakerConfig.custom()
            .failureRateThreshold(35)
            .ringBufferSizeInClosedState(1000)
            .ringBufferSizeInHalfOpenState(100)
            .waitDurationInOpenState(Duration.ofMinutes(1))
            .build();
    return CircuitBreakerRegistry.of(config);
}

然后，您只需将此注册表注入到您的服务中，在受保护的方法中，您就可以为您需要的任何客户机获取CB。

CircuitBreaker circuitBreaker = circuitBreakerRegistry.circuitBreaker("ClientA");

现在您可以使用任何可选的circuitbreaker方法:iscallpermited()或executerunnable()或任何其他方法。

有关更多信息，请参阅用户指南。