当前位置：首页 > news >正文

告别Feign：基于Spring 6.1 RestClient构建高可用声明式HTTP客户端

news 2025/4/26 16:55:00

🧑 博主简介：CSDN博客专家，历代文学网（PC端可以访问：https://literature.sinhy.com/#/?__c=1000，移动端可微信小程序搜索“历代文学”）总架构师，15年工作经验，精通Java编程，高并发设计，Springboot和微服务，熟悉Linux，ESXI虚拟化以及云原生Docker和K8s，热衷于探索科技的边界，并将理论知识转化为实际应用。保持对新技术的好奇心，乐于分享所学，希望通过我的实践经历和见解，启发他人的创新思维。在这里，我希望能与志同道合的朋友交流探讨，共同进步，一起在技术的世界里不断学习成长。
技术合作请加本人wx（注明来自csdn）：foreast_sea

在这里插入图片描述

告别Feign：基于Spring 6.1 RestClient构建高可靠声明式HTTP客户端

文章目录

告别Feign：基于Spring 6.1 RestClient构建高可靠声明式HTTP客户端
- - 引言
  - 一、环境准备（pom.xml）
  - 二、声明式HTTP接口定义
  - 三、同步RestClient配置
  - 四、Token透传实现（同步拦截器）
  - 五、控制器层使用示例
  - 六、核心机制解析
  - 七、方案优势

引言

在微服务架构持续演进的今天，高效的远程服务通信始终是系统设计的核心挑战之一。传统的Spring生态中，RestTemplate长期作为同步HTTP客户端的首选，但其阻塞式模型、繁琐的配置方式以及与现代云原生架构的兼容性问题逐渐显露。随着Spring Framework 6.1的发布，全新的RestClient以更简洁的API设计、更强大的扩展能力登上舞台，标志着Spring在同步HTTP客户端领域的一次革新。

本文聚焦于如何基于Spring Framework 6.1+ 的新特性，构建一套生产级的声明式HTTP通信方案。我们将深入探讨以下核心命题：在非响应式架构下，如何通过RestClient.Builder实现媲美Feign的声明式接口？如何无缝集成Spring Cloud LoadBalancer实现智能负载均衡？如何在同步调用链路中实现安全令牌的自动透传？这些问题的答案不仅关乎代码的优雅性，更直接影响着微服务系统的性能、可维护性和扩展性。

通过剖析RestClient的设计哲学，读者将掌握三大关键技术：

其一，声明式接口驱动开发，借助@HttpExchange注解实现类Feign的简洁定义，告别冗余的模板代码；
其二，深度集成Spring Cloud生态，通过定制ClientHttpRequestInterceptor打通服务发现与负载均衡链路，彻底解决“503 Service Unavailable”和403等典型问题；
其三，工业级连接池配置，基于Apache HttpClient5的精细化连接管理策略，确保高并发场景下的稳定吞吐。

文章还将揭示Spring 6.1+中鲜为人知的高级特性：例如如何通过RestClientAdapter实现与声明式接口的无缝对接，将帮助开发者在传统WebMVC架构中，以零侵入改造的成本，获得接近响应式编程的性能表现。

对于正在面临以下痛点的团队，本文提供了一站式解决方案：

遗留系统需要从RestTemplate向现代客户端迁移。
同步服务调用存在性能瓶颈或连接泄漏问题
需要统一管理多服务的负载均衡与安全认证。
期望在不引入响应式编程的前提下优化资源利用率。

一、环境准备（pom.xml）

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-loadbalancer</artifactId>
</dependency>
<dependency><groupId>org.springframework</groupId><artifactId>spring-web</artifactId><version>6.1.0+</version> <!-- 必须6.1+ -->
</dependency>

二、声明式HTTP接口定义

/**  * <pre>*  调用远程同步角色权限服务*    注：http://horus/horus这个配置，非常关键：*       1. 第一个horus表示远程服务应用的名字（注册到nacos注册中心的应用名，运行期间会被负载均衡拦截并替换成实际的ip和端口）*       2. 第二个horus配置表示远程服务的base上下文路径，即contextPath，如果远程应用不带上下文路径，这里配置成http://horus即可* </pre>* @author sinhy* @since 2022-07-13 17:00* @version V1.0  */
@HttpExchange(url = "http://horus/horus")
public interface AuthoritySyncSDKService
{/*** 同步角色权限* @author sinhy* @since 2022-07-13 16:06  void*/@PostExchange("/syncRoleAuthority")void syncRoleAuthority();
}

