<!--使用線程隔離和服務(wù)降級引入 hystrix依賴-->
       <dependency>
           <groupId>org.springframework.cloud</groupId>
           <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
       </dependency>
   </dependencies>

//@EnableDiscoveryClient//開啟負載均衡
//@EnableCircuitBreaker//開啟服務(wù)隔離和熔斷
//@SpringBootApplication
@SpringCloudApplication//springCloud注解 包含了以上三個注解配置這個不需要配置以上三個注解
public class UserConsumerDemoApplication {
    @Bean
    @LoadBalanced//負載均衡的另一種使用方法  內(nèi)置一個攔截器 攔截所有restTemplate請求
    public RestTemplate restTemplate() {
        // 這次我們使用了OkHttp客戶端,只需要注入工廠即可
        return new RestTemplate();
    }
    public static void main(String[] args) {
        SpringApplication.run(UserConsumerDemoApplication.class, args);
    }
}

@springCloud注解源碼
 * @SpringBootApplication
 * @EnableDiscoveryClient
 * @EnableCircuitBreaker
 * public @interface SpringCloudApplication {
 * }

@RestController
@RequestMapping("/consumer")
@DefaultProperties(defaultFallback = "defaultFallBack")//默認屬性  寫在類上  類中所有方法通用屬性
public class ConsumerController {
    @Autowired
    private RestTemplate restTemplate;
    @Autowired
    private DiscoveryClient discoveryClient;
 @GetMapping("{id}")
@HystrixCommand(fallbackMethod = "queryByIdFallBack")//開啟線程隔離和降級  fallbackMethod指定失敗方法
    //類上配置了  方法上直接配置@HystrixCommand注解就行
@HystrixCommand(commandProperties = { //配置單個方法的超時時間  配置整體的超時時間需要在配置文件中配置
           //設(shè)置超時時長為兩秒
          @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds",value = "2000")
  })
public String queryById(@PathVariable("id") Long id){
        String url="http://user-service/user/"+id;
        String user = restTemplate.getForObject(url, String.class);
        return user;
    }
   //失敗方法和成功方法 參數(shù) 返回值必須一樣 方法名不做限制
    public String  queryByIdFallBack(Long id){
        return "服務(wù)正忙,稍后重試";
    }
    //在方法上配置寫參數(shù)   在類上配置通用的 不能寫參數(shù)
    public String defaultFallBack(){
        return "服務(wù)正忙,稍后重試";
    }

@GetMapping("{id}")
public User queryUserById(@PathVariable("id") Long id) {
    try {
        Thread.sleep(6000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    return this.userService.queryUserById(id);
}

hystrix:
  command:
    default:
      execution:
        isolation:
          thread:
            timeoutInMilliseconds: 6000 # 設(shè)置hystrix的超時時間為6000ms

  public String queryById(@PathVariable("id") Long id){
        //因為很難模擬熔斷現(xiàn)象我們只能手動控制 如果傳入的是偶數(shù)就熔斷 如果是技術(shù)就恢復正常
        if(id%2==0){
            throw new RuntimeException("");
        }
        String url="http://user-service/user/"+id;
        String user = restTemplate.getForObject(url, String.class);
        return user;
    }

@GetMapping("{id}")
   // @HystrixCommand(fallbackMethod = "queryByIdFallBack")//開啟線程隔離和降級  fallbackMethod指定失敗方法
    //類上配置了  方法上直接配置@HystrixCommand注解就行
//    @HystrixCommand(commandProperties = { //配置單個方法的超時時間  配置整體的超時時間需要在配置文件中配置
//            //設(shè)置超時時長為兩秒
//            @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds",value = "2000")
//    })
    @HystrixCommand(
            commandProperties = { //配置單個方法的超時時間  配置整體的超時時間需要在配置文件中配置
               //設(shè)置熔斷器統(tǒng)計次數(shù)為10次
            @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold",value = "10"),
               //設(shè)置休眠時間窗為10秒
            @HystrixProperty(name = "circuitBreaker.sleepWindowInMilliseconds",value = "10000"),
               //設(shè)置錯誤百分比 為百分之六十  十次失敗六次熔斷
            @HystrixProperty(name = "circuitBreaker.errorThresholdPercentage",value = "60")
    })

hystrix:
  command: #指令
   default: #全局的
    execution:
     isolation:
      thread:
       timeoutInMilliseconds: 3000 #配置全局超時時長為3秒