服务器之家:专注于服务器技术及软件下载分享
分类导航

PHP教程|ASP.NET教程|Java教程|ASP教程|编程技术|正则表达式|C/C++|IOS|C#|Swift|Android|VB|R语言|JavaScript|易语言|vb.net|

服务器之家 - 编程语言 - Java教程 - SpringCloud重试机制配置详解

SpringCloud重试机制配置详解

2021-04-20 14:34张建斌 Java教程

本篇文章主要介绍了SpringCloud重试机制配置详解,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧

首先声明一点,这里的重试并不是报错以后的重试,而是负载均衡客户端发现远程请求实例不可到达后,去重试其他实例。

SpringCloud重试机制配置详解

?
1
2
3
4
5
6
7
8
@bean
@loadbalanced
resttemplate resttemplate() {
  httpcomponentsclienthttprequestfactory httprequestfactory = new httpcomponentsclienthttprequestfactory();
  httprequestfactory.setreadtimeout(5000);
  httprequestfactory.setconnecttimeout(5000);
  return new resttemplate(httprequestfactory);
}

SpringCloud重试机制配置详解

feign重试机制 

feign默认是通过自己包下的retryer进行重试配置,默认是5次

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
package feign;
import static java.util.concurrent.timeunit.seconds;
 
/**
 * cloned for each invocation to {@link client#execute(request, feign.request.options)}.
 * implementations may keep state to determine if retry operations should continue or not.
 */
public interface retryer extends cloneable {
 
 /**
  * if retry is permitted, return (possibly after sleeping). otherwise propagate the exception.
  */
 void continueorpropagate(retryableexception e);
 
 retryer clone();
 
 public static class default implements retryer {
 
  private final int maxattempts;
  private final long period;
  private final long maxperiod;
  int attempt;
  long sleptformillis;
 
  public default() {
   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;
  }

feign取消重试

?
1
2
3
4
@bean
  retryer feignretryer() {
    return retryer.never_retry;
  }

feign请求超时设置

?
1
2
3
4
5
6
7
@bean
request.options requestoptions(configurableenvironment env){
  int ribbonreadtimeout = env.getproperty("ribbon.readtimeout", int.class, 6000);
  int ribbonconnectiontimeout = env.getproperty("ribbon.connecttimeout", int.class, 3000);
 
  return new request.options(ribbonconnectiontimeout, ribbonreadtimeout);
}

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持服务器之家。

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

延伸 · 阅读

精彩推荐