OpenFegin+hystrix实现远程HTTP服务调用、服务降级(深度~保姆级)

简介

OpenFeign 是 Spring Cloud 家族的一个成员， 它最核心的作用是为 HTTP 形式的 Rest API 提供了非常简洁高效的 RPC 调用方式。支持Hystrix 、Ribbon和SpringMVC 注解。

Feign和OpenFeign的区别？

1、Feign：

Feign是Netflix公司（第一代SpringCloud）研发的一个轻量级RESTful的伪HTTP服务客户端。

Feign内置了Ribbon逻辑，通过负载均衡算法可以从注册中心中寻找服务。

2、OpenFeign：

OpenFeign是SpringCloud自己研发的，在Feign的基础上做了增强。

OpenFeign除了原有Ribbon逻辑外，还支持了Hystrix和Spring MVC注解。

一、服务端Provider

注意: 当前是springboot整合OpenFegin 服务端没有配置注册中心， 如分布式 微服务请自行配置

1. 服务端Controller层

1.  
   @CrossOrigin
2.  
   @RestController
3.  
   @RequestMapping("/customer/information")
4.  
   public class CrmCustomersController {
5.  
    
6.  
   @Autowired
7.  
   private CrmCustomersService crmCustomersService;
8.  
    
9.  
   /**
10.  
    * 服务数据
11.  
    */
12.  
    @RequestMapping(value = "customerlist", method = {RequestMethod.GET,RequestMethod.POST})
13.  
    public PmpResult queryCustomerList (@RequestParam(value="pageNum",defaultValue="1") int pageNum, @RequestParam(value="pageSize",defaultValue="10") int pageSize,String customersno, String customersname,String daogouid){
14.  
    try {
15.  
     
16.  
    PageInfo<CustomerInformationVo> pageInfo = crmCustomersService.queryCustomerList(pageNum,pageSize,customersno,customersname,daogouid);
17.  
     
18.  
    logger.info("查询成功");
19.  
    return PmpResult.success(pageInfo);
20.  
    }catch (Exception e) {
21.  
    logger.error(e.getMessage(), e);
22.  
    String errorMessage = "查询异常";
23.  
    if (isDev){
24.  
    errorMessage = e.getMessage();
25.  
    }
26.  
    return PmpResult.paramError(errorMessage);
27.  
    }
28.  
     
29.  
    }
30.  
     
31.  
    }

二、消费端Consumer

1. 消费端~例图

2. Pom.xml

1. <!-- openFeing --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-openfeign</artifactId> </dependency>

3. Api

1. @FeignClient注解

@FeignClient参数:

name: 指定FeignClient的(服务)名称，在Eureka/Nacos/其他注册中心 中对应的服务名称。

url: 指定远程调用地址。

configuration: 指定配置类，可以自定义FeignClient的配置。

fallback: 指定降级类，在服务调用失败时返回降级类中的内容。

fallbackFactory: 指定降级工厂类，在服务调用失败时返回降级工厂类中的内容。

decode404: 指定404响应是否解码，默认为true。

path: 指定服务请求的基础路径。

contextId: 当一个服务有多个接口时，我们又不想把所有接口都写到一个类中是时候就用到了 contextId为当前类设置一个唯一ID。不然就回报如下错误 。

2. [扩展]@FeignClient注解 通过属性 contextId 解决名称重复无法启动的问题 错误如下:

1.  
   Description:
2.  
   The bean 'optimization-user.FeignClientSpecification', defined in null, could not be registered. A bean with that name has already been defined in null and overriding is disabled.
3.  
   Action:
4.  
   Consider renaming one of the beans or enabling overriding by setting spring.main.allow-bean-definition-overriding=true

导致 名称重复问题 复现:

1.  
   /*
2.  
   *Consumer1
3.  
   */
4.  
   @FeignClient(name = "xj-user")
5.  
   public interface UserRemoteConsumer1 {
6.  
   @GetMapping("/user1/get")
7.  
   public User getUser(@RequestParam("id") int id);
8.  
   }
