springcloud使用Hystrix實(shí)現(xiàn)斷路器進(jìn)行服務(wù)容錯(cuò)保護(hù)的方法

<project xmlns="http://maven.apache.org/POM/4.0.0"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>
  <groupId>com.sam</groupId>
  <artifactId>hello-consumer</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>1.5.1.RELEASE</version>
  </parent>

  <properties>
    <javaVersion>1.8</javaVersion>
  </properties>

  <dependencyManagement>
    <dependencies>
      <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-dependencies</artifactId>
        <version>Camden.SR6</version>
        <type>pom</type>
        <scope>import</scope>
      </dependency>
    </dependencies>

  </dependencyManagement>

  <dependencies>
    <!-- 引入eureka 客戶端依賴 -->
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-eureka</artifactId>
    </dependency>
    <!-- 引入ribbon 依賴 ，用來(lái)實(shí)現(xiàn)負(fù)載均衡，我們這里只是使用先不作其他介紹 -->
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-ribbon</artifactId>
    </dependency>
    <!-- 引入hystrix 依賴 ，用來(lái)實(shí)現(xiàn)服務(wù)容錯(cuò)保護(hù)-->
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-hystrix</artifactId>
    </dependency>

  </dependencies>
</project>

@EnableDiscoveryClient
@SpringBootApplication
@EnableCircuitBreaker
public class ConsumerApp {


  //@Bean 應(yīng)用在方法上，用來(lái)將方法返回值設(shè)為為bean
  @Bean
  @LoadBalanced //@LoadBalanced實(shí)現(xiàn)負(fù)載均衡
  public RestTemplate restTemplate() {
    return new RestTemplate();
  }
  
  public static void main(String[] args) {
    SpringApplication.run(ConsumerApp.class, args);
  }
}

@SpringCloudApplication
public class ConsumerApp {
  //@Bean 應(yīng)用在方法上，用來(lái)將方法返回值設(shè)為為bean
  @Bean
  @LoadBalanced //@LoadBalanced實(shí)現(xiàn)負(fù)載均衡
  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() {
    // 調(diào)用hello-service服務(wù)，注意這里用的是服務(wù)名，而不是具體的ip+port
    restTemplate.getForObject("http://hello-service/hello", String.class);
    return "hello consumer finish !!!";
  }

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

/**
 *這里不再直接調(diào)用restTemplate，
 *而是通過調(diào)用service進(jìn)行實(shí)現(xiàn) 
 *
 */
@RestController
public class ConsumerController {

  @Autowired
//  RestTemplate restTemplate;
  ConsumerService service;
  
  
  @RequestMapping("/hello-consumer")
  public String helloConsumer() {
//    //調(diào)用hello-service服務(wù)，注意這里用的是服務(wù)名，而不是具體的ip+port
//    restTemplate.getForObject("http://hello-service/hello", String.class);
    return service.consumer();
  }
}