配置项

目录

• 目录
• 介绍
• 命令的属性
  • Execution（执行器）
    • execution.isolation.strategy
    • execution.isolation.thread.timeoutInMilliseconds
    • execution.timeout.enabled
    • execution.isolation.thread.interruptOnTimeout
    • execution.isolation.thread.interruptOnCancel
    • execution.isolation.semaphore.maxConcurrentRequests
  • Fallback
    • fallback.isolation.semaphore.maxConcurrentRequests
    • fallback.enabled
  • Circuit Breaker(熔断器)
    • circuitBreaker.enabled
    • circuitBreaker.requestVolumeThreshold
    • circuitBreaker.sleepWindowInMilliseconds
    • circuitBreaker.errorThresholdPercentage
    • circuitBreaker.forceOpen
  • Metrics(度量)
    • metrics.rollingStats.timeInMilliseconds
    • metrics.rollingStats.numBuckets
    • metrics.rollingPercentile.enabled
    • metrics.rollingPercentile.timeInMilliseconds
    • metrics.rollingPercentile.numBuckets
    • metrics.rollingPercentile.bucketSize
    • metrics.healthSnapshot.intervalInMilliseconds
  • Request Context
    • requestCache.enabled
    • requestLog.enabled
  • Collapser Properties
    • maxRequestsInBatch
    • timerDelayInMilliseconds
    • requestCache.enabled
  • ThreadPool Properties
    • coreSize
    • maxQueueSize
    • queueSizeRejectionThreshold
    • keepAliveTimeMinutes
    • metrics.rollingStats.timeInMilliseconds
    • metrics.rollingStats.numBuckets

介绍

Hystrix使用 Archaius 作为配置的默认实现属性。

下面的文档描述了使用Hystrix默认属性的策略实现，除非你通过使用插件来覆盖它。

每个属性有四个优先级别：

1. 从代码配置全局默认

   如果未设置以下3中的任何一个，则这是默认值。全局默认值在下表中显示为“默认值”。

2. 动态全局默认属性

   您可以使用属性更改全局默认值。全局默认属性名称在下表中显示为“默认属性”。

3. 从代码配置实例的默认属性

   您可以定义特定于实例的默认值。 例：

    HystrixCommandProperties.Setter().withExecutionTimeoutInMilliseconds(int value)
   

   您将以类似于以下方式将此类命令插入HystrixCommand构造函数：

    public HystrixCommandInstance(int id) {
        super(Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("ExampleGroup"))
            .andCommandPropertiesDefaults(HystrixCommandProperties.Setter()
                   .withExecutionTimeoutInMilliseconds(500)));
        this.id = id;
    }
   

   有常用的初始值的方便构造函数。 这里有一个例子：

    public HystrixCommandInstance(int id) {
        super(HystrixCommandGroupKey.Factory.asKey("ExampleGroup"), 500);
        this.id = id;
    }
   

4. 动态实例属性

   您可以动态设置实例特定值，覆盖前面的三个默认值。动态实例属性名称在下表中显示为“实例属性”。

   例如：

将属性的Hystrix命令键部分替换为您要定位的HystrixCommand的Hystrix命令Key.name（）值。

例如，如果键被命名为“SubscriberGetAccount”，则属性名称将为

hystrix.command.SubscriberGetAccount.execution.isolation.thread.timeoutInMilliseconds

命令的属性

查看原文表格

Execution（执行器）

以下属性控制 HystrixCommand.run() 如何执行

execution.isolation.strategy

此属性指示HystrixCommand.run（）执行的隔离策略，具有以下两个选择之一：

• THREAD --它在单独的线程上执行，并发请求受线程池中的线程数量的限制
• SEMAPHORE --它在调用线程上执行，并发请求受到信号量计数的限制

Thread or Semaphore

默认值和推荐设置是使用线程隔离（THREAD）运行命令.

在线程中执行的命令具有超出网络超时可提供的延迟的额外保护层。

一般来说，你应该使用信号量隔离（SEMAPHORE）的唯一场景是当调用是如此高的量（每秒百万次，每个实例），单独的线程的开销太高; 这通常仅适用于非网络呼叫。

