Spring Cloud Feign 拦截器

男娘i 2022-10-05 05:59 189阅读 0赞

拦截器可以为每个 HTTP 请求/响应执行各种隐式任务，从身份验证到日志记录。

常用于服务端接口需要验证签名，所以我方在发起请求时要生成签名然后传过去。

> 如果我们同时拥有\*@Configuration\* bean 和配置属性，*配置属性将覆盖@Configuration\*值*\*。

请求拦截器

自定义请求拦截器：

@Bean
    public RequestInterceptor requestInterceptor() { 
      return requestTemplate -> { 
          requestTemplate.header("user", username);
          requestTemplate.header("password", password);
          requestTemplate.header("Accept", ContentType.APPLICATION_JSON.getMimeType());
      };
    }

此外，要将拦截器添加到请求链中，我们只需要将此 bean 添加到我们的\*@Configuration\*类，或者如我们之前所见，在属性文件中声明它：

feign:
      client:
        config:
          default:
            requestInterceptors:
              com.baeldung.cloud.openfeign.JSONPlaceHolderInterceptor

/** * fegin 拦截器 * @return */
        @Bean
        public RequestInterceptor sign() { 
            return template -> { 
    
                // 如果是get请求
                if (template.method().equals(Request.HttpMethod.GET.name())) { 
                    //获取到get请求的参数
                    Map<String, Collection<String>> queries = template.queries();
                }
    
                //如果是Post请求
                if (template.method().equals(Request.HttpMethod.POST.name())) { 
                    //获得请求body
                    String body = template.requestBody().asString();
                    JSONPObject request = JSON.parseObject(body, JSONPObject.class);
                }
    
                //Do what you want... 例如生成接口签名
    
                String sign = "根据请求参数生成的签名";
                //放入url？之后
                template.query("sign", sign);
    
                //放入请求body中
                String newBody = "原有body" + sign;
                template.body(Request.Body.encoded(newBody.getBytes(StandardCharsets.UTF_8), StandardCharsets.UTF_8));
            };
        }