9.  
    
10.  
    /*
11.  
    *Consumer2
12.  
    */
13.  
    @FeignClient(name = "xj-user")
14.  
    public interface UserRemoteConsumer2 {
15.  
    @GetMapping("/user2/get")
16.  
    public User getUser(@RequestParam("id") int id);
17.  
    }

这种情况下启动就会报错了，因Bean的名称冲突。

原因：由于name重复，而又不允许BeanDefinition重复，所以导致在进行注册时报错。

解决方案一:

增加下面的配置，作用允许出现beanName一样的BeanDefinition。

 spring.main.allow-bean-definition-overriding=true

解释:

spring.main.allow-bean-definition-overriding=true应用程序的一个配置属性，它允许在应用程序上下文中覆盖bean定义。如果设置为true，则可以在应用程序上下文中定义多个具有相同名称的bean，后定义的bean将覆盖先前定义的bean。但是，这可能会导致不可预测的行为和错误，因此应该谨慎使用。

解决方案二(推荐):

每个FeignClient手动指定不同的contextId，这样就不会冲突了。

@FeignClient添加contextId属性

1.  
   /*
2.  
   *Consumer1
3.  
   */
4.  
   @FeignClient(name = "xj-user" contextId = UserRemoteConsumer1)
5.  
   public interface UserRemoteConsumer1 {
6.  
   @GetMapping("/user1/get")
7.  
   public User getUser(@RequestParam("id") int id);
8.  
   }
9.  
    
10.  
    /*
11.  
    *Consumer2
12.  
    */
13.  
    @FeignClient(name = "xj-user" contextId = UserRemoteConsumer2)
14.  
    public interface UserRemoteConsumer2 {
15.  
    @GetMapping("/user2/get")
16.  
    public User getUser(@RequestParam("id") int id);
17.  
    }

总结:想创建多个具有相同名称或url的外部客户端，以便它们指向同一台服务器，但每个服务器都有不同的自定义配置，那么可以使用@FeignClient的contextId属性，以避免这些配置bean的名称冲突。

3. @RequestMapping(value = "/customer/information/customerlist", method = RequestMethod.GET)是要调的接口名

openFegin调用如下:

1.  
   import com.alibaba.fastjson.JSONObject;
2.  
   import com.lt.crm.service.fallback.TransactionFallBackFactory;
3.  
   import org.springframework.cloud.openfeign.FeignClient;
4.  
   import org.springframework.stereotype.Repository;
5.  
   import org.springframework.web.bind.annotation.RequestMapping;
6.  
   import org.springframework.web.bind.annotation.RequestMethod;
7.  
   import org.springframework.web.bind.annotation.RequestParam;
8.  
    
9.  
    
10.  
    @Repository
11.  
    @FeignClient(name = "service-client", url = "http://10.1.8.22:9001", contextId = "ConsumerService", fallbackFactory = TransactionFallBackFactory.class)
12.  
    public interface ConsumerService {
13.  
     
14.  
    @RequestMapping(value = "/customer/information/customerlist", method = RequestMethod.GET)
15.  
    JSONObject queryCustomerList(@RequestParam(value = "pageNum") final int pageNum, @RequestParam(value = "pageSize") final int pageSize);
16.  
     
17.  
     
18.  
    }

4. Hystrix 服务降级处理

说明:

Hystrix配合OpenFeign进行降级，可以对应接口中定义的远程调用单独进行降级操作。

直白的说: 远程调用失败，我们添加一个替代方案，我们知道OpenFegin是以接口的形式来声明远程调用，只要是远程调用失效超时，就执行替代方案。创建一个实现类，对原有的接口方法进行替代方案实现。

1. 使用@Component注解 交给String管理 注入IOC容器

2. 对Api接口进行进行实现、重写调用的Api 远程接口 代码如下:

