springcloud 组件之 Feign 实战使用（五）

落日映苍穹つ 2022-11-30 04:14 295阅读 0赞

Feign 组件是对 Hystrix 和Ribbon 两个组件的再封装，同时把公用的接口提取出来  简化了代码量，便于统一管理。使用流程如下：

一、使用流程：

1、jar  包引入

<dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-openfeign</artifactId>
    </dependency>

2、启动类注解配置 Feign 的功能，核心代码如下：

@SpringBootApplication(scanBasePackages = {"com.nandao.anan"})
    //注册到eureka
    @EnableEurekaClient
    //开启断路器功能
    @EnableCircuitBreaker
    //开启feign支持，clients指定哪个类开启feign
    @EnableFeignClients(clients = {StudentService.class,TeacherServiceFeign.class})
    //或者指定某个目录
    //@EnableFeignClients(basePackages={"com.info.uas.*","com.info.dts.*"})
    public class MicroWebnoApplication {
        public static void main(String[] args) {
            SpringApplication.run(MicroWebnoApplication.class,args);
        }
    }

3、Feign 的客户端 核心代码配置如下：

/*
    * fallback = StudentServiceFallback.class  可以简单处理异常，不能获取具体异常，相当于Hystrix 的降级方法
    * fallbackFactory = StudentServiceFallbackFactory.class  可以具体分析异常，相当于Hystrix 的降级方法，
    * Feign 没有默认的降级方法
    * */
    @FeignClient(name = "MICRO-ORDER-NO",path = "/feign"
            /*fallback = StudentServiceFallback.class,*/
            ,fallbackFactory = StudentServiceFallbackFactory.class)
    public interface StudentService {
    
        @GetMapping("/student/getAllStudent")
        String getAllStudent();
    
        @PostMapping("/student/saveStudent")
        String saveStudent(@RequestBody Student student);
    }

4、Feign 的服务端controller接口核心代码如下：

@Slf4j
    @RestController
    public class StudentController implements StudentService {
        private org.slf4j.Logger log = LoggerFactory.getLogger(getClass());
    
        @Autowired
        private StudentService studentService;
    
        @RequestMapping("/feign/student/getAllStudent")
        @Override
        public String getAllStudent() {
            return studentService.getAllStudent();
        }
    
        @RequestMapping("/feign/student/saveStudent")
        @Override
        public String saveStudent(@RequestBody Student student) {
            return studentService.saveStudent(student);
        }

5、主要几点：服务端接口必须定义跟 feign 客户端相同的 url;传递和接收的参数类型必须一致。

二、抽取公共方法：

把feign 的接口抽取成公共的api ，作为一个单独的微服务，打成jar ,通过maven 私服，依赖到各微服务中，流程如下：

1、创建单独的公共api 微服务，如图：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70][]

2、其他多个微服务去引用，比如：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 1][]

3、这样就可以相互调用了，此方案耦合性比较强。

三、Feign 的降级，如图：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 2][]

1、两种降级方法核心代码如下图：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 3][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 4][]

final String msg = throwable.getMessage();//这是过滤器得到的结果，再走核心降级方法。

2、此降级方法就是封装的Hystrix 的功能的实现。

四、Feign 的全局过滤器功能，如果接口出现问题，先走过滤器方法，再走降级方法，简单demo如下：

import feign.Response;
    import feign.Util;
    import feign.codec.ErrorDecoder;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    import java.io.IOException;
    
    @Configuration
    public class FeignErrMessageFilter {
    
        @Bean
        public ErrorDecoder errorDecoder() {
            return new FeignErrorDecoder();
        }
    
        /*
        * 当调用服务时，如果服务返回的状态码不是200，就会进入到Feign的ErrorDecoder中
        * {"timestamp":"2020-02-17T14:01:18.080+0000","status":500,"error":"Internal Server Error","message":"/ by            zero","path":"/feign/student/errorMessage"}
        * 只有这种方式才能获取所有的被feign包装过的异常信息
        * 这里如果创建的Exception是HystrixBadRequestException
        * 则不会走熔断逻辑，不记入熔断统计
        * */
        class FeignErrorDecoder implements ErrorDecoder {
            private Logger logger = LoggerFactory.getLogger(FeignErrorDecoder.class);
            @Override
            public Exception decode(String s, Response response) {
                RuntimeException runtimeException = null;
                try {
                    String retMsg = Util.toString(response.body().asReader());
                    logger.info(retMsg);
                    runtimeException = new RuntimeException(retMsg);
                } catch (IOException e) {
                    e.printStackTrace();
                }
                return runtimeException;
            }
        }
    }

这个过滤器是对异常信息的再封装，把 feign 的异常信息封装成我们系统的通用异常对象 ，过滤器把异常返回后，feign 前面定义的降级方法就会调到 create 方法，Feign 我不建议大家使用，流程简单并发不高的方法可以用一用。

Feign 的使用已经介绍完，过程中我们发现 该组件增加了代码的耦合性，使得接口的响应速度变慢（因为封装了Hystrix 和Ribbon功能），所以Feign组件不适合业务场景复杂的接口。下一期我们分析 分布式配置中心，敬请期待！

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70]: /images/20221124/d69a9883d0234cecbb87b58cde9cb541.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 1]: /images/20221124/4e81b7a20a8944899acbc91dcaacd562.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 2]: /images/20221124/77c0171b21694b5b9edf996f4aa517e8.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 3]: /images/20221124/f835c9515472400793f0d71a0de42e9d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 4]: /images/20221124/87ec9edd64204f8cbe4f72688a640b34.png