哪些情况导致服务降级:
1、程序运行异常
2、超时
3、服务熔断触发服务降级
4、线程池/信号量打满也会导致服务降级
服务熔断:类比保险丝达到最大服务访问之后,直接绝访问,拉闸限电,然后调用服务降级的方法并返回友好提示。
服务熔断的过程:
服务的降级->进而熔断->恢复调用链路
多次错误,然后慢慢正确,发现刚开始不满足条件,就算是正常的访问地址也不能返回正确结果。
熔断类型:
1、熔断打开:请求不再进行调用当前服务,内部设置时钟一般为MITR(平均故障处理时间),当打开时长达到所设时钟则进入半熔断状态。
2、熔断关闭:熔断关闭不会对服务进行熔断。
3、熔断半开:部分请求根据规则调用当前服务,如果请求成功且符合规则则认位当前服务恢复正常,关闭熔断。
package com.springcloud.service;
import ch.qos.logback.core.util.TimeUtil;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixProperty;
import org.springframework.stereotype.Service;
import org.springframework.web.bind.annotation.PathVariable;
import java.util.UUID;
import java.util.concurrent.TimeUnit;
/**
* @author dc
* @date 2020/7/29 - 10:24
*/
@Service
public class PaymentService {
/**
* 正常访问,肯定OK
* @param id
* @return
*/
public String paymentInfo_OK(Integer id) {
return "线程池:" + Thread.currentThread().getName() + " paymentInfo_OK,id:" + id + "\t" + "O(∩_∩)哈哈~";
}
@HystrixCommand(fallbackMethod = "paymentInfo_TimeOutHandler",commandProperties =
{@HystrixProperty(name="execution.isolation.thread.timeoutInMilliseconds",
value="3000")})
//name:属性名 value:属性值
//execution.isolation.thread.timeoutInMilliseconds:最大超时时间,如果业务方法执行时间超过该值,
//就进入服务降级方法(fallbackMethod)
public String paymentInfo_TimeOut(Integer id) {
int timeNumber = 5;
// int a = 10/0;
//线程睡眠3秒
try {
TimeUnit.SECONDS.sleep(timeNumber);
} catch (InterruptedException e) {
e.printStackTrace();
}
return "线程池:" + Thread.currentThread().getName() + " paymentInfo_TimeOut,id:" + id + "\t" + "O(∩_∩)哈哈~" + " 耗时" + timeNumber + "秒钟";
}
public String paymentInfo_TimeOutHandler(Integer id) {
return "线程池: " + Thread.currentThread().getName() + "paymentInfo_TimeOutHandler, id: "
+ id + "\t" +"服务超时处理";
}
/*---------------------------服务熔断-----------------------------*/
//达到如下条件触发服务熔断
@HystrixCommand(fallbackMethod = "paymentCircuitBreaker_fallback",commandProperties = {
@HystrixProperty(name = "circuitBreaker.enabled", value="true"), //是否开启断路器
@HystrixProperty(name = "circuitBreaker.requestVolumeThreshold", value="10"), //请求次数
@HystrixProperty(name = "circuitBreaker.sleepWindowInMilliseconds", value="10000"), //时间窗口期
@HystrixProperty(name = "circuitBreaker.errorThresholdPercentage", value="60"), //失败率达到多少后跳闸
})
public String paymentCircuitBreaker(Integer id) {
if (id < 0) {
throw new RuntimeException("*******id不能为负数");
}
String serialNumber = UUID.randomUUID().toString();
return Thread.currentThread().getName() + "\t" + "调用成功, 流水号:" + serialNumber;
}
//兜底的方法
public String paymentCircuitBreaker_fallback(Integer id) {
return "id 不能负数,请稍后再试,,id:" + id;
}
}