SpringCloud第七节内容精简（下），Hystrix断路器和服务熔断

服务的降级->再到熔断 ->恢复调用链路

当检测到响应正常后，恢复。

 

修改 8001项目的service层。窗口期10秒，10秒内错误达到一定次数接下来输入对的也会失败

package com.atguigu.springcloud.service; import cn.hutool.core.util.IdUtil; 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.concurrent.TimeUnit; /** * Created by IntelliJ IDEA. * User: zhuangzibing * Date: 2020/7/1 */ @Service public class PaymentService { public String paymentInfo_Ok(Integer id){ return "线程池："+Thread.currentThread().getName()+"paymentInfo_ok,id:"+id; } @HystrixCommand(fallbackMethod = "paymentInfo_TimeOutHandler",commandProperties = { @HystrixProperty(name="execution.isolation.thread.timeoutInMilliseconds",value="5000") }) public String paymentInfo_TimeOut(Integer id){ try { TimeUnit.SECONDS.sleep(3); } catch (InterruptedException e) { e.printStackTrace(); } return "线程池："+Thread.currentThread().getName()+"paymentInfo_TimeOut,id:"+id+"耗时5秒"; } public String paymentInfo_TimeOutHandler(Integer id){ return "线程池："+Thread.currentThread().getName()+"paymentInfo_TimeOutHandler,id:"+id+"拦截方法"; } //=====服务熔断 @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(@PathVariable("id") Integer id) { if(id < 0) { throw new RuntimeException("******id 不能负数"); } String serialNumber = IdUtil.simpleUUID(); return Thread.currentThread().getName()+"\t"+"调用成功，流水号: " + serialNumber; } public String paymentCircuitBreaker_fallback(@PathVariable("id") Integer id) { return "id 不能负数，请稍后再试，/(ㄒoㄒ)/~~ id: " +id; } }

控制器加多一个方法

//服务熔断 @GetMapping("/payment/circuit/{id}") public String paymentCircuitBreaker(@PathVariable("id") Integer id){ String result = paymentService.paymentCircuitBreaker(id); log.info("******result"+result); return result; }

启动类 

@SpringBootApplication @EnableEurekaClient @EnableCircuitBreaker public class PaymentHystrixMain8001 { public static void main(String[] args) { SpringApplication.run(PaymentHystrixMain8001.class,args); } }

效果图。输入-1后返回错误信息。然后重复刷新，接下里输入正确的也会熔断

 

可以参考所有配置

https://blog.csdn.net/bailaoshi666/article/details/107087268

 

服务限流在阿里巴巴的Sentinel说明