Hystrix主要用于实现微服务体系中断路器的作用。往往与spring cloud集成使用。但绝大部分的项目现在还没有完全移植到spring cloud环境中。所以了解其独立使用的方式也很必要，好在Netflix出品，必属精品。开发过程中使用起来也比较简便。
以spring boot项目加入Hystrix为例，看看如果快速的项目中使用Hystrix特性。
maven依赖
<dependency>
<groupId>com.netflix.hystrix</groupId>
<artifactId>hystrix-core</artifactId>
<version>1.5.9</version>
</dependency>
<dependency>
<groupId>com.netflix.hystrix</groupId>
<artifactId>hystrix-metrics-event-stream</artifactId>
<version>1.5.9</version>
</dependency>
<dependency>
<groupId>com.netflix.hystrix</groupId>
<artifactId>hystrix-javanica</artifactId>
<version>1.5.9</version>
</dependency>
spring boot配置类
import org.springframework.boot.web.servlet.ServletRegistrationBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import com.netflix.hystrix.contrib.javanica.aop.aspectj.HystrixCommandAspect;
import com.netflix.hystrix.contrib.metrics.eventstream.HystrixMetricsStreamServlet;
@Configuration
public class HystrixConfiguration {
@Bean
public HystrixCommandAspect hystrixAspect() {
return new HystrixCommandAspect();
}
@Bean
public ServletRegistrationBean hystrixMetricsStreamServlet() {
ServletRegistrationBean registration = new ServletRegistrationBean(new HystrixMetricsStreamServlet());
registration.addUrlMappings("/hystrix.stream");
return registration;
}
}
声明一个HystrixCommandAspect代理类，用于以后被Hystrix相关注解的切面。另外声明一个Servlet，用于收集监控信息。
被Hystrix监控类
@RestController
@RequestMapping({ "/test" })
public class UserController {
@Autowired
private RemoteService remoteService;
@RequestMapping(value = "/user")
@HystrixCommand(fallbackMethod = "fallback", threadPoolProperties = {
@HystrixProperty(name = "coreSize", value = "30"), @HystrixProperty(name = "maxQueueSize", value = "100"),
@HystrixProperty(name = "queueSizeRejectionThreshold", value = "20") }, commandProperties = {
@HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "3000"),
@HystrixProperty(name = "circuitBreaker.requestVolumeThreshold", value = "1")
})
public User getUser1() throws InterruptedException{
User user = remoteService.getUser1();
return user;
}
public User fallback(Throwable e) {
e.printStackTrace();
return new User();
}
}
通过@HystrixCommand设定断路策略，各配置具体作用参考官方解释。
项目运行之后可以通过http://主机/项目名/test/user进行业务访问。另外可以通过http://主机/项目名/hystrix.stream查看调用事件。由于hystrix.stream以json格式输出，可读性较差，所以需要其他方案以便更优雅的展示监控结果。
https://github.com/kennedyoliveira/standalone-hystrix-dashboard就是一个非常不错的项目，将hystrix.stream产生的json以图形化的形式展现。
在git下载该项目并运行后，配置监控url地址即可直观的查看被@HystrixCommand作用调用情况。
