import org.springframework.retry.annotation.Retryable;
import org.springframework.retry.annotation.Backoff;
import org.springframework.web.client.RestClientException;
import org.springframework.cloud.openfeign.FallbackFactory;
// 服务提供者的FallbackFactory实现
class MyServiceFallbackFactory implements FallbackFactory<MyService> {
@Override
public MyService create(Throwable cause) {
return new MyService() {
@Override
public String someServiceMethod(String arg) {
return "Fallback response: " + cause.getMessage();
}
};
}
}
// 服务调用者
public class MyServiceCaller {
// 使用@Retryable注解来指定重试策略
@Retryable(
value = RestClientException.class, // 指定需要重试的异常
maxAttempts = 5, // 最大重试次数
backoff = @Backoff(delay = 1000) // 重试延迟策略，这里设置为1秒后重试
)
public String callService(String arg) {
// 调用远程服务
return myService.someServiceMethod(arg);
}
// 使用OpenFeign进行服务调用，并指定FallbackFactory
@FeignClient(name = "my-service", fallbackFactory = MyServiceFallbackFactory.class)
interface MyService {
@GetMapping("/serviceMethod")
String someServiceMethod(@RequestParam("arg") String arg);
}
}这个代码示例展示了如何在Spring Cloud应用中使用Spring Retry和OpenFeign来实现服务调用的重试和熔断。@Retryable注解指定了重试的条件和策略，而FallbackFactory则在重试失败后提供了一个默认的响应或执行备选逻辑。这个例子简洁而完整，展示了如何将重试机制整合到服务调用中，从而提高系统的健壮性。