feign第一次调用超时_feign源码解读

﹏ヽ暗。殇╰゛Y 2023-01-10 11:56 62阅读 0赞

对于feign的接口请求失败的重试配置可通过如下自定义配置文件实现(一般不建议配置)

  1. @Configurationpublic class FeignConfig { @Bean public Retryer feignRetryer() { return new Retryer.Default(100, SECONDS.toMillis(1), 5); }}

当然,也可使用默认的retry配置文件,下方是feign.Retryer的源码

  1. // 类的全路径是feign.Retryer public Default() { // 默认是重试的间隔是100ms,最大重试间隔是1秒,最大重试次数是5次 this(100, SECONDS.toMillis(1), 5); } public Default(long period, long maxPeriod, int maxAttempts) { this.period = period; this.maxPeriod = maxPeriod; this.maxAttempts = maxAttempts; this.attempt = 1; } public void continueOrPropagate(RetryableException e) { // 如果重试的次数大于最大重试次数,抛异常 if (attempt++ >= maxAttempts) { throw e; } long interval; if (e.retryAfter() != null) { interval = e.retryAfter().getTime() - currentTimeMillis(); // 如果重试间隔大于最大间隔,则取最大间隔 if (interval > maxPeriod) { interval = maxPeriod; } if (interval < 0) { return; } } else { // 如果重试间隔没有明确,则调用nextMaxInterval获取 interval = nextMaxInterval(); } try { // sleep一定时间后再去重试 Thread.sleep(interval); } catch (InterruptedException ignored) { Thread.currentThread().interrupt(); } // sleptForMillis变量是总的重试间隔 sleptForMillis += interval; } /** * 下一次重试的间隔,间隔时间每一次重试都是1.5倍递增,直到最大间隔 **/ long nextMaxInterval() { long interval = (long) (period * Math.pow(1.5, attempt - 1)); return interval > maxPeriod ? maxPeriod : interval; }

spring cloud中的feign整合了ribbon,但feign和ribbon都有重试功能,springcloud统一了两者的行为,将feign的重试策略设置成永不重试,如果要使用feign的重试功能,只需要设置ribbon的重试配置即可,所以一般不建议配置feign的重试策略

64a03ed498707fcf4f20c53d60d50a81.png

feign默认不配置重试策略是会重试的

ribbon默认配置如下

  1. ribbon: # 同一实例最大重试次数,不包括首次调用。默认值为0 MaxAutoRetries: 0 # 同一个微服务其他实例的最大重试次数,不包括第一次调用的实例。默认值为1 MaxAutoRetriesNextServer: 1 # 是否所有操作(GET、POST等)都允许重试。默认值为false OkToRetryOnAllOperations: false

默认情况下,GET方式请求无论是连接异常还是读取异常,都会进行重试 非GET方式请求,只有连接异常时,才会进行重试

如此看来,如果同一个微服务只有一个实例是不会进行重试的,但事实并非如此分析一下源码,feign的重试是在org.springframework.retry.support.RetryTemplate中的doExecute方法中进行中

  1. protected T doExecute(RetryCallback retryCallback,RecoveryCallback recoveryCallback, RetryState state) throws E, ExhaustedRetryException { ...... while (canRetry(retryPolicy, context) && !context.isExhaustedOnly()) { try { if (this.logger.isDebugEnabled()) { this.logger.debug("Retry: count=" + context.getRetryCount()); } // Reset the last exception, so if we are successful // the close interceptors will not think we failed... lastException = null; return retryCallback.doWithRetry(context); } ......}

上方的canRetry是关键

1cc22d3cab15366b642d37ebace1a030.png

最后一行policy.canRetryNextServer是能否选择下一个实例进行重试

760a854cced6fa035a76f51b082c71db.png

而lbContext.getRetryHandler().getMaxRetriesOnNextServer()就是变量retryNextServer

6c8e5d438d46021eb56f1e56ba4d589c.png

9612e877240d87902d4288fc14d81c6a.png

retryNextServer的值就是来源于MaxAutoRetriesNextServer,默认是1,所以canRetry在返回的是true,所以调用了二次解决办法就是要进行如下配置

  1. ribbon: # 同一实例最大重试次数,不包括首次调用。默认值为0 MaxAutoRetries: 0 # 同一个微服务其他实例的最大重试次数,不包括第一次调用的实例。默认值为1 MaxAutoRetriesNextServer: 0 # 是否所有操作(GET、POST等)都允许重试。默认值为false OkToRetryOnAllOperations: false

FeignRibbonClient的自动配置类

1b29d77c8df9d3bb126b0c6bfca2919c.png

可以看出,其默认使用LoadBalancerFeignClient的配置

19c32f91c3b3371387310b0bd50fa686.png

查看其DEFAULT_OPTIONS可知道默认连接超时时间是10s,读取超时是6s

9df92009419f6009f696613e3ac7657e.png

默认的网络请求框架是HttpURLConnection

a290c636c0c1a529020adc3874cd6f39.png

如要更换相应的网络请求框架,只需要添加相应的pom依赖即可

c85c520fde6579b2bc1c190fdaad12bb.png

查看负载均衡怎么做的,查看executeWithLoadBalancer

f59db30e92baa1f324c17b953fd91e5d.png

查看其submit任务

062939c836d4dbe2383d57857dd9feb8.png

其方法selectServer就是负载均衡的关键

ee69018686c162ada5bf2996a7dadcde.png

Feign的流程如下

  1. 通过@EnableFeignClients开启feign
  2. 根据要远程调用的接口添加@FeignClient
  3. 程序扫描特定包下的FeignClient注解并注入Ioc容器
  4. 当feign接口被调用时,通过jdk代理生成相应的RequestTemplate
  5. 根据RequestTemplate生成相应的Request
  6. Request交给类Client去调用,Client可以是HttpClient,Okhttp或HttpUrlConnection
  7. 最后Client被封装到LoadBalanceClient,这个类结合ribbon实现负载均衡

发表评论

表情:
评论列表 (有 0 条评论,62人围观)

还没有评论,来说两句吧...

相关阅读