SpringCloud组件OpenFeign之拦截器解读

2023-05-17 17:05:02 组件拦截器解读

springCloud组件OpenFeign之拦截器

OpenFeign组件中有这么一个接口——RequestInterceptor 。

我们来看一下源码中关于这个接口的介绍。

package feign;
 

public interface RequestInterceptor {
 
  
  void apply(RequestTemplate template);
}

通过对该类及方法的注释可以了解到RequestInterceptor接口的apply方法可以对请求进行拦截，可以在该方法中添加请求头信息。

实践一下。

一、创建一个拦截器在请求头中添加traceId信息

场景如下，使用拦截器在请求头中添加traceId属性，服务端可以获取到该traceId，用于日志追踪。

方式一：创建自定义拦截器+@Configuration

package com.example.rtbootconsumer.config.interceptor;
 
import com.example.rtbootconsumer.common.utils.TraceIdUtil;
import feign.Request;
import feign.RequestInterceptor;
import feign.RequestTemplate;
import org.apache.commons.lang3.StringUtils;
import org.springframework.context.annotation.Configuration;
 

@Configuration
public class FeignRequestInterceptor implements RequestInterceptor {
 
    
    @Override
    public void apply(RequestTemplate template) {
        String traceId = TraceIdUtil.getTraceId();
        if (StringUtils.isNotEmpty(traceId)) {
            template.header("traceId", traceId);
        }
    }
}

方式二：创建自定义拦截器+配置@FeignClient注解的configuration属性

package com.example.rtbootconsumer.config.interceptor;
 
import com.example.rtbootconsumer.common.utils.TraceIdUtil;
import feign.Request;
import feign.RequestInterceptor;
import feign.RequestTemplate;
import org.apache.commons.lang3.StringUtils;
import org.springframework.context.annotation.Configuration;
 

public class FeignRequestInterceptor implements RequestInterceptor {
 
    
    @Override
    public void apply(RequestTemplate template) {
        String traceId = TraceIdUtil.getTraceId();
        if (StringUtils.isNotEmpty(traceId)) {
            template.header("traceId", traceId);
        }
    }
}

package com.example.rtbootconsumer.feignservice;
 
import com.example.rtbootconsumer.pojo.User;
import com.example.rtbootconsumer.vo.ResultBody;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.WEB.bind.annotation.*;
 
import java.util.List;
 
 
@FeignClient(name = "service-provider", path = "/testComm", url = "${addr.url}",configuration = FeignRequestInterceptor.class)
public interface UserFeignService {
 
    @PostMapping(value = "/getUser")
    public ResultBody<User> getUser(@RequestBody User user);
}

二、创建两个拦截器

也可以同时创建多个拦截器实现拦截器链的功能。

此时再创建一个拦截器FeignRequestInterceptor2，用于在请求头中设置属性名为test，值为lalala信息。

方式一：同上

package com.example.rtbootconsumer.config.interceptor;
 
import com.example.rtbootconsumer.common.utils.TraceIdUtil;
import feign.Request;
import feign.RequestInterceptor;
import feign.RequestTemplate;
import org.apache.commons.lang3.StringUtils;
import org.springframework.context.annotation.Configuration;
 

@Configuration
public class FeignRequestInterceptor2 implements RequestInterceptor {
 
    
    @Override
    public void apply(RequestTemplate template) {
        String traceId = TraceIdUtil.getTraceId();
        if (StringUtils.isNotEmpty(traceId)) {
            template.header("test", "lalala");
        }
    }
}

方式二：同上，注意这里设置的@FeignClient注解的configuration属性值是两个拦截器的class数组。

package com.example.rtbootconsumer.feignservice;
 
import com.example.rtbootconsumer.pojo.User;
import com.example.rtbootconsumer.vo.ResultBody;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.*;
 
import java.util.List;
 
 
@FeignClient(name = "service-provider", path = "/testComm", url = "${addr.url}",configuration = {FeignRequestInterceptor.class,FeignRequestInterceptor2.class})
public interface UserFeignService {
 
    @PostMapping(value = "/getUser")
    public ResultBody<User> getUser(@RequestBody User user);
 
    @PostMapping(value = "/testList")
    public ResultBody<List<User>> testList(@RequestBody List<User> list);
}

三、注意

在创建并配置拦截器时有两点需要特别注意。

1.在使用方式一去创建拦截器时

会拦截所有请求。用方式二时若@FeignClient注解的configuration属性未设置拦截器，那么并不会拦截该接口下所有方法的请求。拦截器只会拦截所有configuration属性值设置了拦截器的接口下所有方法的请求。因此使用方式二更灵活。

2.拦截器执行顺序

若使用方式一去创建多个拦截器时，正如前面注释所讲，不能保证拦截器的执行顺序。

但是使用方式二则可以控制拦截器的执行顺序，拦截器的执行顺序和@FeignClient注解中configuration属性中拦截器的配置顺序有关。

若配置为 {FeignRequestInterceptor.class,FeignRequestInterceptor2.class})，则会先执行FeignRequestInterceptor中的拦截，再执行FeignRequestInterceptor2中的拦截。

若配置为 {FeignRequestInterceptor2.class,FeignRequestInterceptor.class})，则会先执行FeignRequestInterceptor2中的拦截，再执行FeignRequestInterceptor中的拦截。有兴趣的可以试一下。

总结

以上为个人经验，希望能给大家一个参考，也希望大家多多支持。

相关文章

SpringCloud组件OpenFeign之拦截器解读

目录