Netflix API有40多个命令在40多个线程池中运行，并且只有少数命令不在线程中运行 - 从内存中缓存获取元数据或者是面向线程隔离命令的外观（参见 “Primary + 辅助与后退“模式 有关的更多信息）。

有关此决策的更多信息，请参阅隔离的工作原理。

execution.isolation.thread.timeoutInMilliseconds

此属性设置以毫秒为单位的时间，在此之后，调用者将观察到超时并离开命令执行。 Hystrix将 HystrixCommand 标记为TIMEOUT，并执行回退逻辑。 注意，如果需要，可以关闭每个命令的超时（参见command.timeout.enabled）。

注意：即使调用者从未在结果Future上调用get()，超时将在HystrixCommand.queue()上触发。 在Hystrix 1.4.0之前，只有调用get()触发超时机制在这种情况下生效。

execution.timeout.enabled

此属性指示 HystrixCommand.run() 执行是否应该有超时。

execution.isolation.thread.interruptOnTimeout

此属性指示在发生超时时是否应中断 HystrixCommand.run() 执行。

execution.isolation.thread.interruptOnCancel

此属性指示当发生取消时，HystrixCommand.run() 执行是否应该中断。

execution.isolation.semaphore.maxConcurrentRequests

此属性设置在使用执行策略为ExecutionIsolationStrategy.SEMAPHORE时，允许执行HystrixCommand.run（）方法的最大请求数。

如果此最大并发限制被命中，则后续请求将被拒绝。

你在使用信号量时使用的逻辑基本上与你选择添加到线程池中的线程数量相同，但是信号量的开销要小得多，通常执行速度要快得多（亚毫秒级） ，否则你会使用线程。

例如，在单个实例上的5000 rps的内存中查找与度量收集已被视为与仅2的信号量一起工作。

隔离原理仍然是相同的，所以信号量应当仍然是整个容器（即Tomcat）线程池的小百分比，而不是它的全部或大部分，否则它不提供保护。

Fallback

以下属性控制 HystrixCommand.getFallback() 如何执行。 这些属性适用于 ExecutionIsolationStrategy.THREAD 和 Execution Isolation Strategy.SEMAPHORE 。

fallback.isolation.semaphore.maxConcurrentRequests

此属性设置 HystrixCommand.Fallback() 方法允许从调用线程发出的请求的最大数量。

如果命中最大并发限制，则后续请求将被拒绝，并且由于没有回退，可以检索到异常。

注意：这意味着如果请求线程数如果大于配置值（默认10），将直接fallback，生产环境中注意调整此值的大小

fallback.enabled

Since: 1.2

此属性确定在发生失败或拒绝时是否尝试调用 HystrixCommand.Fallback()。

Circuit Breaker(熔断器)

断路器特性控制 HystrixCircuitBreaker 的行为。

circuitBreaker.enabled

此属性确定断路器是否将用于跟踪运行状况和短路请求（如果熔断）。

circuitBreaker.requestVolumeThreshold

此属性在滚动窗口中设置将跳过请求链路的最小请求数。

例如，如果值为20，则如果在滚动窗口（例如10秒的窗口）中仅接收到19个请求，则即使所有19个请求失败，电路也不会熔断。

备注：断路器熔断的最小值阀值，如果单位时间内请求小于这个值，断路器永远不会熔断。

circuitBreaker.sleepWindowInMilliseconds

此属性设置在调用链路熔断之后，在允许再次尝试确定调用链路是否应闭合之前拒绝请求的时间量。

备注：可以理解为，调用链路熔断后，一定时间后(默认5秒)，将再次重试调用run()方法，检测是否需要闭合调用链路。实际多线程测试的过程中，只有一个线程会尝试闭合链路，如果仍旧符合熔断条件（比如默认值，响应时间大于1秒），则继续熔断。其他线程一直处于熔断状态，这种设计比较节省调用者的资源，没有必要所有线程都去尝试闭合。

circuitBreaker.errorThresholdPercentage