三、同步RestClient配置

@Configuration
public class HttpExchangeFluxConfiguration
{/***  @LoadBalanced负载均衡注入，此注解用于标记RestTemplate、RestClient或WebClient.Builder这几类对象。将生成器bean配置为使用LoadBalancerClient。* @author lilinhai* @since 2025-04-15 16:23 * @return WebClient.Builder*/@LoadBalanced@Beanpublic RestClient.Builder loadBalancedWebClientBuilder(){return RestClient.builder().requestFactory(new HttpComponentsClientHttpRequestFactory(httpClient()));}@Beanpublic TokenPropagationExchangeFilterFunction tokenFilter(){return new TokenPropagationExchangeFilterFunction();}@Beanpublic HttpServiceProxyFactory httpServiceProxyFactory(RestClient.Builder restClientBuilder, TokenPropagationExchangeFilterFunction tokenFilter){restClientBuilder.requestInterceptor(tokenFilter);RestClient restClient = restClientBuilder.build();return HttpServiceProxyFactory.builderFor(RestClientAdapter.create(restClient)).build();}private PoolingHttpClientConnectionManager poolingConnManager(){PoolingHttpClientConnectionManager pool = new PoolingHttpClientConnectionManager();// 最大连接数pool.setMaxTotal(200);// 每个路由的最大连接数pool.setDefaultMaxPerRoute(50);return pool;}private HttpClient httpClient(){return HttpClients.custom().setConnectionManager(poolingConnManager()).setConnectionReuseStrategy(new DefaultClientConnectionReuseStrategy()).evictExpiredConnections().evictIdleConnections(TimeValue.ofSeconds(30)).build();}
}

四、Token透传实现（同步拦截器）

/**  * 令牌透传过滤器* @author lilinhai* @since 2025-04-15 14:35* @version V1.0  */
public class TokenPropagationExchangeFilterFunction implements ClientHttpRequestInterceptor
{@Overridepublic ClientHttpResponse intercept(HttpRequest request, byte[] body, ClientHttpRequestExecution execution) throws IOException{// 设置授权信息RequestAttributes ra = RequestContextHolder.getRequestAttributes();if (ra != null){ServletRequestAttributes servletRequestAttributes = (ServletRequestAttributes) ra;String clientInfoJsonStr = servletRequestAttributes.getRequest().getHeader(WebHttpConstant.CLIENT_INFO_HEADER_NAME);if (clientInfoJsonStr != null){request.getHeaders().add(WebHttpConstant.CLIENT_INFO_HEADER_NAME, clientInfoJsonStr);}String acceptLanguage = servletRequestAttributes.getRequest().getHeader(HttpHeaders.ACCEPT_LANGUAGE);if (acceptLanguage != null){request.getHeaders().add(HttpHeaders.ACCEPT_LANGUAGE, acceptLanguage);}}return execution.execute(request, body);}
}

五、控制器层使用示例

@RestController
@RequestMapping("/authority")
public class AuthoritySyncController {private final AuthoritySyncSDKService authoritySyncSDKService;public AuthoritySyncController(AuthoritySyncSDKService authoritySyncSDKService){this.authoritySyncSDKService = authoritySyncSDKService;}@GetMapping("/sync")public void sync() {authoritySyncSDKService.syncRoleAuthority();}
}

六、核心机制解析

负载均衡流程
- 通过自定义ClientHttpRequestInterceptor实现服务发现
- 使用LoadBalancerClient.choose()获取服务实例
- 重写请求URI为实际IP:Port
声明式接口原理
- HttpServiceProxyFactory基于JDK动态代理生成实现类
- 底层使用RestClient执行实际HTTP请求
与RestTemplate方案的差异
- 更现代的流式API配置方式
- 原生支持URI重写拦截器链
- 更好的异常处理机制