3. @Component 注解是 Spring 框架中的注解，用于将一个类标记为 Spring 容器中的一个组件，让 Spring 自动扫描并管理这个组件的生命周期和依赖注入。

4. 实现implements FallbackFactory原因:用于在使用 Feign 进行服务调用时，定义一个 FallbackFactory<> 来处理服务调用失败的情况的<ConsumerService>。[ import feign.hystrix.FallbackFactory; ]

5. 以下码为例:服务降级内容我只是返回一段话，根据自己业务定性, 可判断参数是否为空等 返回具体错误信息。

1.  
   import com.alibaba.fastjson.JSONObject;
2.  
   import com.lt.crm.service.api.ConsumerService;
3.  
   import feign.hystrix.FallbackFactory;
4.  
   import org.apache.commons.lang.exception.ExceptionUtils;
5.  
   import org.slf4j.Logger;
6.  
   import org.slf4j.LoggerFactory;
7.  
   import org.springframework.stereotype.Component;
8.  
    
9.  
    
10.  
    @Component
11.  
    public class TransactionFallBackFactory implements FallbackFactory<ConsumerService> {
12.  
     
13.  
    private Logger logger = LoggerFactory.getLogger(getClass());
14.  
    @Override
15.  
    public ConsumerService create(Throwable throwable) {
16.  
     
17.  
    return new ConsumerService() {
18.  
    @Override
19.  
    public JSONObject queryCustomerList(int pageNum, int pageSize) {
20.  
    logger.error("TransactionMsgWaitingConfirm Error : {}" , ExceptionUtils.getFullStackTrace(throwable));
21.  
    String fallbackMessage = "被Hystrix熔断,已作降级处理!";
22.  
    JSONObject jsonObject = new JSONObject();
23.  
    jsonObject.put("fallbackMessage",fallbackMessage);
24.  
    return jsonObject;
25.  
    }
26.  
    };
27.  
    }
28.  
     
29.  
     
30.  
     
31.  
    }

5. 消费端Controller层

@Autowired

private ConsumerService consumerService;

在消费端Controller注入Api调用 ConsumerService

1.  
    
2.  
   import com.alibaba.fastjson.JSONObject;
3.  
   import com.lt.crm.common.PmpResult;
4.  
   import com.lt.crm.service.api.ConsumerService;
5.  
   import io.swagger.annotations.Api;
6.  
   import io.swagger.annotations.ApiOperation;
7.  
   import org.slf4j.Logger;
8.  
   import org.slf4j.LoggerFactory;
9.  
   import org.springframework.beans.factory.annotation.Autowired;
10.  
    import org.springframework.stereotype.Controller;
11.  
    import org.springframework.web.bind.annotation.RequestMapping;
12.  
    import org.springframework.web.bind.annotation.RequestMethod;
13.  
    import org.springframework.web.bind.annotation.RequestParam;
14.  
    import org.springframework.web.bind.annotation.ResponseBody;
15.  
     
16.  
     
17.  
    @Controller
18.  
    @RequestMapping("/customer/information")
19.  
    @Api(tags = "跨服务调用数据")
20.  
    public class ConsumerController {
21.  
    /**
22.  
    * 日志
23.  
    */
24.  
    private final static Logger logger = (Logger) LoggerFactory.getLogger(ConsumerController.class);
25.  
     
26.  
    @Autowired
27.  
    private ConsumerService consumerService;
28.  
     
29.  
    @ResponseBody
30.  
    @ApiOperation(value = "公共开放的端口")
31.  
    @RequestMapping(value = "customerlist", method = RequestMethod.GET)
32.  
    public PmpResult queryCustomerList(@RequestParam(value = "pageNum", defaultValue = "1") int pageNum, @RequestParam(value = "pageSize", defaultValue = "10") int pageSize) {
33.  
     
34.  
    try {
35.  
    // String类型 转换成json 接收
36.  
    JSONObject GetJsonObject = consumerService.queryCustomerList(pageNum, pageSize);
37.  
    if (null != GetJsonObject) {
38.  
    logger.info("调用数据成功");
39.  
    return PmpResult.success("数据服务", GetJsonObject);
40.  
    }
41.  
     
42.  
    } catch (Exception e) {
43.  
    e.printStackTrace();
44.  
    return PmpResult.serviceError("服务异常");
45.  
    }
46.  
    return null;
47.  
    }
48.  
     
49.  
     
50.  
    }

