Spring-Cloud之Feign


Feign的引入可以让我们通过接口注解的形式实现服务间的调用,让调用者无需再关心接口地址这些配置,同时对于接口需要的参数能够更清晰地了解,简化了调用的流程。下面我们通过一些Feign的示例带你快速了解如何使用它。示例使用的Spring-Cloud的版本是Hoxton.SR8,Spring-Boot的版本是2.3.4.RELEASE。示例项目的源代码

添加相关的依赖

feign中已经对ribbon进行集成支持,在spring最新版本已经开始弃用ribbon了,而推荐使用Cloud LoadBalancer(feign也支持)。

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

如果使用Cloud LoadBalancer需要引入如下依赖:

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

使用示例

feign其实是一个伪RPC的组件;我们之前在服务间调用需要的使用者去手动设置请求地址,在加入ribbon后,虽然省略了具体的服务器地址和端口,但是接口地址还是需要手动编写;而引入feign后就可以解决这个问题,由接口的开发者提供给调用者一个接口类的方法的jar包,调用者直接依赖该包,然后注入该接口类即可像调用方法一样调用其他的服务。同时feign提供了在方法调用失败时的处理策略。这样如果接口地址发生改变了,那么只需要更新jar包即可;同时调用者在使用的时候也会更加清晰具体的参数。

要使feign生效,我们还需要在启动类上添加如下注解来启用feign:@EnableFeignClients ;下面对该注解主要的属性进行说明:

  • value和name:服务名称;这个2个随意选择一个配置即可;
  • path:请求路径的前缀;当多个接口地址有相同的前缀时,可以将前缀配置到path中;
  • fallback和fallbackFactory:这2个都是对接口熔断降级处理,也就是异常处理,只能选择其中一个;
  • url: 就是我们直接使用对应接口的真实地址,不再使用负载均衡了。
  • decode404:配置在发生异常的时候;用404替代抛出FeignException异常,替代为404异常。
  • configuration:指定自定义的配置类。

简单示例

定义一个接口,在里面编写需要调用的某个服务的restful接口,然后在类上添加 @FeignClient ,在上面配置要调用的服务名称,也就是说feign会帮助我们拼接这个请求地址(也就是我们在ribbon那里做的事情),因此必须正确才可以。

@FeignClient(name = "feign-server-b") // 服务名称,必须匹配,否则待会将无法替换为真实的地址
public interface GoodsFeignClientDemo1 {

    /**
     * 这里的路径必须和对应要调用的接口地址对应
     */
    @GetMapping("/goods")
    Goods findById(@RequestParam(value = "id")Long id);
}

如果想直接调用即当做http请求工具使用则配置如下:

@FeignClient(name = "feign-server-b", url="https://xxx.xxx") // 直接使用真实的地址
public interface GoodsFeignClientDemo1 {

    /**
     * 这里的路径必须和对应要调用的接口地址对应
     */
    @GetMapping("/goods")
    Goods findById(@RequestParam(value = "id")Long id);
}

在业务代码中使用

@Service
public class OrderServiceImpl implements OrderService {
    
    // 注入该接口的feign接口
    @Autowired
    private GoodsFeignClientDemo1 goodsFeignClientDemo1;

    @Override
    public void demo1() {
        Goods goods = goodsFeignClientDemo1.findById(1L);
        System.out.println("示例1:"+goods);
    }
}

编写feign客户端接口的参数注解示例

由于feign最终是要根据我们编写的接口方法来组装请求的参数和方式的,因此为了让feign能够正常识别我们的参数,需要加上相关注解才可行;比如GET请求的参数加上@RequestParam注解,如果是个对象就需要加上@SpringQueryMap注解。下面是一些常用的示例。

  • GET请求参数中有多个参数
@GetMapping("/goods/demo2")
Goods findById(@RequestParam(value = "id") Long id, @RequestParam(value = "goodsName")String goodsName);
  • GET请求参数是一个自定义对象
@GetMapping("/goods/demo3")
Goods findById(@SpringQueryMap GoodsParams params);
  • GET请求参数是一个自定义对象和普通类型的组合
@GetMapping("/goods/demo4")
Goods findById(@SpringQueryMap GoodsParams params, @RequestParam(value = "id") Long id);
  • GET请求参数在URL路径上
@GetMapping("/goods/demo5/{id}")
Goods findGoods(@PathVariable(value = "id") Long id);
  • 请求参数在body里面
@PostMapping("/goods/demo6")
String checkGoods(@RequestBody GoodsParams params);

为feign添加接口异常处理

可以通过配置@EnableFeignClients注解的fallback或者是fallbackFactory的属性来实现在请求接口异常时返回默认的数据。注意需要在配置中打开feign的hystrix配置:

feign:
  hystrix:
    enabled: true

使用fallback

注意:使用fallback无法打印具体的异常信息

@FeignClient(name = "feign-server-b", fallback = GoodsFeignClientFallback.class)
public interface GoodsFeignClientDemo3 {

    @GetMapping("/goods")
    Goods findById(@RequestParam(value = "id")Long id);
}

异常处理实现类

