Spring Cloud Feign 重试机制-如何实现请求重试

新建工程

• 新建一个Spring Boot工程，命名为feign-retry（随意）
• 编辑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-netflix-eureka-client</artifactId>
</dependency>
<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>

• 修改主类

@SpringBootApplication
@EnableFeignClients
@EnableDiscoveryClient
public class RetryApplication {

    public static void main(String[] args) {
        SpringApplication.run(RetryApplication.class, args);
    }

}

• 修改application.yml

server:
  port: 9000
eureka:
  client:
    service-url:
      defaultZone: http://peer1:1111/eureka/
spring:
  application:
    name: feign-retry

HELLO-CLIENT:
  ribbon:
    ConnectTimeout: 500
    ReadTimeout: 2000
    OkToRetryOnAllOperations: true
    MaxAutoRetriesNextServer: 2
    MaxAutoRetries: 1

application.yml中的HELLO-CLIENT.ribbon.....的配置是通过指定服务配置进行配置的

ConnectTimeout:请求连接的超时时间
ReadTimeout:请求处理的超时时间
OkToRetryOnAllOperations:对所有操作请求都进行重试
MaxAutoRetriesNextServer:切换实例的重试次数
MaxAutoRetries:对当前实例的重试次数

• 新建RetryService

@Service
@FeignClient(value = "HELLO-CLIENT")
public interface RetryService {

    @RequestMapping(value = "/feign/retry")
    String hello();

}

• 新建RetryController

@RestController
@RequestMapping(value = "/feign")
public class RetryController {

    @Autowired
    private RetryService retryService;

    @RequestMapping(value = "/retry")
    public String retryTest() {
        return retryService.hello();
    }

}

修改服务提供实例

• 添加FeignRetryController类

@RestController
@RequestMapping(value = "/feign")
public class FeignRetryController {

    @Autowired
    DiscoveryClient discoveryClient;

    @RequestMapping(value = "/retry")
    public String testFeign() throws InterruptedException {
        System.out.println("收到消费者请求");
        int sleepTime = new Random().nextInt(3000);
        System.out.println("进入等，等待时间为" + sleepTime);
        Thread.sleep(sleepTime);
        System.out.println("等待时间为" + sleepTime + "的请求处理结束");
        return "Hello World";
    }
}

我们在方法里面加了一个随机数，用来测试超时，我们在配置文件里面配置的处理请求超时时间为2000，随机数大于2000对应的请求都应该会请求重试。

测试

启动服务注册中心、启动服务提供实例、启动刚刚新建的工程
访问：http://localhost:9000/feign/retry

我们这个例子只测试了对当前实例请求重试的效果，自己可以测试一下更换实例进行请求重试的效果。