hystrix的最大并发量设置

ゝ一纸荒年。 2023-02-20 04:54 12阅读 0赞

转载自：[http://blog.smallerpig.com/what-hystrix-maxConcurrentRequest-meaning.html][http_blog.smallerpig.com_what-hystrix-maxConcurrentRequest-meaning.html]

## 叙述 ##

组内同学在开发过程中遇到了个问题，  
在使用**`@HystrixCommand(fallbackMethod = "fallBackVisistInfo")`**注解对某个负载均衡的请求方法进行操作时，在大并发请求下，总是会有大部分的请求直接进入fallback，根本不会去请求真正对应的微服务。

如下代码：

@Override
    @HystrixCommand(fallbackMethod = "fallBackVisistInfo")
    public JSONObject getUserVisitInfo(String userkey ) {
        String url = "http://serverid/api/ping?"
                +"userKey=" +userkey ;
        logger.info("请求链接     {}",url );
        JSONObject result = restTemplate.getForObject(url ,JSONObject.class);
        logger.info("request result :{}", result.toJSONString());
        return result;
    }
    
    public JSONObject fallBackVisistInfo(String username) {
        logger.debug("【请求异常】，使用默认值{},{}",0,0);
        JSONObject jsonObject  =  new JSONObject();
        jsonObject.put("returnCode", RequestConstants.REQUEST_SUCCESS_CODE);
        jsonObject.put("returnMsg", RequestConstants.REQUEST_SUCCESS_MSG);
        jsonObject.put("returnData", new JSONObject());
        return  jsonObject;
    }

当然，定位到该问题需要个过程，今天分享的是怎样解决这个问题。

## 解决方案 ##

从google中找到了这样的一个问题：  
[https://stackoverflow.com/questions/39609636/hystrixruntimeexception-testcommand-fallback-execution-rejected][https_stackoverflow.com_questions_39609636_hystrixruntimeexception-testcommand-fallback-execution-rejected]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpemhlbmd5dTg5MTIzMQ_size_16_color_FFFFFF_t_70][]

[https://github.com/Netflix/Hystrix/issues/796][https_github.com_Netflix_Hystrix_issues_796]

正如上面的回复，  
默认的Hystrix会限制某个请求的最大并发量：默认10，如果超过了这个默认的并发值且开启了fallback，则丢弃剩下的请求直接进入fallback方法，找到方法之后就是修改配置的事情了。  
不过作者也建议谨慎修改该值，该值的合理性会影响生产环境的稳定性

在配置文件中加上如下配置：

hystrix.command.default.execution.isolation.strategy=SEMAPHORE
    # 核心的两个设置，允许并发量1000的请求，默认情况下下面两个值都是10，也就是超过10个的并发会直接进入fallback方法，不会去真正请求
    hystrix.command.default.execution.isolation.semaphore.maxConcurrentRequests=1000 
    hystrix.command.default.fallback.isolation.semaphore.maxConcurrentRequests=1000
    
    hystrix.command.default.execution.timeout.enabled=false 
    hystrix.command.default.circuitBreaker.enabled=false
    hystrix.command.default.fallback.enabled=true

上述代码将允许的最大并发请求设置为1000，不过在生产环境下还是需要谨慎设置该值，

另外需要读者好好了解的是hystrix的两种策略  
也就是配置项**`hystrix.command.default.execution.isolation.strategy`**的两个值

### THREAD 默认 ###

运行在独立的线程里，并发请求量受线程池数量限制

### SEMAPHORE ###

并发请求量受 semaphore设置量大小。

在设置为`SEMAPHORE`之后可以设置maxConcurrentRequests的数量了。

关于上述两个关键值，官方文档的解释是：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpemhlbmd5dTg5MTIzMQ_size_16_color_FFFFFF_t_70 1][]

设置好值之后就可以解决

[http_blog.smallerpig.com_what-hystrix-maxConcurrentRequest-meaning.html]: http://blog.smallerpig.com/what-hystrix-maxConcurrentRequest-meaning.html
[https_stackoverflow.com_questions_39609636_hystrixruntimeexception-testcommand-fallback-execution-rejected]: https://stackoverflow.com/questions/39609636/hystrixruntimeexception-testcommand-fallback-execution-rejected
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpemhlbmd5dTg5MTIzMQ_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200623135532184.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpemhlbmd5dTg5MTIzMQ==,size_16,color_FFFFFF,t_70
[https_github.com_Netflix_Hystrix_issues_796]: https://github.com/Netflix/Hystrix/issues/796
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpemhlbmd5dTg5MTIzMQ_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20200623135719260.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpemhlbmd5dTg5MTIzMQ==,size_16,color_FFFFFF,t_70