此属性设置错误百分比，在该值或以上时调用链路应熔断，并开始短路请求到fallback逻辑。

错误数达到或超过配置值时，执行熔断操作，调用fallback.注意此百分比是值在一定时间范围内（默认10秒，见metrics.rollingStats.timeInMilliseconds）

circuitBreaker.forceOpen

该属性，如果为true，强制断路器进入打开（熔断）状态，其中它将拒绝所有请求。此属性优先 circuitBreaker.forceClosed。

circuitBreaker.forceClosed

该属性如果为true，则迫使断路器进入闭合状态，其中它将允许所有请求通过，而不考虑误差百分比。

circuitBreaker.force 打开属性优先，如果设置为true，此属性不执行任何操作。

Metrics(度量)

以下属性与从 Hystrix Command 和 HystrixObservableCommand 执行捕获指标有关。

metrics.rollingStats.timeInMilliseconds

此属性设置统计滚动窗口的持续时间（以毫秒为单位）。 这是Hystrix保持熔断器使用和发布的指标时间。

从1.4.12开始，此属性仅影响初始度量标准创建，并且在启动后对此属性所做的调整将不会生效。 这避免了度量标准数据丢失，并允许优化度量标准收集。

窗口被分成桶和“滚动”这些增量。

例如，如果此属性设置为10秒（10000），其中包含十个1秒钟桶，则下图说明了如何滚动新桶和旧桶：

metrics.rollingStats.numBuckets

此属性设置滚动统计窗口划分的桶数

注意 以下必须为true -- ”metrics.rollingStats.timeInMilliseconds % metrics.rollingStats.numBuckets == 0“ --否则将抛出异常。

换句话说，10000/10是可以的，所以可以是10000/20，但10000/7不行。

从1.4.12开始，此属性仅影响初始度量标准创建，并且在启动后对此属性所做的调整将不会生效。 这避免了度量标准数据丢失，并允许优化度量标准收集。

metrics.rollingPercentile.enabled

此属性指示是否应将跟踪和计算执行延迟作为百分位数。 如果禁用它们，则所有摘要统计信息（平均值，百分位数）都将返回-1。

metrics.rollingPercentile.timeInMilliseconds

此属性设置滚动窗口的持续时间，其中保留执行时间以允许百分位数计算，以毫秒为单位。窗口被分成桶和“卷”这些增量。

从1.4.12开始，此属性仅影响初始度量标准创建，并且在启动后对此属性所做的调整将不会生效。 这避免了度量标准数据丢失，并允许优化度量标准收集。

metrics.rollingPercentile.numBuckets

此属性设置滚动百分位窗口将划分的桶的数量。

注意：以下内容必须为true - “metrics.rolling Percentile.time In Milliseconds％metrics.rolling Percentile.numBuckets == 0” - 否则将抛出异常。

从1.4.12开始，此属性仅影响初始度量标准创建，并且在启动后对此属性所做的调整将不会生效。 这避免了度量标准数据丢失，并允许优化度量标准收集。

metrics.rollingPercentile.bucketSize

此属性设置每个存储桶保留的最大执行次数。 更多的执行发生在它们将围绕并在桶的开始处开始重写的时间期间。

例如，如果桶大小设置为100并且表示10秒的桶窗口，但在该时间期间发生500次执行，则在该10秒钟桶中将仅保留最后100次执行。

如果增加此大小，这还会增加存储值所需的内存量，并增加对列表进行排序以执行百分位数计算所需的时间。

从1.4.12开始，此属性仅影响初始度量标准创建，并且在启动后对此属性所做的调整将不会生效。 这避免了度量标准数据丢失，并允许优化度量标准收集。

metrics.healthSnapshot.intervalInMilliseconds

此属性设置在允许计算成功和错误百分比并影响断路器状态的健康快照之间等待的时间（以毫秒为单位）。

在高容量调用链路上，错误百分比的连续计算可能变得CPU密集，因此此属性允许您控制计算的频率。

Request Context

这些属性涉及 HystrixCommand 使用的 HystrixRequestContext 功能

requestCache.enabled

