Ribbon的超时配置会覆盖OpenFeign的超时配置吗

蔚落 2023-10-13 17:10 9阅读 0赞

# 前言 #

平常的开发工作中调用Rpc服务最关注的性能指标就是响应时间rt，OpenFeign提供了超时时间配置项。本文将从源码层面分析OpenFeign超时时间配置原理，以及Ribbon超时配置的关系分析。

通过本文可以明白两个问题：

*  OpenFeign超时配置和Ribbon超时配置的关系
 *  OpenFeign超时配置能否动态实时修改生效

# OpenFeign配置超时方式 #

在OpenFeign中，有一个超时项配置类，专门用来接收超时配置的。 支持连接超时和读数据超时配置，所有的超时配置最终都会生成对应的Options实例。

java复制代码   public static class Options {
            //连接超时时间
            private final int connectTimeoutMillis;
            //读数据超时时间
            private final int readTimeoutMillis;
            private final boolean followRedirects;
       }

默认多久超时呢？ 在FeignRibbonClientAutoConfiguration自动配置中使用了默认的构造函数，根据构造函数参数,默认连接超时10s,读数据6s超时，也就是不改配置，OpenFeign的接口默认超时时间有10s。

java复制代码 public Options() {
                this(10000, 60000);
            }

OpenFeign到底有哪些配置方式呢？

*  全局配置方式一

feign.client.config.default.connectTimeout=1000 feign.client.config.default.readTimeout=1000

*  全局配置方式二

java复制代码@Configuration
    public class TestFeignClientConfiguration {
        
        @Bean
        public Request.Options options() {
            //配置全局300ms就超时
            Request.Options options = new Request.Options(300, 300);
            return new Request.Options();
        }
    }
    }

*  指定FeignClient生效配置一 以feignClientFeignClientApi为例 feign.client.config.FeignClientApi.connectTimeout=1000 feign.client.config.FeignClientApi.readTimeout=1000
 *  指定FeignClient生效配置二

java复制代码@FeignClient(value = "fox-server", contextId = "feignClientApi", configuration = TestFeignClientConfiguration.class)
    public interface FeignClientApi {
            @PostMapping("/get")
            String getName(@RequestBody @Validated DemoRequest request);
    }
    
    //和全局配置比少了Configuration注解
    public class TestFeignClientConfiguration {
        
        @Bean
        public Request.Options options() {
            //配置全局300ms就超时
            Request.Options options = new Request.Options(300, 300);
            return new Request.Options();
        }
    }
    }

# 配置生效原理 #

这些配置是怎么生效的呢？

首先在Feign的自动装配类FeignAutoConfiguration中，启用了 FeignClientProperties配置类。这样配置文件里的属性就可以被解析了。

java复制代码@Configuration
    @ConditionalOnClass(Feign.class)
    @EnableConfigurationProperties({ FeignClientProperties.class,
            FeignHttpClientProperties.class })
    public class FeignAutoConfiguration {
    }

配置类以feign.client开头

