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

发布于：2025-04-19 ⋅ 阅读:(20) ⋅ 点赞:(0)

🧑 博主简介：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客户端

文章目录

引言

在微服务架构持续演进的今天，高效的远程服务通信始终是系统设计的核心挑战之一。传统的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
    @Bean
    public RestClient.Builder loadBalancedWebClientBuilder()
    {
        return RestClient.builder().requestFactory(new HttpComponentsClientHttpRequestFactory(httpClient()));
    }
    
    @Bean
    public TokenPropagationExchangeFilterFunction tokenFilter()
    {
        return new TokenPropagationExchangeFilterFunction();
    }
    
    @Bean
    public 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
{
    
    @Override
    public 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实现熔断

网站公告

今日签到

点亮在社区的每一天
去签到

热门文章

最新发布