6. application.properties配置超时时间

说明: OpenFegin 默认1ms 未响应会抛出异常 ， 往往在调用远程接口的时候 、业务逻辑复杂、 没等业务处理完毕就抛出异常 、我们可以针对这类问题 可以配置延长时长。

1. 配置 Feign 超时问题

2. 配置hystrix 超时时间

1.  
   ######################################openFegin######################################
2.  
   # 默认开启
3.  
   feign.httpclient.enabled=true
4.  
   # 默认关闭
5.  
   feign.okhttp.enabled=false
6.  
   # 默认关闭
7.  
   feign.hystrix.enabled=true
8.  
   # 默认关闭
9.  
   feign.sentinel.enabled=false
10.  
     
11.  
    # default context 连接超时时间 5000ms = 5秒
12.  
    feign.client.config.default.connectTimeout = 5000
13.  
    # default context 读超时时间
14.  
    feign.client.config.default.readTimeout = 5000
15.  
     
16.  
    ######################################Hystrix Config######################################
17.  
    #开启hystrix超时管理
18.  
    hystrix.command.default.execution.timeout.enabled=true
19.  
    #hystrix超时时间
20.  
    hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=60000
21.  
     
22.  
    #开启ribbon超时管理
23.  
    ribbon.http.client.enabled=false
24.  
    #请求超时时间
25.  
    ribbon.ReadTimeout=20000
26.  
    #连接超时时间
27.  
    ribbon.ConnectTimeout=20000
28.  
    ribbon.MaxAutoRetries=0
29.  
    ribbon.MaxAutoRetriesNextServer=1
30.  
    ribbon.OkToRetryOnAllOperations=false

7. 启动类:

启动类上使用注解 @EnableFeignClients 开启 openFeign 功能。

1.  
   /**
2.  
   * 微服务应用服务启动类
3.  
   * 1、（@EnableDiscoveryClient）注解为链接微服务注册中心用，如实际环境中使用注册中心，请取消注释部分，
4.  
   * 与配置文件中相关注册中心配置信息结合使用。
5.  
   * @author xj
6.  
   *
7.  
   */
8.  
   @EnableDiscoveryClient
9.  
   @EnableFeignClients(clients= {ConsumerService.class} )//加入@EnableFeignClients注解 开启Feign远程服务调用,使Feign的bean可以被注入
10.  
    @ServletComponentScan
11.  
    @SpringBootApplication(scanBasePackages = {"com.lt.crm"})
12.  
    @EnableCaching
13.  
    public class OpenFeignApplication {
14.  
    public static void main(String[] args) {
15.  
    SpringApplication.run(OpenFeignApplication.class, args);}
16.  
    }

8. 测试 熔断降级

启动消费端Consumer，并没有启动服务端Provider ，过了超时时间，此时执行了服务降级,这样做避免了在微服务中服务雪崩的灾难。

后台也捕获了error :

连接被拒绝:连接执行GET: Connection refused: connect executing GET http://10.1.8.22:9001/customer/information/customerlist?pageNum=1&pageSize=10

1.  
   2023-03-17 16:56:52.399 ERROR 20928 --- [ervice-client-1] c.l.c.s.f.TransactionFallBackFactory : TransactionMsgWaitingConfirm Error : feign.RetryableException: Connection refused: connect executing GET http://10.1.8.22:9001/customer/information/customerlist?pageNum=1&pageSize=10
2.  
   at feign.FeignException.errorExecuting(FeignException.java:84)
