SpringCloud Fegin超时重试源码

本文内容纲要：

springCloud中最重要的就是微服务之间的调用，因为网络延迟或者调用超时会直接导致程序异常，因此超时的配置及处理就至关重要。

在开发过程中被调用的微服务打断点发现会又多次重试的情况，测试环境有的请求响应时间过长也会出现多次请求，网上查询了配置试了一下无果，决定自己看看源码。

本人使用的SpringCloud版本是Camden.SR3。

微服务间调用其实走的是http请求，debug了一下默认的ReadTimeout时间为5s，ConnectTimeout时间为2s，我使用的是Fegin进行微服务间调用，底层用的还是Ribbon，网上提到的配置如下

ribbon: ReadTimeout:60000 ConnectTimeout:60000 MaxAutoRetries:0 MaxAutoRetriesNextServer:1

超时时间是有效的但是重试的次数无效，如果直接使用ribbon应该是有效的。

下面开始测试：

在微服务B中建立测试方法，sleep8s确保请求超时 @PostMapping("/testa") publicIntegertestee(){ try{ Thread.sleep(8000L); }catch(InterruptedExceptione){ e.printStackTrace(); } return9; }

在微服务A中使用fegin调用此方法时看到有异常

看到在SynchronousMethodHandler中请求的方法

ObjectexecuteAndDecode(RequestTemplatetemplate)throwsThrowable{ Requestrequest=targetRequest(template); if(logLevel!=Logger.Level.NONE){ logger.logRequest(metadata.configKey(),logLevel,request); } Responseresponse; longstart=System.nanoTime(); try{ response=client.execute(request,options); response.toBuilder().request(request).build(); }catch(IOExceptione){ if(logLevel!=Logger.Level.NONE){ logger.logIOException(metadata.configKey(),logLevel,e,elapsedTime(start)); } //出现异常后抛出RetryableException throwerrorExecuting(request,e); }

出现异常后调用throwerrorExecuting(request,e)抛出异常

在调用executeAndDecode的地方catch

@Override publicObjectinvoke(Object[]argv)throwsThrowable{ RequestTemplatetemplate=buildTemplateFromArgs.create(argv); Retryerretryer=this.retryer.clone(); while(true){ try{ returnexecuteAndDecode(template); }catch(RetryableExceptione){ //重试的地方 retryer.continueOrPropagate(e); if(logLevel!=Logger.Level.NONE){ logger.logRetry(metadata.configKey(),logLevel); } continue; } } }

retryer.continueOrPropagate(e);这句就是关键继续跟进

publicvoidcontinueOrPropagate(RetryableExceptione){ //maxAttempts是构造方法传进来的大于重试次数抛出异常,否则继续循环执行请求 if(attempt++>=maxAttempts){ throwe; }

默认的Retryer构造器

publicDefault(){ this(100,SECONDS.toMillis(1),5); }

第一个参数period是请求重试的间隔算法参数，第二个参数maxPeriod是请求间隔最大时间，第三个参数是重试的次数。算法如下：

longnextMaxInterval(){ longinterval=(long)(period*Math.pow(1.5,attempt-1)); returninterval>maxPeriod?maxPeriod:interval; }

新建一个配置类

@Configuration publicclassFeginConfig{ @Bean publicRetryerfeginRetryer(){ Retryerretryer=newRetryer.Default(100,SECONDS.toMillis(10),3); returnretryer; } }

在feginClient是加入configuration的配置

`` @FeignClient(value="fund-server",fallback=FundClientHystrix.class,configuration=FeginConfig.class) publicinterfaceFundClient

重启重试，只调用了一次，Fegin重试次数解决。

我们再看看请求超时这里的参数 @Override publicResponseexecute(Requestrequest,Request.Optionsoptions)throwsIOException{ try{ URIasUri=URI.create(request.url()); StringclientName=asUri.getHost(); URIuriWithoutHost=cleanUrl(request.url(),clientName); FeignLoadBalancer.RibbonRequestribbonRequest=newFeignLoadBalancer.RibbonRequest( this.delegate,request,uriWithoutHost); //请求参数 IClientConfigrequestConfig=getClientConfig(options,clientName); returnlbClient(clientName).executeWithLoadBalancer(ribbonRequest, requestConfig).toResponse(); } catch(ClientExceptione){ IOExceptionio=findIOException(e); if(io!=null){ throwio; } thrownewRuntimeException(e); } }

其中ReadTimeout和ConnectTimeout读取的就是ribbon的配置，再来看一眼

ribbon: ReadTimeout:60000 ConnectTimeout:60000 MaxAutoRetries:0 MaxAutoRetriesNextServer:1

如果想覆盖ribbon的超时设置可以在刚刚写的FeginConfig里注入下面的bean

@Bean publicRequest.OptionsfeginOption(){ Request.Optionsoption=newRequest.Options(7000,7000); returnoption; }

总结：使用开源的东西在弄不清问题出在哪时最好能看看源码，对原理的实现以及自己的编码思路都有很大的提升。

http://www.jianshu.com/p/767f3c72b547

本文内容总结：

原文链接：https://www.cnblogs.com/zhangjianbin/p/7228396.html