OpenFeign重试机制源码+自定义

OpenFeign的重试机制是通过Retryer接口实现的，默认情况下，Feign使用的是SameUrlParameterValueRetryer，它会对相同URL的请求进行重试。

要实现自定义重试策略，你可以定义一个实现了Retryer接口的类，并在Feign客户端的配置中指定使用这个自定义的重试器。

下面是一个简单的自定义重试器的示例：

import feign.Retryer;
import java.util.concurrent.TimeUnit;
 
public class CustomRetryer implements Retryer {
    private int retryPeriod;
    private int maxAttempts;
 
    public CustomRetryer(int retryPeriod, int maxAttempts) {
        this.retryPeriod = retryPeriod;
        this.maxAttempts = maxAttempts;
    }
 
    @Override
    public void continueOrPropagate(RetryableException e) {
        if (e.getAttemptCount() >= maxAttempts) {
            // 达到最大重试次数，抛出异常
            throw e;
        }
        try {
            // 实现重试逻辑，这里简单地使用Thread.sleep实现
            Thread.sleep(retryPeriod);
        } catch (InterruptedException interrupted) {
            Thread.currentThread().interrupt();
            throw new RetryableException(interrupted.getMessage(), e.getCause());
        }
    }
}

然后在Feign客户端的配置中使用这个自定义的重试器：

import feign.Feign;
import feign.Retryer;
 
public class FeignClientConfiguration {
 
    @Bean
    public Retryer feignRetryer() {
        // 自定义重试间隔和最大重试次数
        return new CustomRetryer(1000, 5); // 每隔1秒重试，最多重试5次
    }
 
    @Bean
    public YourFeignClient yourFeignClient(Decoder decoder, Encoder encoder, YourContract contract) {
        return Feign.builder()
                .decoder(decoder)
                .encoder(encoder)
                .contract(contract)
                .retryer(feignRetryer()) // 使用自定义的重试器
                .target(YourFeignClient.class, "http://your-service-url");
    }
}

在上面的代码中，YourFeignClient是你的Feign客户端接口，YourContract是Feign的合同，Decoder和Encoder分别是Feign的解码器和编码器，它们负责序列化请求数据和反序列化响应数据。

这样，当你的Feign客户端调用远程服务时，如果出现异常，将会根据你在CustomRetryer中定义的策略进行重试。