熔断机制概述

• 熔断机制是应对雪崩效应的一种微服务链路保护机制。当扇出链路的某个微服务出错不可用或者响应时间太长时会进行服务的降级，进而熔断该节点微服务的调用，快速返回错误的响应信息。
• 当检测到该节点微服务调用响应正常后，恢复调用链路。
• 在Spring Cloud框架里，熔断机制通过Hystrix实现。Hystrix会监控微服务间调用的状况，当失败的调用到一定闻值，缺省是5秒内20次调用失败，就会启动熔断机制。熔断机制的注解是@HystrixCommand。
• 在启动类加上注解：@EnableHystrix

// 服务熔断
@HystrixCommand(fallbackMethod"paymentcircuitBreaker_fallback",commandproperties = {
        @HystrixProperty(name="circuitBreaker.enabled",value ="true"),// 是否开启断路器
        @HystrixProperty(name="circuitBreaker.requestVolumeThreshold",value = "10"),// 清求次数
        @HystrixProperty(name="circuitBreaker.sleepWindowInMilliseconds",value ="1000")，// 时间窗口期
        @HystrixProperty(name="circuitBreaker,errorThresholdpercentage",value ="60"),// 失败率达到多少后跳闸
}
public string paymentcircuitBreaker(@Pathvariable("id") Integer id){
        if(id < @){
            throw new RuntimeException("******id 不能负数");
        }
        String serialNumber = Idutil.simpleuuID();
        return Thread.currentThread().getName()+"\t"+"调用成功，流水号:" + serialNumber;
}
public String paymentircuitBreaker_fallback(@PathVariable("id") Integer id){
        return "id 不能负数，请稍后再试，/(ToT)/~~ id:" +id;
}

涉及到断路器的三个重要参数: 快照时间窗、请求总数阀值、错误百分比阀值。

• 快照时间窗：断路器确定是否打开需要统计一些请求和错误数据，而统计的时间范围就是快照时间窗，默认为最近的10秒。
• 请求总数阀值：在快照时间窗内，必须满足请求总数阀值才有资格断。默认为20，意味着在10秒内，如果该hystrix命令的调用次数不足20次即使所有的请求都超时或其他原因失败，断路器都不会打开。
• 错误百分比阀值：当造求总数在快照时间窗内超过了阀值，比如发生了30次调用，如果在这30次调用中，有15次发生了超时异常，也就是超讨50%的错误百分比，在默认设定50%阀值情况下，这时候就会将断路器打开。

断路器打开之后

• 再有请求调用的时候，将不会调用主逻辑，而是直接调用降级faback。通过断路器，实现了自动地发现错误并将降级逻娼切换为主逻辑，减少响应延迟的效果。
• 原来的主逻辑要如何恢复呢?
• 对于这一问题，hystrix也为我们实现了自动恢复功能。当断路器打开，对主逻辑进行熔断之后，hystrix会启动一个休眠时间窗，在这个时间窗内，降级逻辑是临时的成为主逻辑。当休眠时间窗到期，断路器将进入半开状态，释放一次请求到原来的主逻辑上，如果此次请求正常返回，那么断路器将继续闭合主逻辑恢复，如果这次请求依然有问题，断路器继续进入打开状态，休眠时间窗重新计时。

配置项

@HystrixCommand(fallbackMethod = "strfalbackMethod",
	groupKey ="strGroupCommand",
	commandKey ="strCommand",
	threadPoolKey ="strThreadPo1",
	commandProperties = {
	// 设置隔离策略，THREAD 表示钱程池 SEMAPHORE: 信号池隔离
	@HystrixProperty(name = "execution.isolation.strategy", value = "THREAD"),
	// 当隔离策略选择信号池隔离的时候，用来设置信号的大小《最大并发数)
	@HystrixProperty(name = "execution.isolation,semaphore.maxConcurrentRequests", value = "10"),
	// 配置命令执行的超时时间
	@HystrixProperty(name = "execution,isolation.thread.timeoutinMilliseconds", value = "10"),
	// 是否启用超时时间
	@HystrixProperty(name = "execution,timeout,enabled"， value = "true"),
	// 执行超时的时候是否中断
	@HystrixProperty(name = "execution.isolation,thread.interruptOnTimeout", value = "true"),
	// 执行被取消的时候是否中断
	@HystrixProperty(name = "execution.isolation.thread,interruptOnCancel", value = "true"),
	// 允许回调方法执行的最大井发数
	@HystrixProperty(name = "fallback,isolation,semaphore,maxConcurrentRequests", value = "10"),
	// 服务降级是否启用，是否执行回调函数
	@HystrixProperty(name = "fallback.enabled"， value = "true"),
	// 该属性用来设置在动时间窗中，断路器熔断的最小请求数。例如，默认该值为 20 的时候
	// 如果滚动时间窗(默10秒)内仅收到了19个请求， 即使这19个请求都失败了，断路器也不会打开。
	@HystrixProperty(name = "circuitBreaker,requestVolumeThreshold"， value = "20"）,
	// 该腐性用来设置在嵘动时间窗中，表示在英动时间窗中，在请来数量超过
	//circuitBreakerrequestVolumeThreshold 的信况下，如果错误请求数的百分比超过50
	// 就把新路器设置为“打开”状态，否则就没置为“关闭”状态。
	@HystrixProperty(name = "circuitBreaker.errorThresholdPercentage", value = "50"),
	// 该属性用来设置当断路器打开之后的休眠时间窗。 休眠时间窗结束之后，会将断路器置为“半开”状态，尝就断的请求命令，如果低然失败成格断路器维续设置为“打开”状态
	// 如果成功就没置为“关闭”状态。
	@HystrixProperty(name = "circuitBreaker,sleeplindowinMilliseconds"， value = "5000"),
	// 断路器强制打开
	@HystrixProperty(name ="circuitBreaker,forceOpen", value = "false"),
	// 断路器强制关闭
	@HystrixProperty(name ="circuitBreaker,forceClosed"， value = "false"),
	// 滚动时间窗设置，该时间用于新路器判新健康度时市要收集信息的持续时间
	@HystrixProperty(name = "metrics,rollingStats,timeinMilliseconds", value = "10000"),
	//该属性用来设置淡动时间窗统计拐标信息时划分””的数量，断路器在收标信息的时候会根据// 设置的时间窗长度拆分成多个“桶”来累计各度量值，每个”桶”记录了一段时间内的天集指标。I/比如10 秒内拆分成10个"”收集这样，所以 timeinMilliseconds 必须能被 numBuckets 整。否则会是常
	@HystrixProperty(name = "metrics,rollingStats,numBuckets", value = "10"),
	// 该属性用来没置在执行过程中每个“桶” 中保留的最大执行次数，如果在动时间内发生超过该设定值的执行次数，1/威从最初的位置开始重写。例如，将该值设置为100，滋动口为10秘，若在10秒内一个 “施”中发生7500次执行，1/么该“”中只保留 最后的100次执行的统计。另外，增加该值的大小会增加内存量的消耗，并增加排序百分位教所需的计算时间。
	@HystrixProperty(name = "metrics,rollingPercentile,bucketsize", value = "100"),
	// 该属性用来设置来集影响断路器状态的健康快照(请求的成功、 错误百分比》的间隔等待时间
	@HystrixProperty(name = "metrics.healthSnapshot,intervalinMilliseconds", value = "500"),
	// 是否开启请求缓存
	@HystrixProperty(name = "requestCache,enabled", value = "true"),
	// HystrixCommand的执行和喜件是否打印日志到HystrixRequestLog 中
	@HystrixProperty(name = "requestLog.enabled"， value = "true")
	},
	threadPoolProperties = {
	// 该委教用来设置执行命令线程他的核心线程载，该值也就是命今执行的最大并发量
	@HystrixProperty(name = "coreSize" value = "10"),
	// 该毒数用来设置钱程池的最大队列大小。当设置为-1时，钱程将使用 SynchronousQueue 实的队列// 否则练使用 LinkedBlockingQueue 英现的队列。
	@HystrixProperty(name = "maxQueueSize"，value = "-1"),
	// 该参数用来为队列没置拒绝阀值。 通过该参数， 即使队列没有达到最大值也能拒绝请求。//该参数主要是对 LinkedBlockingQueue 队列的补充因为 LinkedBlockingOueue
	// 队列不能动态格改它的对象大小，而通过该属性就可以调整拒绝请来的队列大小了。
	@HystrixProperty(name = "queueSizeRejectionThreshold"， value ="5")
	}
)