3.  
   at feign.SynchronousMethodHandler.executeAndDecode(SynchronousMethodHandler.java:113)
4.  
   at feign.SynchronousMethodHandler.invoke(SynchronousMethodHandler.java:78)
5.  
   at feign.hystrix.HystrixInvocationHandler$1.run(HystrixInvocationHandler.java:106)
6.  
   at com.netflix.hystrix.HystrixCommand$2.call(HystrixCommand.java:302)
7.  
   at com.netflix.hystrix.HystrixCommand$2.call(HystrixCommand.java:298)
8.  
   at rx.internal.operators.OnSubscribeDefer.call(OnSubscribeDefer.java:46)
9.  
   at rx.internal.operators.OnSubscribeDefer.call(OnSubscribeDefer.java:35)
10.  
    at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
11.  
    at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
12.  
    at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
13.  
    at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
14.  
    at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
15.  
    at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
16.  
    at rx.Observable.unsafeSubscribe(Observable.java:10327)
17.  
    at rx.internal.operators.OnSubscribeDefer.call(OnSubscribeDefer.java:51)
18.  
    at rx.internal.operators.OnSubscribeDefer.call(OnSubscribeDefer.java:35)
19.  
    at rx.Observable.unsafeSubscribe(Observable.java:10327)
20.  
    at rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:41)
21.  
    at rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:30)
22.  
    at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)
23.  
    at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
24.  
    at rx.Observable.unsafeSubscribe(Observable.java:10327)
25.  
    at rx.internal.operators.OperatorSubscribeOn$SubscribeOnSubscriber.call(OperatorSubscribeOn.java:100)
26.  
    at com.netflix.hystrix.strategy.concurrency.HystrixContexSchedulerAction$1.call(HystrixContexSchedulerAction.java:56)
27.  
    at com.netflix.hystrix.strategy.concurrency.HystrixContexSchedulerAction$1.call(HystrixContexSchedulerAction.java:47)
28.  
    at com.netflix.hystrix.strategy.concurrency.HystrixContexSchedulerAction.call(HystrixContexSchedulerAction.java:69)
29.  
    at rx.internal.schedulers.ScheduledAction.run(ScheduledAction.java:55)
30.  
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
31.  
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
32.  
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
33.  
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
34.  
    at java.lang.Thread.run(Thread.java:748)

现在启动服务端再次调用，已经通过消费者9004端口 拿到了服务端9001提供的数据。

三、openFeign传参方式

简介:

在接口当中传参的方式有很多，但是在 openFeig中的 传参是 有一定规则的，详细如下。

1. 传递JSON数据

服务端Provider接口中JSON传参方法如下：

1.  
   @RestController
2.  
   @RequestMapping("/openfeign/provider")
3.  
   public class OpenFeignProviderController {
4.  
   @PostMapping("/order1")
5.  
   public Order createOrder1(@RequestBody Order order){
6.  
   return order;
7.  
   }
8.  
   }

注意:在Spring Boot 中通过@RequestBody标识入参。

消费端Consumer在openFeign接口传参如下：

1.  
   @FeignClient(value = "openFeign-provider")//服务名
2.  
   public interface OpenFeignService {
3.  
   /**
4.  
   * 参数默认是@RequestBody标注的，这里的@RequestBody可以不填
5.  
   * 方法名称任意
6.  
   */
7.  
   @RequestMapping("/openfeign/provider/order1", method = RequestMethod.GET)
8.  
   Order createOrder1(@RequestBody Order Order);
9.  
   }

注意: 我用的是@RequestMapping注解 这是一个组合注解，里面包含@RequestBody 可以不填。

2. POJO表单传参

服务端Provider接口传参方法如下：

1.  
   @RestController
2.  
   @RequestMapping("/openfeign/provider")
3.  
   public class OpenFeignProviderController {
4.  
   @PostMapping("/order2")
5.  
   public Order createOrder2(Order order){
6.  
   return order;
7.  
   }
8.  
   }

注意: 参数使用POJO对象接收。

