10-SpringCloud OpenFeign

2021-08-25 16:31:01 浏览数 (1)

OpenFeign基础知识

官方文档

GitHub地址

Feign is a declarative web service client. It makes writing web service clients easier. To use Feign create an interface and annotate it. It has pluggable annotation support including Feign annotations and JAX-RS annotations. Feign also supports pluggable encoders and decoders. Spring Cloud adds support for Spring MVC annotations and for using the same HttpMessageConverters used by default in Spring Web. Spring Cloud integrates Ribbon and Eureka, as well as Spring Cloud LoadBalancer to provide a load-balanced http client when using Feign. link

Feign是一个声明式WebService客户端。使用Feign能让编写Web Service客户端更加简单。它的使用方法是定义一个服务接口然后在上面添加注解。Feign也支持可拔插式的编码器和解码器。Spring Cloud对Feign进行了封装，使其支持了Spring MVC标准注解和HttpMessageConverters。Feign可以与Eureka和Ribbon组合使用以支持负载均衡。

Feign的作用

Feign旨在使编写Java Http客户端变得更容易。

前面在使用Ribbon RestTemplate时，利用RestTemplate对http请求的封装处理，形成了一套模版化的调用方法。但是在实际开发中，由于对服务依赖的调用可能不止一处，往往一个接口会被多处调用，所以通常都会针对每个微服务自行封装一些客户端类来包装这些依赖服务的调用。所以，Feign在此基础上做了进一步封装，由他来帮助我们定义和实现依赖服务接口的定义。在Feign的实现下，我们只需创建一个接口并使用注解的方式来配置它(以前是Dao接口上面标注Mapper注解,现在是一个微服务接口上面标注一个Feign注解即可)，即可完成对服务提供方的接口绑定，简化了使用Spring cloud Ribbon时，自动封装服务调用客户端的开发量。

Feign集成了Ribbon

利用Ribbon维护了Payment的服务列表信息，并且通过轮询实现了客户端的负载均衡。而与Ribbon不同的是，通过feign只需要定义服务绑定接口且以声明式的方法，优雅而简单的实现了服务调用。

Feign和OpenFeign两者区别

Feign是Spring Cloud组件中的一个轻量级RESTful的HTTP服务客户端Feign内置了Ribbon，用来做客户端负载均衡，去调用服务注册中心的服务。Feign的使用方式是:使用Feign的注解定义接口，调用这个接口，就可以调用服务注册中心的服务。

代码语言：javascript复制
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-feign</artifactId>
</dependency>

OpenFeign是Spring Cloud在Feign的基础上支持了SpringMVC的注解，如@RequesMapping等等。OpenFeign的@Feignclient可以解析SpringMVc的@RequestMapping注解下的接口，并通过动态代理的方式产生实现类，实现类中做负载均衡并调用其他服务。

代码语言：javascript复制
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>

OpenFeign服务调用

接口 注解：微服务调用接口 @FeignClient

新建80工程

新建cloud-consumer-feign-order80

修改POM.xml

代码语言：javascript复制
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>com.dance.springcloud</artifactId>
        <groupId>com.dance</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>cloud-consumer-feign-order80</artifactId>

    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
    </properties>

    <dependencies>
        <!--openfeign-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
        <!--eureka client-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <!-- dependent on common modules -->
        <dependency>
            <groupId>com.dance</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <!--web-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <!--一般基础通用配置-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

</project>

新建yml配置

代码语言：javascript复制
server:
  port: 80

eureka:
  client:
    register-with-eureka: false
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/

新建主启动类

代码语言：javascript复制
package com.dance.springcloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.openfeign.EnableFeignClients;

@SpringBootApplication
// 开启Feign客户端
@EnableFeignClients
public class OrderFeignMain80 {
    public static void main(String[] args) {
        SpringApplication.run(OrderFeignMain80.class, args);
    }
}

新建Service

业务逻辑接口 @FeignClient配置调用provider服务

新建PaymentFeignService接口并新增注解@FeignClient

代码语言：javascript复制
package com.dance.springcloud.service;

import com.dance.springcloud.entities.CommonResult;
import com.dance.springcloud.entities.Payment;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;


@Component
@FeignClient(value = "CLOUD-PAYMENT-SERVICE")
public interface PaymentFeignService {
    @GetMapping(value = "/payment/get/{id}")
    public CommonResult<Payment> getPaymentById(@PathVariable("id") Long id);

}

新建Controller

代码语言：javascript复制
package com.dance.springcloud.controller;

import com.dance.springcloud.entities.CommonResult;
import com.dance.springcloud.entities.Payment;
import com.dance.springcloud.service.PaymentFeignService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;

@RestController
@Slf4j
public class OrderFeignController {
    @Resource
    private PaymentFeignService paymentFeignService;

    @GetMapping(value = "/consumer/payment/get/{id}")
    public CommonResult<Payment> getPaymentById(@PathVariable("id") Long id) {
        return paymentFeignService.getPaymentById(id);
    }

}

测试

  1. 启动Eureka集群
  2. 启动提供者集群
  3. 启动Feign消费者
  4. 测试
  5. http://localhost/consumer/payment/get/1

Feign自带负载均衡配置项

OpenFeign超时控制

超时设置，故意设置超时演示出错情况,应为在微服务中,服务之间的调用有时候会因为网络的延迟,业务处理量大,等待时间长的问题,肯定是要处理超时的

修改提供者Controller

8001和8002两个服务Controller都添加接口,不然应为负载的问题会报错,找不到

代码语言：javascript复制
@RestController
@Slf4j
public class PaymentController {
    
      ................