@Component
public class GoodsFeignClientFallback implements GoodsFeignClientDemo3 {

    @Override
    public Goods findById(Long id) {
        System.out.println(id+"请求接口异常");
        return null;
    }
}

使用fallbackFactory

@FeignClient(name = "feign-server-b", fallbackFactory = GoodsFeignClientFallbackFactory.class)
public interface GoodsFeignClientDemo4 {
    
    @GetMapping("/goods")
    Goods findById(@RequestParam(value = "id")Long id);
}

异常处理实现类

@Component
public class GoodsFeignClientFallbackFactory implements FallbackFactory<GoodsFeignClientDemo4> {
    @Override
    public GoodsFeignClientDemo4 create(Throwable throwable) {
        // 这里通过匿名实现
        return new GoodsFeignClientDemo4() {
            @Override
            public Goods findById(Long id) {
                // 这里可以进行异常的处理
                System.out.println(id+"请求接口异常: "+throwable.getMessage());
                return null;
            }
        };
    }
}

通过feign自定义拦截器实现请求统一参数添加

当我们需要在请求中添加一些默认的统一参数,那么可以通过添加自定义拦截器来实现。首先需要实现RequestInterceptor接口

public class CustomRequestInterceptor implements RequestInterceptor {

    @Override
    public void apply(RequestTemplate requestTemplate) {
        System.out.println("拦截请求...做统一处理");
        requestTemplate.header("uid", "9527");
    }
}

定义bean配置类

public class FeignConfiguration {

    @Bean
    public RequestInterceptor requestInterceptor(){
        return new CustomRequestInterceptor();
    }
}

在feignClient上配置

@FeignClient(name = "feign-server-b", configuration = FeignConfiguration.class)
public interface GoodsFeignClientDemo5 {

    @GetMapping("/goods")
    Goods findById(@RequestParam(value = "id") Long id);
}

一些可能遇见的问题

当一个服务需要暴露的接口较多时,通常我们会选择分模块分包分类来处理,此时对一个服务来说就要定义多个feign client接口;由于最终bean的名称是根据服务名来生成,因此或出现同名的bean导致启动失败。也就是会出现如下提示:

2021-05-17 17:02:49.325 ERROR 39740 --- [           main] o.s.b.d.LoggingFailureAnalysisReporter   : 

***************************
APPLICATION FAILED TO START
***************************

Description:

The bean 'feign-server-b.FeignClientSpecification' could not be registered. A bean with that name has already been defined and overriding is disabled.

Action:

Consider renaming one of the beans or enabling overriding by setting spring.main.allow-bean-definition-overriding=true

这样只需要在配置文件里面加上如下配置即可:spring.main.allow-bean-definition-overriding=true

同时项目中接口地址和feign中地址必须保持唯一(也就是RequestMapping中配置的值),否则将可能会出现问题。

feign配置

对请求参数和响应的数据进行压缩,默认是没有开启的。

feign:
  compression:
    # 请求和响应压缩配置
    request:
      enabled: true
      mime-types: text/xml,application/xml,application/json
      min-request-size: 2048
    response:
      enabled: true

对服务进行个性化配置

feign:
  client:
    config:
      # 全局配置
      default:
        connectTimeout: 1000
        readTimeout: 1000
        loggerLevel: BASIC
      # 单独某个服务配置
      feign-server-b:
        connectTimeout: 5000
        readTimeout: 5000
        loggerLevel: full

在开发测试环境打开feign的请求日志打印

feign:
  client:
    config:
      # 单独某个服务配置
      feign-server-b:
        connectTimeout: 5000
        readTimeout: 5000
        loggerLevel: full
# 将feign客户端请求类的日志级别调整为 DEBUG  
logging.level.top.vchar.feign.GoodsFeignClientDemo5: DEBUG

加上之后控制台会打印如下日志:

...
2021-05-18 10:10:15.551 DEBUG 41344 --- [eign-server-b-1] top.vchar.feign.GoodsFeignClientDemo5    : [GoodsFeignClientDemo5#findById] ---> GET http://feign-server-b/goods?id=1 HTTP/1.1
2021-05-18 10:10:15.551 DEBUG 41344 --- [eign-server-b-1] top.vchar.feign.GoodsFeignClientDemo5    : [GoodsFeignClientDemo5#findById] Accept-Encoding: gzip
2021-05-18 10:10:15.551 DEBUG 41344 --- [eign-server-b-1] top.vchar.feign.GoodsFeignClientDemo5    : [GoodsFeignClientDemo5#findById] Accept-Encoding: deflate
2021-05-18 10:10:15.551 DEBUG 41344 --- [eign-server-b-1] top.vchar.feign.GoodsFeignClientDemo5    : [GoodsFeignClientDemo5#findById] uid: 9527
2021-05-18 10:10:15.551 DEBUG 41344 --- [eign-server-b-1] top.vchar.feign.GoodsFeignClientDemo5    : [GoodsFeignClientDemo5#findById] ---> END HTTP (0-byte body)
...

特别提醒:扫码关注微信订阅号'起岸星辰',实时掌握IT业界技术资讯! 转载请保留原文中的链接!
  目录