前言

1、基于Ribbon实现

1、在服务消费者中，导入依赖

<!-- hystrix 依赖 --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-hystrix</artifactId></dependency>

2、在服务消费者调用feign的service中添加注解

@HystrixCommand(commandProperties={// 10s 内请求数大于 10 个就启动熔断器，当请求符合熔断条件，触发 fallbackMethod 默认 20 个@HystrixProperty(name= HystrixPropertiesManager.CIRCUIT_BREAKER_REQUEST_VOLUME_THRESHOLD,
            value="10"),// 请求错误率大于 50% 就启动熔断器，然后 for 循环发起重试请求，当请求符合熔断触发条件触发 fallbackMethod@HystrixProperty(name= HystrixPropertiesManager.CIRCUIT_BREAKER_ERROR_THRESHOLD_PERCENTAGE,
            value="50"),// 熔断多少秒后去重试请求，默认 5s@HystrixProperty(name= HystrixPropertiesManager.CIRCUIT_BREAKER_SLEEP_WINDOW_IN_MILLISECONDS,
            value="5000")},fallbackMethod="selectOrderByIdFallback")@Overridepublic OrderselectOrderById(Integer id){// 手动制造异常if(id==1){thrownewRuntimeException("查询主键为1的订单信息导致异常");}returnnewOrder(id,"order-001","中国",22788D,
                productFeign.selectProductList());}

3、编写降级处理，和注解中的fallbackMethod保持一致
（在添加@HystrixCommand注解的方法的同一类中添加即可）

// 托底数据public OrderselectOrderByIdFallback(Integer id){returnnewOrder(id,"托底No","托底地址",55242D, null);}

4、启动类中添加注解：

@EnableCircuitBreaker

5、测试

2、基于Feign实现

1、创建降级处理的类，实现我们的 FeignClient
重写 FeignClient 的所有方法，方法体就是请求该外部请求失败之后进行降级处理，我们这里就直接打个日志，然后返回null了。

@Component@Slf4jpublicclassMyFeignClientFallbackimplementsMyFeignClient{@Overridepublic StringcommunityArticle(String label){
        log.error("communityArticle method timed out.");return null;}@Overridepublic StringinteractiveInfo(Map<String, Object> map){
        log.error("interactiveInfo method timed out.");return null;}@Overridepublic PayVOpayments(String openId, String token, String ip, PaymentParam param){
        log.error("payments method timed out.");
        PayVO payVO=newPayVO();
        payVO.setCode("408");
        payVO.setMessage("payments method timed out");return payVO;}@Overridepublic PayTypeVOpayTypes(String token, String orderId){
        log.error("payTypes method timed out.");
        PayTypeVO payTypeVO=newPayTypeVO();
        payTypeVO.setCode("408");
        payTypeVO.setMessage("payTypes method timed out");return payTypeVO;}@Overridepublic RecordorderDetail(String token, String orderId){
        log.error("orderDetail method timed out.");
        Record record=newRecord();
        record.setCode("408");
        record.setMessage("orderDetail method timed out");return record;}}

2、在 FeignClient 上添加 fallback 属性

3、修改配置文件：

feign:hystrix:enabled:true#在30秒内，发生20次以上的请求时，假如错误率达到50%以上，则断路器将被打开。hystrix:command:default:# 或者填写具体的服务名称execution:isolation:thread:timeoutInMilliseconds:5000#请求超时时间circuitBreaker:sleepWindowInMilliseconds:30000#窗口期requestVolumeThreshold:20#请求阈值errorThresholdPercentage:50#错误百分比阈值

到这里就完成了。可是如果远程服务报错了，具体的报错信息，如何获得呢。

2.1Feign服务异常信息捕获

在上一个示例的基础上
1、给 FeignClient 添加 fallbackFactory 属性
fallback 属性替换成fallbackFactory

@FeignClient(value="service-product", fallbackFactory= ProductFeignFallbackFactory.class)

2、编写降级处理类

@ComponentpublicclassProductFeignFallbackFactoryimplementsFallbackFactory<ProductFeign>{// 捕获日志，在需要捕获异常的方法中进行处理
    Logger logger= LoggerFactory.getLogger(ProductFeignFallbackFactory.class);@Overridepublic ProductFeigncreate(Throwable throwable){returnnewProductFeign(){@Overridepublic List<Product>selectProductList(){
                logger.error("service-product 服务出现异常，异常信息："+ throwable);return Arrays.asList(newProduct(-1,"托底数据",999,85652D));}@Overridepublic ProductselectProductById(Integer id){
                logger.error("service-product 服务出现异常，异常信息："+ throwable);returnnewProduct(-1,"托底数据",999,85652D);}};}}

注意：降级处理类上不要遗忘了@Component注解
到这里就结束了。