    @GetMapping(value = "/payment/feign/timeout")
    public String paymentFeignTimeout() {
        // 业务逻辑处理正确，但是需要耗费3秒钟
        try {
            TimeUnit.SECONDS.sleep(3);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return serverPort;
    }
            
        ...............
}

修改消费者Service

代码语言：javascript复制
package com.dance.springcloud.service;

import com.dance.springcloud.entities.CommonResult;
import com.dance.springcloud.entities.Payment;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;


@Component
@FeignClient(value = "CLOUD-PAYMENT-SERVICE")
public interface PaymentFeignService {
    @GetMapping(value = "/payment/get/{id}")
    public CommonResult<Payment> getPaymentById(@PathVariable("id") Long id);
    @GetMapping(value = "/payment/feign/timeout")
    public String paymentFeignTimeout();
}

修改消费者Controller

代码语言：javascript复制
package com.dance.springcloud.controller;

import com.dance.springcloud.entities.CommonResult;
import com.dance.springcloud.entities.Payment;
import com.dance.springcloud.service.PaymentFeignService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;

@RestController
@Slf4j
public class OrderFeignController {
    @Resource
    private PaymentFeignService paymentFeignService;

    @GetMapping(value = "/consumer/payment/get/{id}")
    public CommonResult<Payment> getPaymentById(@PathVariable("id") Long id) {
        return paymentFeignService.getPaymentById(id);
    }

    @GetMapping(value = "/consumer/payment/feign/timeout")
    public String paymentFeignTimeout() {
        // OpenFeign客户端一般默认等待1秒钟
        return paymentFeignService.paymentFeignTimeout();
    }

}

测试

  1. 启动Eureka集群
  2. 启动提供者集群
  3. 启动OpenFeign消费者
  4. 浏览器测试
  5. http://localhost/consumer/payment/feign/timeout
  6. 将会跳出错误Spring Boot默认错误页面。

OpenFeign默认等待1秒钟，超过后报错

修改yml配置

YML文件里需要开启OpenFeign客户端超时控制

代码语言：javascript复制
server:
  port: 80

eureka:
  client:
    register-with-eureka: false
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/
#设置feign客户端超时时间(OpenFeign默认支持ribbon)(单位：毫秒)
ribbon:
  #指的是建立连接所用的时间，适用于网络状况正常的情况下,两端连接所用的时间
  ReadTimeout: 5000
  #指的是建立连接后从服务器读取到可用资源所用的时间
  ConnectTimeout: 5000

再次测试:

成功~

OpenFeign日志增强

日志打印功能

Feign提供了日志打印功能，我们可以通过配置来调整日恙级别，从而了解Feign 中 Http请求的细节。

说白了就是对Feign接口的调用情况进行监控和输出

日志级别

  • NONE：默认的，不显示任何日志;
  • BASIC：仅记录请求方法、URL、响应状态码及执行时间;
  • HEADERS：除了BASIC中定义的信息之外，还有请求和响应的头信息;
  • FULL：除了HEADERS中定义的信息之外，还有请求和响应的正文及元数据。

配置日志Bean

代码语言：javascript复制
package com.dance.springcloud.config;

import feign.Logger;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class FeignConfig {
    @Bean
    Logger.Level feignLoggerLevel() {
        return Logger.Level.FULL;
    }
}

修改yml配置

YML文件里需要开启日志的Feign客户端

代码语言：javascript复制
logging:
  level:
    # feign日志以什么级别监控哪个接口
    com.dance.springcloud.service.PaymentFeignService: debug

后台日志查看

得到更多日志信息。

代码语言：javascript复制
2021-08-23 19:33:48.678 DEBUG 8308 --- [p-nio-80-exec-1] c.d.s.service.PaymentFeignService        : [PaymentFeignService#paymentFeignTimeout] <--- HTTP/1.1 200 (3185ms)
2021-08-23 19:33:48.678 DEBUG 8308 --- [p-nio-80-exec-1] c.d.s.service.PaymentFeignService        : [PaymentFeignService#paymentFeignTimeout] connection: keep-alive
2021-08-23 19:33:48.678 DEBUG 8308 --- [p-nio-80-exec-1] c.d.s.service.PaymentFeignService        : [PaymentFeignService#paymentFeignTimeout] content-length: 4
2021-08-23 19:33:48.678 DEBUG 8308 --- [p-nio-80-exec-1] c.d.s.service.PaymentFeignService        : [PaymentFeignService#paymentFeignTimeout] content-type: text/plain;charset=UTF-8
2021-08-23 19:33:48.678 DEBUG 8308 --- [p-nio-80-exec-1] c.d.s.service.PaymentFeignService        : [PaymentFeignService#paymentFeignTimeout] date: Mon, 23 Aug 2021 11:33:48 GMT
2021-08-23 19:33:48.678 DEBUG 8308 --- [p-nio-80-exec-1] c.d.s.service.PaymentFeignService        : [PaymentFeignService#paymentFeignTimeout] keep-alive: timeout=60
2021-08-23 19:33:48.678 DEBUG 8308 --- [p-nio-80-exec-1] c.d.s.service.PaymentFeignService        : [PaymentFeignService#paymentFeignTimeout] 
2021-08-23 19:33:48.679 DEBUG 8308 --- [p-nio-80-exec-1] c.d.s.service.PaymentFeignService        : [PaymentFeignService#paymentFeignTimeout] 8001
2021-08-23 19:33:48.679 DEBUG 8308 --- [p-nio-80-exec-1] c.d.s.service.PaymentFeignService        : [PaymentFeignService#paymentFeignTimeout] <--- END HTTP (4-byte body)

又完成了一个组件的学习~开心心 撒花花

作者：彼岸舞

时间：2021823

内容关于：Spring Cloud H版

本文属于作者原创,未经允许,禁止转发

springcloud 负载均衡 负载均衡缓存 微服务

0 人点赞