spring cloud hystrix 断路器

spring cloud hystrix 断路器

断路器本身是一种开关保护机制，用于在电路上保护线路过载，当线路中有电器发生短路时，
断路器能够及时切断故障电路，防止发生过载、发热甚至起火等严重后果。

Spring Cloud Hystrix 实现了断路器、线路隔离等一系列服务保护功能。
它也是基于 Netflix 的开源框架 Hystrix 实现的，该框架的目标在于通过控制那些访问远程系统、
服务和第三方库的节点，从而对延迟和故障提供更强大的容错能力。Hystrix 具备服务降级、服务熔断、
线程和信号隔离、请求缓存、请求合并以及服务监控等强大功能。

(1)pom依赖jar包
<dependency>
　　<groupId>org.springframework.cloud</groupId>
　　<artifactId>spring-cloud-starter-hystrix</artifactId>
</dependency>

(2)@EnableCircuitBreaker 注解开启断路器功能
@EnableCircuitBreaker
@EnableEurekaClient
@RibbonClient(name = "SPRING-CLOUD-CLIENT3",configuration = MyRibbonConfig.class)
@SpringBootApplication
public class App {

@Bean
    @LoadBalanced
    RestTemplate restTemplate() {
        return new RestTemplate();
    }

public static void main(String[] args) throws Exception {
        SpringApplication.run(App.class, args);
    }
}
(3)改造服务消费方式，新增 HelloService 类，注入 RestTemplate 实例。
然后，将在 ConsumerController 中对 RestTemplate 的使用迁移到 helloService 函数中，
最后，在 helloService 函数上增加 @HystrixCommand 注解来指定回调方法。

@Service
public class UserService {
@Autowired
private RestTemplate restTemplate;

//通过Thread.sleep 函数可让接口的处理线程不是马上返回内容，而是在阻塞几秒后才返回内容。由于 Hystrix 默认超时时间为 2000 毫秒，
//所以这里采用了 0 至 3000 的随机数以让处理过程有一定概率发生超时来触发断路器。
@HystrixCommand(fallbackMethod = "hiFallback")
public String getUsers() {
System.out.println("***********");
// 让处理线程等待几秒钟
        int sleepTime = new Random().nextInt(3000);
        try {
            Thread.sleep(sleepTime);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
String url = "http://192.168.137.1:8082/spring-cloud-client3/user/hi/";
RestTemplate r= new RestTemplate();
String result=r.getForObject(url, String.class);
System.out.println("result="+result);
return result;
}

public String hiFallback() {
return "err";
}
}

@Controller("usercontroller")
@RequestMapping("/user")
public class UserController{

@Autowired
private UserService userService;

@RequestMapping("/")
@ResponseBody
public String list() {
String res = userService.getUsers();
return "user";
}

@RequestMapping("/hi")
@ResponseBody
public String sayHi() {
System.out.println(" *** sayHi *** ");
return "a";
}
}