上篇简单的介绍了Feign的使用,本篇将结合注册中心,进行Feign的高级应用,案例中有三个角色:服务注册中心、服务提供者、服务消费者,注册中心为上篇的eureka单机版。

具体高级应用为如下几条:

  • 1.使用feign进行服务间的调用
  • 2.feign开启Gzip压缩
  • 3.feign开启日志
  • 4.feign替换JDK默认的URLConnection为okhttp
  • 5.feign超时设置
  • 6.feign使用hystrix进行熔断、降级处理
1.使用feign进行服务间的调用
服务提供者
  • 创建provider-service服务提供者,添加如下依赖:
<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>

  
  

    }

    • 创建HelloController,添加一个hello方法
    @RestController
    public class HelloController {
    
    @RequestMapping("/hello")
    public String hello(String name){
        return  "hello " + name;
    }
    

    }

    服务消费者
    • 创建consumer-service服务提供者,添加如下依赖:
    <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>
    <!-- 因为要使用feign调用其他服务,所以需要添加此依赖 -->
    <dependency>
    	<groupId>org.springframework.cloud</groupId>
    	<artifactId>spring-cloud-starter-openfeign</artifactId>
    </dependency>
    
     
     
    • application.properties配置文件代码如下:
    server.port=9700
    spring.application.name=consumer-service
    eureka.instance.prefer-ip-address=true
    # 配置注册中心地址
    eureka.client.serviceUrl.defaultZone=http://zy:zy123@localhost:10025/eureka/
    
     
     

      }

      • 创建一个接口HelloFeignService,调用服务提供者
      //name为服务提供者向注册中心注册的实例名
      @FeignClient(name = "provider-service" )
      public interface HelloFeignService {
          //地址为服务提供者对外暴露的地址
          @RequestMapping(value = "/hello" , method = RequestMethod.GET)
          String hello(@RequestParam("name") String name);
      }
      
       
       
      • 创建IndexController控制器,注入feign,像本地方法一样调用服务提供者的服务
      @RestController
      public class IndexController {
      
      @Autowired private HelloFeignService feignService;
      
      @RequestMapping(value = "/hello" , method = RequestMethod.GET)
      public String hello(String name){
          return feignService.hello(name);
      }
      

      }

      启动2个项目,访问服务消费者 http://localhost:9700/hello?name=zy ,效果如下说明feign调用成功
      在这里插入图片描述

      高级应用的第一点ok了

      2.feign开启Gzip压缩

      Spring Cloud Feign支持对请求与响应的压缩,以提高通信效率,在服务消费者配置文件开启压缩支持和压缩文件的类型即可

      #feign 请求与响应的压缩
      feign.compression.request.enabled=true
      feign.compression.response.enabled=true
      feign.compression.request.mime-types=text/xml,application/xml,application/json
      feign.compression.request.min-request-size=2048
      
       
       
      3.feign开启日志

      feign开启日志有两种方式,一种是使用配置文件,一种是使用java代码,下面将介绍代码方式
      创建FeignLogConfig类,添加一个LoggerBean

      @Configuration
      public class FeignLogConfig {
      
      /**
       * 日志level有4个级别
       * 1.NONE,不记录任何日志
       * 2.BASIC,仅记录请求方法、URL以及响应状态码和执行时间
       * 3.HEADRES,除了BASIC以外的还会记录请求和响应的头信息
       * 4.FULL,所有
       * @return
       */
      @Bean
      Logger.Level feignLogger(){
          return Logger.Level.FULL;
      }
      

      }

      4.feign替换JDK默认的URLConnection为okhttp

      使用okhttp,能提高qps,因为okhttp有连接池和超时时间进行调优

      • 在服务消费者中,添加feign-okhttp依赖
      <dependency>
      	<groupId>io.github.openfeign</groupId>
      	<artifactId>feign-okhttp</artifactId>
      </dependency>
      
       
       
      • >
      • 在配置文件中,禁用默认的http,启用okhttp
      feign.httpclient.enabled=false
      feign.okhttp.enabled=true
      
       
       
        • 创建OkHttpConfig类,添加okhttp的bean
        /**
         * 配置okhttp与连接池
         * ConnectionPool默认创建5个线程,保持5分钟长连接
         */
        @Configuration
        @ConditionalOnClass(Feign.class)
        @AutoConfigureBefore(FeignAutoConfiguration.class)
        public class OkHttpConfig {
        
        @Bean
        public okhttp3.OkHttpClient okHttpClient(){
            return new okhttp3.OkHttpClient.Builder()
                    //设置连接超时
                    .connectTimeout(10 , TimeUnit.SECONDS)
                    //设置读超时
                    .readTimeout(10 , TimeUnit.SECONDS)
                    //设置写超时
                    .writeTimeout(10 , TimeUnit.SECONDS)
                    //是否自动重连
                    .retryOnConnectionFailure(true)
                    .connectionPool(new ConnectionPool(10 , 5L, TimeUnit.MINUTES))
                    .build();
        }
        

        }

        5.feign超时设置
        # feign启用hystrix,才能熔断、降级
        feign.hystrix.enabled=true
        

        hystrix的超时时间

        hystrix.command.default.execution.timeout.enabled=true
        hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=10000

        ribbon的超时时间

        ribbon.ReadTimeout=10000
        ribbon.ConnectTimeout=10000

          }

          HelloFeignFallbackService代码如下:

          /**
           * hystrix服务降级处理,防止因超时、异常等导致的服务调用雪崩
           */
          @Service
          public class HelloFeignFallbackService implements HelloFeignService{
              @Override
              public String hello(String name) {
                  return "未找到" + name ;
              }
          }
          
           
           

          然后启动服务提供者与消费者,再访问 http://localhost:9700/hello?name=zy ,发现页面缓了10来秒,就直接返回了熔断方法中的内容,说明hystrix熔断降级成功
          在这里插入图片描述

          代码已上传至码云,源码,项目使用的版本信息如下:

          • SpringBoot 2.0.6.RELEASE
          • SpringCloud Finchley.SR2(非常新的版本)
                </div>
          
          Logo

          权威|前沿|技术|干货|国内首个API全生命周期开发者社区

          更多推荐