前言

软件版本:

  • Spring Cloud 2023.0.0
  • Spring Cloud OpenFeign 4.1.0

Spring Cloud Open Feign的熔断降级需要配合SpringCloud熔断器(Spring Cloud Circuit Breaker)来实现。

Spring Cloud 2023支持多种熔断器,这里我们使用Resilience4J

引入熔断器依赖

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-circuitbreaker-resilience4j</artifactId>
</dependency>

开启OpenFeign的断路器支持

现在OpenFeign的相关配置都在spring.cloud.openfeign下。

spring:
  cloud:
    openfeign:
      circuitbreaker:
        enabled: true

OpenFeign定义降级逻辑

OpenFeign定义降级逻辑的方式和以前没有太大变化。

FeignClient的Fallback有两种配置方式:

  • 方式一:FallbackClass
  • 方式二:FallbackFactory

方式一:FallbackClass

  1. 在FeignClient上的@FeignClientfallback属性上指定FallbackClass,如下:

    @FeignClient(value = "article", fallback = IArticleClientFallback.class)
    public interface IArticleClient {
        @PostMapping(value = "/api/v1/article/save")
        ResponseResult<Long> saveArticle(@RequestBody ApArticleDto apArticleDto);
    }
    
  2. 这是它的FallbackClass:

    public class IArticleClientFallback implements IArticleClient {
        @Override
        public ResponseResult<Long> saveArticle(ApArticleDto apArticleDto) {
            System.err.println("fallback~~~");
            return ResponseResult.errorResult(55555, "文章保存失败~");
        }
    }
    
  3. 启用FallbackClass

    public class FallbackConfig {
        @Bean
        public IArticleClientFallback iArticleClientFallback() {
            return new IArticleClientFallback();
        }
    }
    

    在启动类上的@EnableFeignClients注释的defaultConfiguration属性中启用配置类:

    @EnableFeignClients(basePackages = "com.example.api", defaultConfiguration = FallbackConfig.class)
    

    使用其他方式注入FallbackClass也是可以的。

方式二:FallbackFactory

  1. 在FeignClient上的@FeignClientfallbackFactory属性上指定FallbackFactory,如下:

    @FeignClient(value = "heima-leadnews-article", fallbackFactory = IArticleClientFallbackFactory.class)
    public interface IArticleClient {
    @PostMapping(value = "/api/v1/article/save")
    ResponseResult<Long> saveArticle(@RequestBody ApArticleDto apArticleDto);
    }
    
  2. FallbackFactory:

    public class IArticleClientFallbackFactory implements FallbackFactory<IArticleClient> {
        @Override
        public IArticleClient create(Throwable throwable) {
            return new IArticleClient() {
                @Override
                public ResponseResult<Long> saveArticle(ApArticleDto apArticleDto) {
                    return ResponseResult.errorResult(555, throwable.getMessage());
                }
            };
        }
    }
    
  3. 启用FallbackFactory

    FallbackFactory不能使用一般的方式注册为Bean,请使用以下方式。

    新建一个配置类,不用加@Configuration@SpringBootConfiguration

    public class FallbackConfig {
        @Bean
        public IArticleClientFallbackFactory iArticleClientFallbackFactory() {
            return new IArticleClientFallbackFactory();
        }
    }
    

    在启动类上的@EnableFeignClients注释的defaultConfiguration属性中启用配置类:

    @EnableFeignClients(basePackages = "com.example.api", defaultConfiguration = FallbackConfig.class)
    
Logo

有“AI”的1024 = 2048,欢迎大家加入2048 AI社区

更多推荐