Spring Boot 中使用 Feign 调用内网 IP 接口并记录入参与出参

在微服务架构中，服务间的通信是常见的需求。Spring Cloud 提供的 Feign 客户端是一个声明式的 Web 服务客户端，它使得服务间的调用变得非常简单。然而，在实际开发中，我们可能需要调用内网 IP 地址的接口，并且希望记录请求的入参和响应的出参，以便于调试和监控。本文将详细介绍如何实现这一需求。

1. Feign 简介

Feign 是一个基于 Java 的声明式 Web 服务客户端，它使得编写 HTTP 客户端变得更加容易。通过 Feign，你可以使用接口和注解的方式定义与远程服务的交互，而无需编写复杂的 HTTP 请求代码。Feign 与 Spring Cloud 集成后，可以方便地在 Spring Boot 项目中使用。

2. 调用内网 IP 接口

在某些场景下，我们需要调用内网 IP 地址的接口。例如，你的微服务部署在内网环境中，需要访问其他内网服务。Feign 支持直接指定服务的 URL，这使得调用内网 IP 接口变得非常简单。

2.1 配置 Feign 客户端

在 Spring Boot 项目中，可以通过 @FeignClient 注解的 url 属性直接指定内网 IP 地址。例如：

import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;@FeignClient(value = "inner-service", url = "http://192.168.1.100:8080")
public interface InnerServiceClient {@GetMapping("/api/endpoint")String getSomeData();
}

在上述代码中，value 属性用于标识服务名称，而 url 属性直接指定了内网 IP 地址和端口。

3. 记录入参和出参

为了更好地调试和监控，我们可能需要记录请求的入参和响应的出参。Feign 提供了强大的拦截器机制，可以通过实现 RequestInterceptor 和 Decoder 接口来实现这一需求。

3.1 自定义请求拦截器

请求拦截器可以在请求发送前对请求进行处理。通过实现 RequestInterceptor 接口，我们可以记录请求的入参：

import feign.RequestInterceptor;
import feign.RequestTemplate;
import lombok.extern.slf4j.Slf4j;@Slf4j
public class FeignRequestInterceptor implements RequestInterceptor {@Overridepublic void apply(RequestTemplate requestTemplate) {// 获取请求的入参String requestBody = new String(requestTemplate.request().body(), StandardCharsets.UTF_8);log.info("Feign 请求入参：{}", requestBody);}
}

3.2 自定义响应拦截器

响应拦截器可以在响应解码时对响应进行处理。通过实现 Decoder 接口，我们可以记录响应的出参：

import feign.FeignException;
import feign.Request;
import feign.Response;
import feign.codec.DecodeException;
import feign.codec.Decoder;
import io.micrometer.core.instrument.util.IOUtils;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
import java.lang.reflect.Type;
import java.nio.charset.StandardCharsets;@Slf4j
public class FeignLogDecoder implements Decoder {private final Decoder delegate;public FeignLogDecoder(Decoder delegate) {this.delegate = delegate;}@Overridepublic Object decode(Response response, Type type) throws IOException {// 获取响应体String responseBody = IOUtils.toString(response.body().asInputStream(), StandardCharsets.UTF_8);log.info("Feign 响应出参：{}", responseBody);// 将响应体重新写入 Response 对象中，供后续处理return delegate.decode(response.toBuilder().body(responseBody, StandardCharsets.UTF_8).build(), type);}
}

3.3 配置 Feign 客户端

将自定义的拦截器和解码器注册到 Feign 客户端中：

import feign.codec.Decoder;
import feign.optionals.OptionalDecoder;
import org.springframework.cloud.openfeign.support.ResponseEntityDecoder;
import org.springframework.cloud.openfeign.support.SpringDecoder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class FeignConfig {@Beanpublic RequestInterceptor requestInterceptor() {return new FeignRequestInterceptor();}@Beanpublic Decoder feignDecoder() {return new FeignLogDecoder(new OptionalDecoder(new ResponseEntityDecoder(new SpringDecoder())));}
}

3.4 使用 Feign 客户端

在 Feign 客户端中使用自定义的配置类：

import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;@FeignClient(value = "inner-service", url = "http://192.168.1.100:8080", configuration = FeignConfig.class)
public interface InnerServiceClient {@GetMapping("/api/endpoint")String getSomeData();
}

4. 配置 Feign 日志级别

为了更好地调试和记录日志，可以在 application.yml 或 application.properties 文件中配置 Feign 的日志级别：

logging:level:com.example.feign: DEBUG

5. 注意事项

网络连通性：确保调用方服务可以访问内网 IP 地址。如果调用方和被调用方不在同一网络，可能需要配置代理或网关。
安全性：内网 IP 地址通常不暴露在公网中，确保网络环境安全，避免敏感信息泄露。
服务发现：如果你使用了服务发现（如 Eureka 或 Consul），可以直接通过服务名调用，而不需要硬编码 IP 地址。如果必须使用 IP 地址，确保 IP 地址不会频繁变动。
性能影响：记录日志可能会对性能产生一定影响，建议在生产环境中根据实际需求调整日志级别。
线程安全：RequestTemplate 和 Response 是线程安全的，因此在拦截器中直接操作这些对象是安全的。
敏感信息处理：如果请求或响应中包含敏感信息（如密码、令牌等），需要在日志中进行脱敏处理。