0%

Hystrix配置参数

Hystrix配置参数

1
2
3
4
5
6
7
8
9
10
11
12
13
14
@HystrixCommand(groupKey="UserGroup", commandKey = "GetUserByIdCommand",
commandProperties = {
@HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "100"),//指定多久超时,单位毫秒。超时进fallback
@HystrixProperty(name = "circuitBreaker.requestVolumeThreshold", value = "10"),//判断熔断的最少请求数,默认是10;只有在一个统计窗口内处理的请求数量达到这个阈值,才会进行熔断与否的判断
@HystrixProperty(name = "circuitBreaker.errorThresholdPercentage", value = "10"),//判断熔断的阈值,默认值50,表示在一个统计窗口内有50%的请求处理失败,会触发熔断
},
threadPoolProperties = {
@HystrixProperty(name = "coreSize", value = "30"),
@HystrixProperty(name = "maxQueueSize", value = "101"),
@HystrixProperty(name = "keepAliveTimeMinutes", value = "2"),
@HystrixProperty(name = "queueSizeRejectionThreshold", value = "15"),
@HystrixProperty(name = "metrics.rollingStats.numBuckets", value = "12"),
@HystrixProperty(name = "metrics.rollingStats.timeInMilliseconds", value = "1440")
})
  • groupKey group标识,一个group使用一个线程池
  • commandKey command标识,当前执行方法名
  • threadPoolKey
  • fallbackMethod fallback方法名,两者需要返回值和参数列表相同
  • ignoreExceptions
  • observableExecutionMode
  • raiseHystrixExceptions
  • defaultFallback

commandProperties参数

HystrixCommandProperties

  • circuitBreaker.enabled 是否开启断路器,默认true
  • circuitBreaker.requestVolumeThreshold 一个滑动窗口下的最小的请求次数(请求是否达到开启的阈值),默认20,只有在一个统计窗口内处理的请求数量达到这个阈值,才会进行熔断与否的判断
  • circuitBreaker.sleepWindowInMilliseconds 触发短路的时间值,触发circuitBreaker后该时间段内会拒绝请求(熔断多久之后开始进入半开),默认5000ms
  • circuitBreaker.errorThresholdPercentage 失败率达到多少后跳闸,该时间段内对应请求次数失败率达到多少后进行跳闸,默认50%
  • execution.isolation.strategy 设置隔离策略,THREAD表示线程 SEMAPHORE表示信号量,默认THREAD,有几种情况可以使用SEMAPHORE模式:只想控制并发度 外部的方法已经做了线程隔离 调用的是本地方法或者可靠度非常高、耗时特别小的方法
  • execution.isolation.semaphore.maxConcurrentRequests 如果选用SEMAPHORE,用来设置信号量池的大小,最大并发数,默认10
  • execution.isolation.thread.timeoutInMilliseconds 配置超时时间,默认1000ms
  • execution.timeout.enabled 是否启用超时时间,默认true
  • execution.isolation.thread.interruptOnTimeout 执行超时是否中断,默认true,THREAD模式下有效
  • execution.isolation.thread.interruptOnFutureCancel 执行被取消时是否中断,默认false
  • fallback.isolation.semaphore.maxConcurrentRequests 允许回调方法执行的最大并发数,默认10,SEMAPHORE模式下有效
  • fallback.enabled 服务降级是否启用,默认true
  • circuitBreaker.forceOpen 是否强制开启熔断
  • circuitBreaker.forceClosed 是否强制关闭熔断
  • metrics.rollingStats.timeInMilliseconds 设置统计滚动窗口的长度,单位毫秒
  • metrics.rollingStats.numBuckets 设置统计窗口的桶数量,滚动窗口会被分隔成桶,并且进行滚动,该值设置必须能被metrics.rollingStats.timeInMilliseconds 整除,表示metrics.rollingStats.timeInMilliseconds若值为10000,metrics.rollingStats.numBuckets 值为10,则表示每个桶是1000ms,也就是1s
  • metrics.rollingPercentile.enabled 设置执行时间是否被跟踪,并且计算各个百分比50%、90%等
  • metrics.rollingPercentile.timeInMilliseconds 设置执行时间在滚动窗口中保留时间,用来计算百分比
  • metrics.rollingPercentile.numBuckets 设置rollingPercentile窗口的桶数量,该值必须能被metrics.rollingPercentile.timeInMilliseconds整除
  • metrics.rollingPercentile.bucketSize 设置每个桶保存的执行时间的最大值,如果设置为100,但是有500次请求,则只会计算最近的100次
  • metrics.healthSnapshot.intervalInMilliseconds 采光间隔时间
  • requestCache.enabled 设置是否缓存请求
  • requestLog.enabled 设置HystrixCommand执行事件是否大隐刀HystrixRequestLog中

如果配置中同时包含Ribbon和Hystrix的超时配置,需要确保Hystrix超时配置长于Ribbon的超时配置

threadPoolProperties配置

线程池配置

HystrixThreadPoolProperties

  • coreSize 线程池的核心线程数,最大并发执行数量

  • allowMaximumSizeToDivergeFromCoreSize 允许扩升到maximumSize

  • maximumSize 只有allowMaximumSizeToDivergeFromCoreSize设置为true才会生效

  • maxQueueSize 最大队列长度,如果为正数,将从队列由SynchronousQueue改为LinkedBlockingQueue

    1
    2
    3
    4
    5
    6
    7
    8
    public BlockingQueue<Runnable> getBlockingQueue(int maxQueueSize) {

    if (maxQueueSize <= 0) {
    return new SynchronousQueue<Runnable>();
    } else {
    return new LinkedBlockingQueue<Runnable>(maxQueueSize);
    }
    }
  • keepAliveTimeMinutes keep-live时间

  • queueSizeRejectionThreshold 设置拒绝请求的临界值

  • metrics.rollingStats.timeInMilliseconds

  • metrics.rollingStats.numBuckets

欢迎关注我的其它发布渠道