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

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

🧑 博主简介:CSDN博客专家历代文学网(PC端可以访问:https://literature.sinhy.com/#/?__c=1000,移动端可微信小程序搜索“历代文学”)总架构师,15年工作经验,精通Java编程高并发设计Springboot和微服务,熟悉LinuxESXI虚拟化以及云原生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://payment即可* </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();}
}

六、核心机制解析

  1. 负载均衡流程

    • 通过自定义ClientHttpRequestInterceptor实现服务发现
    • 使用LoadBalancerClient.choose()获取服务实例
    • 重写请求URI为实际IP:Port
  2. 声明式接口原理

    • HttpServiceProxyFactory基于JDK动态代理生成实现类
    • 底层使用RestClient执行实际HTTP请求
  3. 与RestTemplate方案的差异

    • 更现代的流式API配置方式
    • 原生支持URI重写拦截器链
    • 更好的异常处理机制

七、方案优势

  1. 官方推荐:完全基于Spring 6.1+官方组件栈
  2. 性能优化:底层使用HttpComponents连接池
  3. 配置灵活:支持细粒度的超时和连接管理
  4. 未来兼容:为迁移到响应式架构保留接口兼容性

注意事项

  1. 确保服务调用URL格式为http://service-name/path
  2. Spring Security配置需要正确设置SecurityContextHolder策略
  3. 生产环境建议启用spring-cloud-starter-circuitbreaker-resilience4j实现熔断
http://www.xdnf.cn/news/8551.html

相关文章:

  • 今日多肽之——订书肽
  • Linux文件类型
  • 建筑科技的未来图景:探究中建海龙的创新基因
  • C语言超详细结构体知识
  • 工程化实践:Flutter项目结构与规范
  • 广东中级消防设施操作员理论考试精选题
  • SpringAI+DeepSeek大模型应用开发——5 ChatPDF
  • 相比其他缓存/内存数据库(如 Memcached, Ehcache 等),Redis 在微服务环境中的优势和劣势是什么?
  • 【RK3588 嵌入式图形编程】-SDL2-扫雷游戏-结束和重新开始游戏
  • string函数的应用
  • Python 写生成 应用商店(2025版) 网页 方便收集应用 ,局域网使用
  • 极狐GitLab 外部授权控制机制是怎样的?
  • 【前端知识】今天聊一聊web的事件机制
  • SpringBoot学习(properties、yml(主流)、yaml格式配置文件)(读取yml配置文件的3种方式)(详解)
  • Kafka消费者端重平衡流程
  • 中间件--ClickHouse-9--MPP架构(分布式计算架构)
  • kafka菜鸟教程
  • GEE学习笔记 29:基于GEE的多源Landsat合成与植被指数时序提取
  • axios 模拟实现
  • 【HFP】蓝牙HFP协议音频连接核心技术深度解析
  • 【2】CICD持续集成-k8s集群中安装Jenkins
  • 8.观察者模式:思考与解读
  • 【SAP ME 44】在 HANA DB中报废SFC时的SHOP_ORDER表记录锁定
  • 设计模式从入门到精通之(五)观察者模式
  • LIB-ZC, 一个跨平台(Linux)平台通用C/C++扩展库, stream 流操作
  • conversation_template | conversation_actors | conversation_line_template
  • 网安加·百家讲坛 | 刘志诚:AI安全风险与未来展望
  • MCP的推出将给未来的开发带来哪些变革?
  • 解决jupyter notebook修改路径下没有c.NotebookApp.notebook_dir【建议收藏】
  • 第五章 SQLite数据库:4、SQLite 进阶用法:常见的约束、PRAGMA 配置、数据操作