3.Feign 服务异常不进入熔断

2019年10月09日 17:17 · 阅读(2828) ·

基础知识

2.Spring Cloud-熔断器 Hystrix

开发环境

名称 版本
操作系统 Windows 10 X64
JDK JDK1.8（jdk-8u151-windows-x64）
IntelliJ IDEA IntelliJ IDEA 2018.3
Maven Maven 3.6.0

代码说明

本文代码基于 2.引用 lombok 使用 log 基础上进行修改

test-invoice-contract

添加下面的文件

添加类-KeepErrMsgConfiguration

  1. package com.test.invoice.service.hystrix;
  3. import com.alibaba.fastjson.JSON;
  4. import com.test.invoice.excepiton.InternalApiException;
  5. import com.test.invoice.util.ExceptionUtil;
  6. import feign.Response;
  7. import feign.Util;
  8. import feign.codec.ErrorDecoder;
  9. import lombok.extern.slf4j.Slf4j;
  10. import org.springframework.context.annotation.Bean;
  11. import org.springframework.http.HttpStatus;
  13. import java.io.IOException;
  15. /**
  16.  * @Author: 
  17.  * @Description: 保留 feign 服务异常信息
  18.  * @Date: Created in 1:29 2019/7/5
  19.  * 保留原始异常信息
  20.  * 当调用服务时，如果服务返回的状态码不是200，就会进入到Feign的ErrorDecoder中，
  21.  * 因此如果我们要解析异常信息，就要重写ErrorDecoder：
  22.  * Spring Cloud Feign 熔断机制填坑
  23.  * http://www.ciphermagic.cn/spring-cloud-feign-hystrix.html
  24.  * 原理是根据response.body()反序列化为自定义的Result类，提取出里面的message信息，然后抛出RuntimeException，这样当进入到熔断方法中时，获取到的异常就是我们处理过的RuntimeException。
  25.  */
  26. @Slf4j
  27. public class KeepErrMsgConfiguration {
  28.     @Bean
  29.     public ErrorDecoder errorDecoder() {
  30.         return new UserErrorDecoder();
  31.     }
  33.     /**
  34.      * 自定义错误解码器
  35.      */
  36.     public class UserErrorDecoder implements ErrorDecoder {
  37.         @Override
  38.         public Exception decode(String methodKey, Response response) {
  40.             if (response.status() != HttpStatus.OK.value()) {
  41.                 //if (response.status() == HttpStatus.SERVICE_UNAVAILABLE.value()) {
  42.                 try {
  43.                     // 获取原始的返回内容
  44.                     String json = Util.toString(response.body().asReader());
  45.                     InternalApiException internalApiException = JSON.parseObject(json, InternalApiException.class);
  46.                     log.info(" 【===Server Exception===】,{}", ExceptionUtil.getErrorMessage(internalApiException));
  47.                     RuntimeException exception = new RuntimeException(internalApiException.getMessage());
  48.                     return exception;
  49.                 } catch (IOException e) {
  50.                     log.error(e.getMessage(), e);
  51.                     return new RuntimeException("unknown error");
  52.                 }
  53.                 //}
  54.             }
  55.             return new RuntimeException("unknown error");
  57.         }
  58.     }
  59. }

添加类-NotBreakerConfiguration

  1. package com.test.invoice.service.hystrix;
  3. import com.alibaba.fastjson.JSON;
  4. import com.netflix.hystrix.exception.HystrixBadRequestException;
  5. import com.test.invoice.excepiton.InternalApiException;
  6. import com.test.invoice.util.ExceptionUtil;
  7. import feign.Response;
  8. import feign.Util;
  9. import feign.codec.ErrorDecoder;
  10. import lombok.extern.slf4j.Slf4j;
  11. import org.springframework.context.annotation.Bean;
  12. import org.springframework.http.HttpStatus;
  14. import java.io.IOException;
  16. /**
  17.  * @Author:
  18.  * @Description: feign 服务异常不进入熔断
  19.  * @Date: Created in 1:29 2018/6/2
  20.  * 不进入熔断，直接抛出异常
  21.  * 有时我们并不希望方法进入熔断逻辑，只是把异常原样往外抛。
  22.  * 这种情况我们只需要捉住两个点：不进入熔断、原样。
  23.  * 原样就是获取原始的异常,而不进入熔断,需要把异常封装成HystrixBadRequestException，
  24.  * 对于HystrixBadRequestException，Feign会直接抛出，不进入熔断方法。
  25.  */
  26. @Slf4j
  27. public class NotBreakerConfiguration {
  28.     @Bean
  29.     public ErrorDecoder errorDecoder() {
  30.         return new UserErrorDecoder();
  31.     }
  33.     /**
  34.      * 自定义错误解码器
  35.      */
  36.     public class UserErrorDecoder implements ErrorDecoder {
  38.         @Override
  39.         public Exception decode(String methodKey, Response response) {
  40.             Exception exception = null;
  41.             if (response.status() != HttpStatus.OK.value()) {
  42.                 //if (response.status() == HttpStatus.SERVICE_UNAVAILABLE.value()) {
  43.                 try {
  44.                     // 获取原始的返回内容(来自GlobalExceptionHandler类中的返回信息)
  45.                     String json = Util.toString(response.body().asReader());
  46.                     InternalApiException internalApiException = JSON.parseObject(json, InternalApiException.class);
  47.                     log.info(" 【===Server Exception===】,{}", ExceptionUtil.getErrorMessage(internalApiException));
  48.                     exception = new HystrixBadRequestException(internalApiException.getMessage());
  49.                 } catch (IOException e) {
  50.                     log.error(e.getMessage(), e);
  51.                     exception = new HystrixBadRequestException(e.getMessage());
  52.                 }
  53.                 //}
  54.             }
  55.             return exception;
  57.         }
  58.     }
  59. }

