springcloud 组件之 Feign 实战使用（五）-蒲公英云

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

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;
        }
    }
}