springcloud使用Hystrix实现断路器进行服务容错保护的方法

  4.0.0
  com.sam
  hello-consumer
  0.0.1-SNAPSHOT
  
    org.springframework.boot
    spring-boot-starter-parent
    1.5.1.RELEASE
  

  
    1.8
  

  
    
      
        org.springframework.cloud
        spring-cloud-dependencies
        Camden.SR6
        pom
        import
      
    

  

  
    
    
      org.springframework.cloud
      spring-cloud-starter-eureka
    
    
    
      org.springframework.cloud
      spring-cloud-starter-ribbon
    
    
    
      org.springframework.cloud
      spring-cloud-starter-hystrix
    

  

@EnableDiscoveryClient
@SpringBootApplication
@EnableCircuitBreaker
public class ConsumerApp {


  //@Bean 应用在方法上，用来将方法返回值设为为bean
  @Bean
  @LoadBalanced //@LoadBalanced实现负载均衡
  public RestTemplate restTemplate() {
    return new RestTemplate();
  }
  
  public static void main(String[] args) {
    SpringApplication.run(ConsumerApp.class, args);
  }
}

@SpringCloudApplication
public class ConsumerApp {
  //@Bean 应用在方法上，用来将方法返回值设为为bean
  @Bean
  @LoadBalanced //@LoadBalanced实现负载均衡
  public RestTemplate restTemplate() {
    return new RestTemplate();
  }
  
  public static void main(String[] args) {
    SpringApplication.run(ConsumerApp.class, args);
  }
}

@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Inherited
@SpringBootApplication
@EnableDiscoveryClient
@EnableCircuitBreaker
public @interface SpringCloudApplication {
}

@Service
public class ConsumerService {
  
  @Autowired
  RestTemplate restTemplate;

  @HystrixCommand(fallbackMethod = "errorMsg")
  public String consumer() {
    // 调用hello-service服务，注意这里用的是服务名，而不是具体的ip+port
    restTemplate.getForObject("http://hello-service/hello", String.class);
    return "hello consumer finish !!!";
  }

  public String errorMsg() {
    return "error!!!";
  }
}

/**
 *这里不再直接调用restTemplate，
 *而是通过调用service进行实现 
 *
 */
@RestController
public class ConsumerController {

  @Autowired
//  RestTemplate restTemplate;
  ConsumerService service;
  
  
  @RequestMapping("/hello-consumer")
  public String helloConsumer() {
//    //调用hello-service服务，注意这里用的是服务名，而不是具体的ip+port
//    restTemplate.getForObject("http://hello-service/hello", String.class);
    return service.consumer();
  }
}