消费端Consumer在openFeign接口传参如下：

1.  
   @FeignClient(value = "openFeign-provider")
2.  
   public interface OpenFeignService {
3.  
   /**
4.  
   * 参数默认是@RequestBody标注的，如果通过POJO表单传参的，使用@SpringQueryMap标注
5.  
   */
6.  
   @RequestMapping("/customer/information/order2", method = RequestMethod.GET)
7.  
   Order createOrder2(@SpringQueryMap Order order);
8.  
   }

注意: openFeign提供了一个注解@SpringQueryMap解决POJO表单传参，这也是官方文档明确给出了解决方案。

3. URL中携带参数

服务端Provider接口传参方法如下：

1.  
   @RestController
2.  
   @RequestMapping("/openfeign/provider")
3.  
   public class OpenFeignProviderController {
4.  
    
5.  
   @GetMapping("/test/{id}")
6.  
   public String test(@PathVariable("id")Integer id){
7.  
   return "accept one msg id=" id;
8.  
   }

注意: 此种方式针对restful方式中的GET请求方式。

消费端Consumer在openFeign接口传参如下：

1.  
   @FeignClient(value = "openFeign-provider")
2.  
   public interface OpenFeignService {
3.  
    
4.  
   @GetMapping("/openfeign/provider/test/{id}")
5.  
   String get(@PathVariable("id")Integer id);
6.  
   }

注意: 使用注解@PathVariable接收url中的占位符。

四、开启日志增强

说明: openFeign 虽提供了日志增强功能，但默认是不显示任何日志的，开发者在调试阶段可以自己配置日志的级别。

级别如下:

• NONE：默认的，不显示任何日志;

• BASIC：仅记录请求方法、URL、响应状态码及执行时间;

• HEADERS：除了BASIC中定义的信息之外，还有请求和响应的头信息;

• FULL：除了HEADERS中定义的信息之外，还有请求和响应的正文及元数据。

1. 配置日志级别

自定义一个配置类，在其中设置日志级别如下：

1.  
    
2.  
   import feign.Logger;
3.  
   import org.springframework.context.annotation.Bean;
4.  
   import org.springframework.context.annotation.Configuration;
5.  
    
6.  
   @Configuration
7.  
   public class OpenFeginConfig {
8.  
   /**
9.  
   * 日志级别定义
10.  
    * @return
11.  
    */
12.  
    @Bean
13.  
    Logger.Level OpenFeignLoggerLevel(){
14.  
    return Logger.Level.FULL;
15.  
    }
16.  
    }

注意细节：Logger导包是feign包。

2. YAML配置

1.  
   logging:
2.  
   level:
3.  
   com.lt.crm.service.api: debug

注意：此处 com.lt.crm.service.api 是 openFeign 接口所在的包名，可以根据自己项目路径配置一个特定的openFeign接口。

3. 注解@FeignClient中配置 configuration

说明:@FeignClient配置里 configuration = OpenFeginConfig.class

1.  
   @Repository
2.  
   @FeignClient(name = "service-client", url = "http://10.1.8.22:9001", contextId = "ConsumerService", fallbackFactory = TransactionFallBackFactory.class, configuration = OpenFeginConfig.class)
3.  
   public interface ConsumerService {
4.  
    
5.  
   @RequestMapping(value = "/customer/information/customerlist", method = RequestMethod.GET)
6.  
   JSONObject queryCustomerList(@RequestParam(value = "pageNum") final int pageNum, @RequestParam(value = "pageSize") final int pageSize);
7.  
    
8.  
    
9.  
   }

4. 查看打印日志示意图

五、Gzip压缩数据(全局压缩~接口与浏览器响应压缩)

1. 全局压缩相关配置

1.  
   ######################################接口与浏览器响应压缩######################################
2.  
   #全局压缩（接口与浏览器响应压缩）
3.  
   server:
4.  
   compression:
5.  
   #开启Gzip压缩
6.  
   enabled: true
7.  
   #配置min-response-size 压缩数据大小的最小阈值，默认2048
8.  
   min-response-size: 1 #设置1kb以上开始压缩
9.  
   #配置mime-types 压缩支持的MIME TYPE
10.  
    mime-types:
11.  
    - image/png
12.  
    - image/jpeg
13.  
    - image/jpg
14.  
    - text/html
15.  
    - text/xml
16.  
    - application/xml
17.  
    - application/json

min-response-size 和 mime-types 含默认值，可以不手动指定，如有其他需要可按需指定

2. 测试压缩

未开启压缩前 请求数据大小为526KB

开启压缩 请求数据大小为82KB

点击查看请求头信息

3. Gzip压缩算法

Gzip是一种数据格式，采用deflate算法压缩数据；当GZIP算法压缩到一个纯文本数据时，效果会非常显著。

数据经过压缩后实际上降低了网络传输的字节数，最明显的好处就是可以加快网页加载的速度。网页加载速度加快，除了节省流量，改善用户的浏览体验外。

Gzip压缩传输原理图如下:

1、客户端向服务器请求头中带有：Accept-Encoding:gzip,deflate 字段，向服务器表示，客户端支持的压缩格式（gzip或者deflate)，如果不发送该消息头，服务器是不会压缩的。