修改-TRbtTestConsumer-@FeignClient

  1. package com.test.invoice.service.consumer;
  3. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  4. import com.test.invoice.service.hystrix.NotBreakerConfiguration;
  5. import com.test.invoice.vo.ResponseVO;
  6. import org.springframework.cloud.openfeign.FeignClient;
  7. import org.springframework.web.bind.annotation.*;
  9. import com.test.invoice.data.TRbtTestData;
  10. import com.test.invoice.data.TRbtTestDataParam;
  11. import com.test.invoice.service.hystrix.TRbtTestHystrix;
  13. /**
  14.  * Feign-api 接口定义——TRbtTestConsumer
  15.  *
  16.  * @author:
  17.  * @version:
  18.  * @date: 2019-08-08 14:45
  19.  */
  20. //@FeignClient(value = "service-producer")
  21. //modify by v_hwhao 20190828 加入熔断处理
  22. //@FeignClient(value = "service-producer",fallback = TRbtTestHystrix.class)
  23. //modify by v_hwhao 20190927 - 不进入熔断，直接抛出异常
  24. @FeignClient(value = "service-producer",configuration = NotBreakerConfiguration.class)
  25. public interface TRbtTestConsumer {
  26.     @PostMapping("/Test/Add")
  27.     ResponseVO<String> Add(@RequestBody TRbtTestData data);
  29.     @PostMapping("Test/Update")
  30.     ResponseVO<Boolean> Update(@RequestBody TRbtTestData data);
  32.     @RequestMapping(value="Test/Del",method=RequestMethod.GET)
  33.     ResponseVO<Boolean> Del(@RequestParam(value="name",required = true) String name,@RequestParam(value="version",required = true) String version);
  35.     @PostMapping("/Test/Get")
  36.     ResponseVO<TRbtTestData> Get(@RequestBody TRbtTestData data);
  38.     @PostMapping("/Test/Query")
  39.     ResponseVO<Page<TRbtTestData>> Query(@RequestBody TRbtTestDataParam param);
  40. }

测试

修改test-invoice-service-TRbtTestServiceImpl-Get 方法

  1. @Override
  2. public ResponseVO<TRbtTestData> Get(@RequestBody TRbtTestData data){
  4.     int i = 1 / 0;
  6.     List<TRbtTestEntity> list = baseMapper.selectList(Wrappers.<TRbtTestEntity>lambdaQuery().eq(TRbtTestEntity::getName, data.getName()));
  7.     if(!list.isEmpty()){
  8.         TRbtTestEntity entity = list.get(0);
  9.         data.setName(entity.getName());
  10.         data.setVersion(entity.getVersion());
  11.         return new ResponseVO<>(ResponseCode.OK, data);
  12.     }else{
  13.         return new ResponseVO<>(ResponseCode.PARAM_INVALID, data);
  14.     }
  15. }

1.使用熔断处理的情况

(1)

  1. //modify by v_hwhao 20190828 加入熔断处理
  2. @FeignClient(value = "service-producer",fallback = TRbtTestHystrix.class)
  3. public interface TRbtTestConsumer

(2)使用 Postman 访问 Get 接口

  1. 地址：http://localhost:8080/Inv/Api/Test/Get
  2. Body Raw 参数：{"id":"","name":"测试数据-菲克-1","version":""}

返回结果

  1. {
  2.     "code": 5001,
  3.     "msg": "熔断处理-系统异常",
  4.     "timestamp": 1570608703141
  5. }

2.Feign 服务异常不进入熔断 的情况

(1)

  1. //modify by v_hwhao 20190927 - 不进入熔断，直接抛出异常
  2. @FeignClient(value = "service-producer",configuration = NotBreakerConfiguration.class)
  3. public interface TRbtTestConsumer

(2)使用 Postman 访问 Get 接口

  1. 地址：http://localhost:8080/Inv/Api/Test/Get
  2. Body Raw 参数：{"id":"","name":"测试数据-菲克-1","version":""}

返回结果

  1. {
  2.     "timestamp": "2019-10-09T08:08:09.426+0000",
  3.     "status": 500,
  4.     "error": "Internal Server Error",
  5.     "message": "Request processing failed; nested exception is java.lang.ArithmeticException: / by zero",
  6.     "path": "/Inv/Api/Test/Get"
  7. }