SpringCloud实战六：Spring Cloud Feign 高级应用

￡神魔★判官ぃ 2022-04-05 10:08 201阅读 0赞

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

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

*  1.使用feign进行服务间的调用
 *  2.feign开启Gzip压缩
 *  3.feign开启日志
 *  4.feign替换JDK默认的URLConnection为okhttp
 *  5.feign超时设置
 *  6.feign使用hystrix进行熔断、降级处理

##### 1.使用feign进行服务间的调用 #####

###### 服务提供者 ######

*  创建provider-service服务提供者，添加如下依赖：

*  application.properties配置文件代码如下：

server.port=9600
    spring.application.name=provider-service
    eureka.instance.prefer-ip-address=true
    #配置注册中心地址
    eureka.client.serviceUrl.defaultZone=http://zy:zy123@localhost:10025/eureka/

*  启动主类添加@EnableDiscoveryClient

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

*  创建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>
    
    <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/

*  启动主类添加@EnableDiscoveryClient、@EnableFeignClients2个注解

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

*  创建一个接口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][http_localhost_9700_hello_name_zy] ，效果如下说明feign调用成功  
![在这里插入图片描述][2018121122565885.png]

高级应用的第一点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

##### 6.feign使用hystrix进行熔断、降级处理 #####

上面的超时时间设置为10秒，把服务提供者sleep睡眠时间大于10秒，服务消费者就会触发hystrix，进行熔断保护

*  改造服务提供者，让服务睡眠60秒

@RequestMapping("/hello")
        public String hello(String name){
            try {
                //睡眠60秒，测试feign的熔断、降级
                Thread.sleep(60 * 1000);
            }catch (Exception e){
                e.printStackTrace();
            }
            return  "hello " + name;
        }

*  改造服务消费者，添加feign的熔断、降级方法，feign的hystrix熔断降级很好实现，只要在FeignClient的fallback回滚方法中指定那个实现类即可

@FeignClient(name = "provider-service" , fallback = HelloFeignFallbackService.class)
    public interface HelloFeignService {
    
        @RequestMapping(value = "/hello" , method = RequestMethod.GET)
        String hello(@RequestParam("name") String name);
    }

HelloFeignFallbackService代码如下：

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

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

代码已上传至码云，[源码][Link 1]，项目使用的版本信息如下：

*  SpringBoot 2.0.6.RELEASE
 *  SpringCloud Finchley.SR2（非常新的版本）

[http_localhost_9700_hello_name_zy]: http://localhost:9700/hello?name=zy
[2018121122565885.png]: /images/20220405/b12f79dde56c4bf6b2fa3c8ecbaf9a18.png
[20181211232600763.png]: /images/20220405/0e19211466184ad29486a5075e1f06cb.png
[Link 1]: https://gitee.com/zhuyu1991/spring-cloud/