spring-cloud-hystrix熔断

依赖pom

<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-netflix</artifactId>
<version>1.0.7RELEASE</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-hystrix</artifactId>
</dependency>
<dependencies>

源代码

@RestController
@SpringBootApplication
@EnableCircuitBreaker
public class Application extends SpringBootServletInitializer{
@AutoWired
FooService fooService;

@RequestMapping("/foo")
public String foo(){
return fooService.getFoo();
}

public static void main(String[] args){
SpringApplication.run(Application.class,args);
}
}

模拟服务失败的情况

@Component
public FooService{
@HystrixCommand(fallbackMethod="defaultFoo")
public static String getFoo() throws Exception {
throw new Exception();
}

public static String defaultFoo(){
return "defaultFoo";
}

}

浏览器调用 foo

展示 defaultFoo

熔断器是一种异常的处理机制

进一步尝试,模拟服务有时成功 有时失败的情况

@Component
public FooService{

static int count=0;
@HystrixCommand(fallbackMethod="defaultFoo")
public static String getFoo() throws Exception {
count++;
count%=20;
System.out.println("realGetFoo");
if(count<10){
throw new Exception();
}else{
return "foo";
}
}

public static String defaultFoo(){
return "defaultFoo";
}

}

插入一些日志输出，发现会先调用一下getFoo这个接口，如果出现异常则调用defaultFoo

熔断可能可以设置一些策略，在某些情况下不调用getFoo接口

启用hystrix报表

添加依赖

<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-netflix-hystrix-dashboard</artifactId>
</dependency>

Application增加注解

@EnableHystrixDashBoard

在浏览器中输入

http://host:port/hytrix

并填入地址，可以进入hystrix-dashboard界面

测试发现如果多次快速调用foo接口 并且Foo接口抛出异常

断路器会变为open状态，此时程序不会尝试调用实际的getFoo方法，而是直接调用defaultFoo

过一段时间之后 circuit会自动闭合