java复制代码@ConfigurationProperties("feign.client")
    public class FeignClientProperties {
    
        private boolean defaultToProperties = true;
    
        private String defaultConfig = "default";
    
        private Map<String, FeignClientConfiguration> config = new HashMap<>();

在FeignClientConfiguration中有超时时间字段

![image.png][]

![get_code_MGUyNzIwMzY5Y2QzOGFiOWU4M2NjMDg0ZDAxOTVlYWYsMTY4OTMwMDM3NTcyMQ][]

这样Spring容器启动后会将feign.client为前缀的配置项注入到FeignClientProperties类对象中。

由于配置项config是一个map,只要key是对应的FeignClient里的contextId或者default就会生效。

具体在哪使用的呢？

在Feign初始化阶段,从Spring容器读取FeignClientProperties

java复制代码protected void configureFeign(FeignContext context, Feign.Builder builder) {
            //查找`FeignClientProperties`
            FeignClientProperties properties = this.applicationContext
                    .getBean(FeignClientProperties.class);
            if (properties != null) {
                if (properties.isDefaultToProperties()) {
                    configureUsingConfiguration(context, builder);
                    configureUsingProperties(
                            properties.getConfig().get(properties.getDefaultConfig()),
                            builder);
                    configureUsingProperties(properties.getConfig().get(this.contextId),
                            builder);
                }
                else {
                    configureUsingProperties(
                            properties.getConfig().get(properties.getDefaultConfig()),
                            builder);
                    configureUsingProperties(properties.getConfig().get(this.contextId),
                            builder);
                    configureUsingConfiguration(context, builder);
                }
            }
            else {
                configureUsingConfiguration(context, builder);
            }
        }

上面的代码就涉及到了配置优先级问题。默认是配置文件里的优先。

![image.png][image.png 1]

![get_code_YzdiN2FkNjFjNzk1ZmI5YTQxY2Q3OWJkNTRkOWMxNjIsMTY4OTMwMDM3NTcyMQ][]

根据优先级确定配置后，构造Request.Options对象，与FeignClient对象绑定。

java复制代码protected void configureUsingProperties(
                FeignClientProperties.FeignClientConfiguration config,
                Feign.Builder builder) {
            
            if (config.getConnectTimeout() != null && config.getReadTimeout() != null) {
                builder.options(new Request.Options(config.getConnectTimeout(),
                        config.getReadTimeout()));
            }
        
        }

上面是初始化好了Feign的超时配置，如果使用了ribbon负载均衡，在执行阶段可能会被修改。

*  如果是OpenFeign默认配置，使用ribbon配置覆盖默认配置

org.springframework.cloud.openfeign.ribbon.LoadBalancerFeignClient\#getClientConfig

java复制代码IClientConfig getClientConfig(Request.Options options, String clientName) {
            IClientConfig requestConfig;
            //默认10s的配置情况，使用ribbon配置覆盖默认配置
            if (options == DEFAULT_OPTIONS) {
                requestConfig = this.clientFactory.getClientConfig(clientName);
            }
            else {
                requestConfig = new FeignOptionsClientConfig(options);
            }
            return requestConfig;
        }

执行请求前，如果有配置优先使用已有的配置，兜底使用ribbon配置。整体流程如下

![image.png][image.png 2]

![get_code_ZjFjZjlkYjhkNDE3OTliYjBlNmY0ODg1YTA5YTIyYjMsMTY4OTMwMDM3NTcyMQ][]

java复制代码@Override
        public RibbonResponse execute(RibbonRequest request, IClientConfig configOverride)
                throws IOException {
            Request.Options options;
            //存在配置了，读已经配置的，如果为空，使用ribbon配置
            if (configOverride != null) {
                RibbonProperties override = RibbonProperties.from(configOverride);
                options = new Request.Options(override.connectTimeout(this.connectTimeout),
                        override.readTimeout(this.readTimeout));
            }
            else {
                options = new Request.Options(this.connectTimeout, this.readTimeout);
            }
            Response response = request.client().execute(request.toRequest(), options);
            return new RibbonResponse(request.getUri(), response);
        }

# OpenFeign超时配置问题 #

配置都是生成FeignClient对象之前就设置好了，如果想动态实时生效是不支持的，修改超时时间需要重启服务。有没有办法不重启服务实时生效呢？

我们可以写一个aop切面，拦截feign.Client\#execute方法,第二个参数就是调用时候会使用的Options参数，只要修改第二个参数就可以了。

![image.png][image.png 3]

![get_code_ZTgwZGJlMDg1MWQ5NjcyYmZkZDRiYzQ4NzAyYWNhNjAsMTY4OTMwMDM3NTcyMQ][]

# 总结 #

1、OpenFeign支持配置类和配置文件配置超时时间，默认连接超时时间是10s,读数据时间6s，配置文件的优先生效 2、Ribbon支持配置超时时间，默认1s,如果OpenFeign没有单独配置超时时间，则会使用Ribbon的超时时间覆盖 3、OpenFeign超时时间是构造Client之前就初始化好了，不支持动态修改生效，可以通过aop拦截Client的execute方法修改。

[image.png]: https://img-blog.csdnimg.cn/img_convert/7e2a2148d9dc43d71c111014055f1cc9.webp?x-oss-process=image/format,png
[get_code_MGUyNzIwMzY5Y2QzOGFiOWU4M2NjMDg0ZDAxOTVlYWYsMTY4OTMwMDM3NTcyMQ]: https://mp.toutiao.com/mp/agw/article_material/open_image/get?code=MGUyNzIwMzY5Y2QzOGFiOWU4M2NjMDg0ZDAxOTVlYWYsMTY4OTMwMDM3NTcyMQ==
[image.png 1]: https://img-blog.csdnimg.cn/img_convert/676fa1a9c8a774cfe8bb0d02afbce838.webp?x-oss-process=image/format,png
[get_code_YzdiN2FkNjFjNzk1ZmI5YTQxY2Q3OWJkNTRkOWMxNjIsMTY4OTMwMDM3NTcyMQ]: https://mp.toutiao.com/mp/agw/article_material/open_image/get?code=YzdiN2FkNjFjNzk1ZmI5YTQxY2Q3OWJkNTRkOWMxNjIsMTY4OTMwMDM3NTcyMQ==
[image.png 2]: https://img-blog.csdnimg.cn/img_convert/675684c3af84b3f238105eacf535ac45.webp?x-oss-process=image/format,png
[get_code_ZjFjZjlkYjhkNDE3OTliYjBlNmY0ODg1YTA5YTIyYjMsMTY4OTMwMDM3NTcyMQ]: https://mp.toutiao.com/mp/agw/article_material/open_image/get?code=ZjFjZjlkYjhkNDE3OTliYjBlNmY0ODg1YTA5YTIyYjMsMTY4OTMwMDM3NTcyMQ==
[image.png 3]: https://img-blog.csdnimg.cn/img_convert/3f2c9026ebd478012855f91ff319cb7f.webp?x-oss-process=image/format,png
[get_code_ZTgwZGJlMDg1MWQ5NjcyYmZkZDRiYzQ4NzAyYWNhNjAsMTY4OTMwMDM3NTcyMQ]: https://mp.toutiao.com/mp/agw/article_material/open_image/get?code=ZTgwZGJlMDg1MWQ5NjcyYmZkZDRiYzQ4NzAyYWNhNjAsMTY4OTMwMDM3NTcyMQ==