因为使用的是注解方式，所以我们需要设置Aspect
- 依赖（hystrix-core至少要1.5.9以上）
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
| <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.1.2</version>
</dependency>
<dependency>
<groupId>com.netflix.hystrix</groupId>
<artifactId>hystrix-javanica</artifactId>
<version>1.5.9</version>
</dependency>
|
- 启动类
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
| @SpringBootApplication
public class Main {
public static void main(String[] args) {
SpringApplication.run(Main.class, args);
}
@Bean
public ServletRegistrationBean servletRegistrationBean() {
// ServletName默认值为首字母小写，即myServlet
return new ServletRegistrationBean(new HystrixMetricsStreamServlet(), "/hystrix.stream");
}
// 向Spring容器注入HystrixCommandAspect
@Bean(name = "hystrixAspect")
public HystrixCommandAspect hystrixCommandAspect() {
return new HystrixCommandAspect();
}
}
|
- 控制器
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
| @Controller
public class HelloController {
// 注解配置
@RequestMapping("/anno")
@ResponseBody
@HystrixCommand(groupKey = "annoGroup", commandKey = "annoCommand", fallbackMethod = "annoFallback",
commandProperties = {
@HystrixProperty(name = "execution.isolation.strategy", value = "THREAD"),
@HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "500")
})
public Object anno() {
try {
TimeUnit.MILLISECONDS.sleep(600);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("anno method thread: " + Thread.currentThread().getName());
return "anno";
}
// 失败回调方法
public Object annoFallback() {
System.out.println("annoFallback method thread: " + Thread.currentThread().getName());
return "annoFallback";
}
}
|