@RestController
@RequestMapping("/hystrix")
@DefaultProperties(defaultFallback = "timeOutFallbackMethod")
public class HystrixController {
    @Autowired
    private IHystrixService iHystrixService;
    @GetMapping("/error")
    @HystrixCommand
    public String errorMethod() {
        int i = 10 / 0;
        return iHystrixService.fallBackMethodOk();
    }
    @GetMapping("/timeOut")
    @HystrixCommand(fallbackMethod = "timeOutFallbackMethod", commandProperties = {
            //超過(guò)2秒及服務(wù)降級(jí)
            @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "2000")
    })
    public String timeOutMethod() throws InterruptedException {
        //線程睡眠3秒
        return iHystrixService.timeOutMethod();
    }
    /**
     * 降級(jí)方法
     *
     * @return
     */
    private String timeOutFallbackMethod() {
        return "服務(wù)訪問失敗，降級(jí)處理";
    }
}

@RestController
@AllArgsConstructor
@RequestMapping("/provider")
public class HystrixProviderController {
    @Autowired
    private HystrixService hystrixService;
    /**
     * 模擬接口錯(cuò)誤場(chǎng)景
     * @return
     */
    @GetMapping("/executeProviderMethod1")
    public String executeProviderMethod1(){
        int i =5/0;
        String result = hystrixService.errorMethod();
        return result;
    }
}

@FeignClient(contextId = "hystrixService", value = "Lxlxxx-system", fallbackFactory = HystrixFallbackFactory.class)
public interface HystrixService {
    /**
     * 異常方法
     *
     * @return
     */
    @GetMapping("/hystrix/error")
    public String errorMethod();
    /**
     * 超時(shí)方法
     *
     * @return
     */
    @GetMapping("/hystrix/timeOut")
    public String timeOutMethod();
}

@Component
@Slf4j
public class HystrixFallbackFactory implements FallbackFactory<HystrixService> {
    @Override
    public HystrixService create(Throwable cause) {
        log.error("用戶服務(wù)調(diào)用失敗:{}", cause.getMessage());
        return new HystrixService() {
            @Override
            public String errorMethod() {
                return "觸發(fā)system 服務(wù)的降級(jí)方法";
            }
            @Override
            public String timeOutMethod() {
                return null;
            }
        };
    }
}

@Service
@Slf4j
public class HystrixServiceImpl implements IHystrixService {
    //服務(wù)熔斷
    @HystrixCommand(fallbackMethod = "fallback",commandProperties = {
            @HystrixProperty(name = "circuitBreaker.enabled",value = "true"),  //是否開啟斷路器
            @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold",value = "5"),   //請(qǐng)求次數(shù)
            @HystrixProperty(name = "circuitBreaker.sleepWindowInMilliseconds",value = "10000"),  //時(shí)間范圍
            @HystrixProperty(name = "circuitBreaker.errorThresholdPercentage",value = "60"), //失敗率達(dá)到多少后跳閘
    })
    @Override
    public String countError(Integer count){
        //模擬報(bào)錯(cuò)
        if (count > 0){
            throw new RuntimeException("*****count 必須大于0");
        }
        return Thread.currentThread().getName()+"\t"+"調(diào)用成功";
    }
    public String fallback(Integer count){
        return "count 必修大于0    count: " +count;
    }
}