2、服务端在收到请求之后，如果发现请求头中含有 Accept-Encoding 字段，并且支持该类型的压缩，就对响应报文压缩之后返回给客户端，并且携带 Content-Encoding:gzip 消息头，表示响应报文是根据该格式压缩过的。

3、客户端接收到响应之后，先判断是否有 Content-Encoding 消息头，如果有，按该格式解压报文。否则按正常报文处理。

六、OpenFeign开启Gzip压缩数据(局部压缩~微服务之间利用Feign请求及响应压缩)

1. 全局压缩相关配置

1.  
   ######################################openFegin Gzip######################################
2.  
   #局部压缩（微服务之间利用feign请求及响应压缩）
3.  
   feign:
4.  
   compression:
5.  
   request:
6.  
   enabled: true # 开启压缩
7.  
   min-request-size: 1 # 开启压缩的阈值，单位字节，默认2048，即是2k，此处为演示效果设置成1字节
8.  
   mime-types: text/xml,application/xml,application/json
9.  
   response:
10.  
    enabled: true #响应压缩

注意：openFeign支持的Gzip仅仅是在openFeign接口的请求和响应，即openFeign消费者调用服务提供者的接口。

2. 开启Gzip压缩后日志信息

查看Gzip压缩开启后的打印日志

日志中包含 content-encoding: gzip 表示压缩成功

3. 开启Gzip压缩后日志信息

查看Gzip压缩关闭后的打印日志

日志中未出现 content-encoding: gzip 表示未被压缩 并且可以清楚看到时间为 1231ms

七、如何OpenFegin 替换默认的httpclient ?

前言:

1、OpenFeign在默认情况下使用的是JDK原生的URLConnection发送HTTP请求，没有连接池，但是对每个地址会保持一个长连接，即利用HTTP的persistence connection。
2、默认的http客户端是 javax.net.ssl.HttpsURLConnection，详细信息查看feign-core：feign.Client，该http客户端不支持添加拦截器和连接池。所以我们需要添加第三方http客户端。

在生产环境中，通常也不会使用默认的httpclient，两种选择如下：

• 使用ApacheHttpClient

• 使用OkHttp

声明: 我使用的是 OkHttp 如果使用 ApacheHttpClient 思路是基本一致 。

1. pom.xml依赖如下

1.  
   <!-- 使用 Apache HttpClient 替换 Feign原生httpclient-->
2.  
   <dependency>
3.  
   <groupId>org.apache.httpcomponents</groupId>
4.  
   <artifactId>httpclient</artifactId>
5.  
   </dependency>
6.  
   <!-- 使用 Okhttp 替换 Feign原生httpclient-->