此属性指示 HystrixCommand.getCacheKey()) 是否应与 HystrixRequstCache 一起使用，以通过请求范围的缓存提供重复数据缓存功能。

requestLog.enabled

此属性指示 HystrixCommand 和事件是否应记录到 HystrixRequestLog

Collapser Properties

以下属性控制 HystrixCollapser 行为。

maxRequestsInBatch

此属性设置在触发批处理执行之前批处理中允许的最大请求数。

timerDelayInMilliseconds

此属性设置创建批处理后触发其执行的毫秒数。

requestCache.enabled

此属性指示是否为 Hystrix Collapser.execute())和Hystrix Collapser.queue)调用启用请求高速缓存。

ThreadPool Properties

以下属性控制Hystrix命令在其上执行的线程池的行为。大多数时候，默认值为10的线程会很好（通常可以做得更小）。

要确定是否需要更大，计算大小的基本公式为： 请求每秒在峰值时健康×99th百分位延迟（秒）+ 冗余值

参见下面的例子，看看这个公式是如何付诸实践的。

一般原则是保持池尽可能小，因为它是缓解负载的主要工具，并防止资源在延迟发生时被阻塞。

上图显示了一个示例配置，其中依赖关系没有理由命中99.5百分位，因此它在网络超时层将其缩短，并立即重试，期望它将在大多数时间获得中等延迟，并且能够在300ms线程超时内完成这一切。

如果依赖有合法的理由有时达到99.5百分位数（例如缓存未命中延迟生成），那么网络超时将被设置为高于它，例如在325ms，0或1次重试，线程超时设置更高（350ms + ）。

线程池的大小为10，以处理第99百分位数请求的突发，但是当一切正常时，此线程池通常只有1或2个线程在任何给定时间处于活动状态，以服务大约40ms的中间调用。

当您正确配置HystrixCommand层的超时应该是罕见的，但保护是在那里，除了网络延迟影响时间，或连接+读+重试+连接+读的组合在最坏的情况下仍然超过配置的总体超时。

每个方向上的配置的积极性和权衡对于每个依赖性是不同的。

您可以随着性能特征更改或发现问题，根据需要实时更改配置，如果出现问题或配置错误，则无需删除整个应用程序。

coreSize

此属性设置核心线程池大小。 这是可以同时执行的Hystrix命令的最大数量。

maxQueueSize

此属性设置BlockingQueue实现的最大队列大小。

如果将此值设置为-1，那么将使用同步队列( SynchronousQueue )，否则将使用 LinkedBlockingQueue的正值。

注意：此属性仅在初始化时适用，因为队列实现不能重新调整大小或更改，而不重新初始化不支持的线程执行程序。

如果需要克服此限制并允许队列中的动态更改，请参阅队列大小拒绝阈值属性

要在SynchronousQueue和LinkedBlockingQueue之间切换，需要重新启动。

queueSizeRejectionThreshold

此属性设置队列大小拒绝阈值 - 即使未达到maxQueueSize也将发生拒绝的人为最大队列大小。 此属性存在，因为BlockingQueue的 maxQueueSize 不能动态更改，我们希望允许您动态更改影响拒绝的队列大小。

这是HystrixCommand在对线程执行排队时使用的。

注意：如果maxQueueSize == -1，则此属性不适用。

keepAliveTimeMinutes

此属性设置保持活动时间，以分钟为单位。

这实际上并不使用，因为 corePoolSize 和 maxPoolSize 在默认实现中设置为相同的值，但是如果您要通过插件(plugin)使用自定义实现，那么这将可供您使用。

metrics.rollingStats.timeInMilliseconds

此属性设置统计滚动窗口的持续时间（以毫秒为单位）。 这是为线程池保留多长时间。

窗口被分成桶和“卷”这些增量。

metrics.rollingStats.numBuckets

此属性设置滚动统计窗口划分的桶数。

注意：以下内容必须为true - “metrics.rolling Stats.time In Milliseconds％metrics.rollingStats.numBuckets == 0” - 否则将抛出异常。

换句话说，10000/10是好的，所以是10000/20，但10000/7不是。