
本项目代码:https://gitee.com/yunjiao-source/tutorials4j/tree/master/framework
在微服务架构中,服务间的HTTP调用无处不在。一个可靠、可观测的HTTP客户端基础设施,能够极大地提升问题排查效率和开发体验。本文围绕一套完整的Spring Boot HTTP客户端配置方案,深入分析其日志记录、异常处理及默认头注入的实现思路与代码细节。
在Spring生态中,我们通常使用三种方式发起HTTP请求:
RestTemplate(传统同步阻塞)RestClient(Spring Boot 3.2+ 新同步客户端)WebClient(响应式非阻塞)面对多种客户端,我们希望统一实现:
X-Request-Id、Authorization等公共头。traceId/spanId,便于日志关联。本文分析的代码正是为了满足上述需求而设计,支持三种客户端的一致配置。
tutorials4j.framework.web
├── rest
│ ├── util
│ │ └── RestUtils.java // 公共工具 + WebClient Filter 工厂
│ └── interceptor
│ └── LogClientHttpRequestInterceptor.java // RestTemplate/RestClient 拦截器
├── rest.autoconfigure
│ ├── ClientLoggerConfiguration.java // 日志自动配置
│ └── ClientDefaultConfiguration.java // 默认头 + 异常处理自动配置
└── core.properties
└── WebClientProperties.java // 配置属性类核心设计思想:**通过自动配置向容器中的客户端构建器(Builder/Customizer)添加行为,从而无侵入地增强所有客户端实例**。
RestUtils – 通用工具与WebClient扩展点RestUtils 提供了三个关键能力:
public static String generateTraceId() {
return IdUtil.fastSimpleUUID();
}
public static String generateSpanId() {
return IdUtil.fastSimpleUUID().substring(0, 8);
}利用hutool工具生成简化UUID,便于在日志中追踪单次请求链路。开发者可在请求头中携带这些ID,并在下游服务中传递。
public static ExchangeFilterFunction ofCatchExcepitonLogger() {
return ExchangeFilterFunction.ofResponseProcessor(response -> {
if (response.statusCode().value() > 300) {
return response.bodyToMono(String.class)
.flatMap(body -> Mono.error(new WebFrameworkException("接口调用异常: " + body)));
}
return Mono.just(response);
});
}**关键点**:
>=300的状态码(包括301/302重定向、4xx/5xx)视为异常。public static ExchangeFilterFunction ofClientRequestLogger() {
return ExchangeFilterFunction.ofRequestProcessor(request -> {
requestLoggerDetails(request);
return Mono.just(request);
});
}通过requestLoggerDetails和responseLoggerDetails两个私有辅助方法,将请求方法、URL、所有头部以及响应状态码、所有头部以INFO级别输出。输出格式清晰:
[ClientRequest]请求: GET https://api.example.com/data
请求头列表:
Accept=application/json
Authorization=Bearer xxxx**设计亮点**:将请求/响应头日志分离为独立的Filter,便于按需组合(例如只记录请求,不记录响应)。
LogClientHttpRequestInterceptor – 同步客户端拦截器对于RestTemplate和RestClient(底层同样基于ClientHttpRequestInterceptor),实现了统一的ClientHttpRequestInterceptor接口:
@Override
public ClientHttpResponse intercept(HttpRequest request, byte[] body, ClientHttpRequestExecution execution) throws IOException {
HttpRequestUtils.requestLogger(request, body); // 记录请求
ClientHttpResponse response = execution.execute(request, body);
HttpRequestUtils.responseLogger(response); // 记录响应
return response;
}这里将日志记录委托给一个外部的工具类HttpRequestUtils(未给出具体实现,但预期会打印请求行、请求头、响应状态码、响应头等信息)。这种委托模式保持了RestUtils和HttpRequestUtils的职责分离。
ClientLoggerConfiguration – 日志自动配置该配置类负责向三种客户端**无条件**添加日志记录能力:
@Bean
RestTemplateCustomizer logHeadersRestTemplateCustomizer() {
return restTemplate -> restTemplate.getInterceptors().add(new LogClientHttpRequestInterceptor());
}
@Bean
RestClientCustomizer logHeadersRestClientCustomizer() {
return restClientBuilder -> restClientBuilder.requestInterceptor(new LogClientHttpRequestInterceptor());
}
@Bean
WebClientCustomizer logHeadersWebClientCustomizer() {
return webClientBuilder -> {
webClientBuilder.filter(RestUtils.ofClientRequestLogger());
webClientBuilder.filter(RestUtils.ofClientResponseLogger());
};
}**核心机制**:Spring Boot的RestTemplateCustomizer、RestClientCustomizer、WebClientCustomizer会扫描所有Bean,并自动应用到应用创建的客户端实例上。因此开发者不需要手动为每个RestTemplate添加拦截器。
ClientDefaultConfiguration – 默认头与异常处理此类提供两个核心增强:
@Bean
RestTemplateRequestCustomizer<ClientHttpRequest> defaultHeadersRestTemplateRequestCustomizer(WebClientProperties properties) {
return request -> properties.getDefaultHeaders().forEach(request.getHeaders()::set);
}RestTemplateRequestCustomizer是Spring Boot 2.x之后提供的接口,与RestTemplateCustomizer配合,作用于每次请求创建时。RestClient和WebClient也通过各自的Customizer添加默认头。WebClientProperties绑定配置前缀(如tutorials4j.web.client.default-headers),用户可在application.yml中配置:
tutorials4j:
web:
client:
default-headers:
X-Source: my-app
Accept-Language: zh-CN@Bean
WebClientCustomizer defaultWebClientCustomizer() {
return restClientBuilder -> restClientBuilder.filter(RestUtils.ofCatchExcepitonLogger());
}注意:该方法返回的WebClientCustomizer会添加异常捕获Filter,但仅对响应式WebClient生效。**为什么不给RestTemplate/RestClient添加类似处理?** 因为它们通常使用ErrorHandler机制,或者开发者可以在调用处自行捕获RestClientException。当然,你也可以扩展RestTemplate的ResponseErrorHandler实现类似功能,但本文方案未包含(留给读者自行扩展)。
WebClientProperties – 配置属性简单的@ConfigurationProperties类,用于承载defaultHeaders。通过@Data简化getter/setter,并提供了默认空HashMap避免NPE。
tutorials4j.web.client.default-headers:
X-Trace-Id: ${TRACE_ID:unknown}RestTemplate、RestClient、WebClient,自动拥有日志和默认头能力。traceId,可以在创建请求时利用RestUtils.generateTraceId()设置到请求头中。RestUtils.ofCatchExcepitonLogger()中调用了response.bodyToMono(String.class),这会消费掉body,后续如果业务代码还想读取body会失败。因此建议只将此Filter置于最顶层(如全局异常处理),或者除了记录错误消息外不依赖body内容。RestTemplate的日志拦截器和底层ClientHttpRequestFactory的日志,可能会产生重复输出。本例中仅靠拦截器输出一次,是合理的。可以在RestUtils中增加一个ExchangeFilterFunction,自动从当前上下文(如MDC或Reactor Context)中提取traceId,并添加到请求头中。类似地,LogClientHttpRequestInterceptor也可以做相同事情。
当前代码未涉及重试和超时,但可以基于同样的Customizer机制添加WebClient的exchangeStrategies、RestTemplate的RequestConfig等。
如果需要打印响应体,可以将日志Filter修改为exchangeFilterFunction包裹,在获取body后打印再重新生成新的ClientResponse(需缓冲body)。但注意性能和大响应体可能导致内存问题。
本文展示了一套生产级的Spring Boot HTTP客户端统一配置方案。通过合理利用Spring Boot提供的Customizer钩子,以及WebClient的Filter机制,实现了日志记录、默认头注入、异常转换等通用能力。这套模式在微服务网关、业务服务调用外部API等场景下非常实用,能大幅提升可观测性和代码复用性。
开发者可以将这些配置封装为一个独立的spring-boot-starter,引入后即获得全自动的客户端增强,减少重复劳动,专注核心业务逻辑。
阅读最新文章,请关注我的微信公众号: 杨运交
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。