7.  
   <dependency>
8.  
   <groupId>io.github.openfeign</groupId>
9.  
   <artifactId>feign-okhttp</artifactId>
10.  
    <version>10.1.0</version>
11.  
    </dependency>

2. application.properties 启用 OkHttp 配置

1.  
   # 默认开启
2.  
   feign.httpclient.enabled=false
3.  
   # 默认关闭
4.  
   feign.okhttp.enabled=true

关闭默认的httpclient 开启okhttp

3. 配置OkHttp响应拦截器

前言:

微服务之间使用OpenFeign，由于业务得需求有时候我们需要在请求或者响应的时候做一些额外的操作。比如请求的时候添加请求头，响应时候判断token是否过期等等。这时候拦截器就派上用场了！

1.  
   import lombok.extern.slf4j.Slf4j;
2.  
   import okhttp3.Interceptor;
3.  
   import okhttp3.MediaType;
4.  
   import okhttp3.OkHttpClient;
5.  
   import okhttp3.Request;
6.  
   import okhttp3.Response;
7.  
   import okhttp3.ResponseBody;
8.  
   import org.springframework.context.annotation.Bean;
9.  
   import org.springframework.context.annotation.Configuration;
10.  
    import java.io.IOException;
11.  
     
12.  
    @Slf4j
13.  
    @Configuration
14.  
    public class FeignOkHttpClientConfig {
15.  
     
16.  
     
17.  
    @Bean
18.  
    public OkHttpClient.Builder okHttpClientBuilder() {
19.  
    return new OkHttpClient.Builder().addInterceptor(new FeignOkHttpClientResponseInterceptor());
20.  
    }
21.  
     
22.  
     
23.  
    /**
24.  
    * okHttp响应拦截器
25.  
    */
26.  
    public static class FeignOkHttpClientResponseInterceptor implements Interceptor {
27.  
     
28.  
     
29.  
    @Override
30.  
    public Response intercept(Chain chain) throws IOException {
31.  
     
32.  
    Request originalRequest = chain.request();
33.  
    Response response = chain.proceed(originalRequest);
34.  
     
35.  
    MediaType mediaType = response.body().contentType();
36.  
    String content = response.body().string();
37.  
    //解析content，做你想做的事情！！!
38.  
    System.out.print("拦截器" content "往哪跑?");
39.  
     
40.  
    //生成新的response返回，网络请求的response如果取出之后，直接返回将会抛出异常
41.  
    return response.newBuilder()
42.  
    .body(ResponseBody.create(mediaType, content))
43.  
    .build();
44.  
    }
45.  
    }
46.  
     
47.  
     
48.  
     
49.  
    }

4. Feign使用okhttpclient时报错:java.lang.IllegalStateException: original request is required

问题复现:

1.  
   2023-03-27 16:43:23.754 ERROR 21120 --- [ervice-client-1] c.l.c.s.f.TransactionFallBackFactory : TransactionMsgWaitingConfirm Error : java.lang.IllegalStateException: original request is required
2.  
   at feign.Util.checkState(Util.java:127)
3.  
   at feign.Response.<init>(Response.java:48)
4.  
   at feign.Response.<init>(Response.java:38)
5.  
   at feign.Response$Builder.build(Response.java:133)
6.  
   at feign.okhttp.OkHttpClient.toFeignResponse(OkHttpClient.java:99)
7.  
   at feign.okhttp.OkHttpClient.execute(OkHttpClient.java:161)

具体描述:

可以看到状态200 请求成功 ，并且我设置的超时是5秒，而我查看后台日志请求只用了130ms说明没有超时，为什么一直走熔断? 为什么会一直报: java.lang.IllegalStateException: original request is required

解决方案:

最初我用的okhttp 版本是9.7.0 导致，feign-core 的版本和 feign-okhttp版本不一致问题引起，或者可以理解版本为不兼容导致，将 feign-okhttp版本换成 10.1.0 成方可解决。