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

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

1.使用feign进行服务间的调用2.feign开启Gzip压缩3.feign开启日志4.feign替换JDK默认的URLConnection为okhttp5.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.RELEASESpringCloud Finchley.SR2（非常新的版本） </div>