Springboot2.X集成openfeign(使用okhttp3)接口化管理http请求(支持Hystrix熔断)

迷南。 2023-01-12 01:47 141阅读 0赞

# 项目配置 #

### 新增依赖 ###

这里注意openfeign版本是对应springboot的  请依据官方版本选择依赖

<dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-starter-openfeign</artifactId>
                    <version>2.2.6.RELEASE</version>
                </dependency>
    
                <dependency>
                    <groupId>io.github.openfeign</groupId>
                    <artifactId>feign-okhttp</artifactId>
                    <version>11.0</version>
                </dependency>

### 新增配置 ###

在application增加feign配置

feign:
      # 开启压缩
      compression:
        request:
          enabled: true
        response:
          enabled: true
      okhttp:
        enabled: true
      hystrix:
        enabled: true

增加FeignConfig配置类

@EnableFeignClients("com.lionli.**.feign") // 扫描feign接口所在包 重要
    @Configuration
    @ConditionalOnClass(Feign.class)
    @AutoConfigureBefore(FeignAutoConfiguration.class)
    public class FeignConfig {
    
        @Bean
        public OkHttpClient okHttpClient(){
            return new OkHttpClient.Builder()
                    .readTimeout(60, TimeUnit.SECONDS)
                    .connectTimeout(60, TimeUnit.SECONDS)
                    .writeTimeout(120, TimeUnit.SECONDS)
                    .connectionPool(new ConnectionPool())
                    .build();
        }
    
        @Bean
        public Feign.Builder feignBuilder() {
            return HystrixFeign.builder();
        }
    
        @Bean
        public Contract feignContract() {
            return new SpringMvcContract();
        }
    
        @Bean
        public Logger.Level feignLoggerLevel() {
            return Logger.Level.BASIC;
        }
    
        @Bean
        public Request.Options feignRequestOptions() {
            return new Request.Options(10, TimeUnit.SECONDS, 60,TimeUnit.SECONDS,true);
        }
    
        @Bean
        public Retryer feignRetry() {
            return new Retryer.Default();
        }
    
    }

### 开启Feign客户端 ###

在启动类新增 @EnableFeignClients 注解

@SpringBootApplication
    public class FeignTestApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(RuoYiApplication.class, args);
        }
    
    }

# 测试编写 #

### 编写Service接口 ###

这里我们使用百度搜索为例

@FeignClient(name = "baidu",url = "http://www.baidu.com",fallback = FeignTestFallback.class)
    public interface FeignTestService {
    
        @GetMapping("/s")
        String search(@RequestParam("wd") String wd);
    }

### 编写容错Fallback类 ###

@Component
    public class FeignTestFallback implements FeignTestService {
    
        @Override
        public String search(String wd) {
            return "请求异常报错了";
        }
    }

### 编写controller类 ###

@RestController
    @RequestMapping("/feign/test")
    public class FeignTestController {
    
        @Autowired
        private FeignTestService feignTestService;
    
        @GetMapping("/search/{wd}")
        public String search(@PathVariable String wd) {
            return feignTestService.search(wd);
        }
    }

# 运行测试用例 #

### 访问测试接口 ###

这里我们使用postman做访问测试

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDQ2MTI4MQ_size_16_color_FFFFFF_t_70][]

成功返回内容

### 查看请求日志 ###

![20210127154653781.png][]

日志正常

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDQ2MTI4MQ_size_16_color_FFFFFF_t_70]: /images/20221119/6b6743bb96d746c7b5aa5cc715d935d1.png
[20210127154653781.png]: /images/20221119/a0711be7d0b24f358565d0cc65efd5a7.png