SpringCloud-feign使用详解_Java

feign

1、openfeign是什么

feign是一个声明式webservice客户端。使用feign能让编写web service客户端更加简单。它的使用方法是定义一个服务接口然后在上面添加注解。feign也支持可拔插式的编码器和解码器。spring cloud对feign进行了封装，使其支持了spring mvc标准注解和httpmessageconverters。feign可以与eureka和ribbon组合使用以支持负载均衡。

2、feign能干什么

feign旨在使编写java http客户端变得更容易。

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

3、feign集成ribbon

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

4、feign和openfeign的区别

feign是spring cloud组件中的一个轻量级restful的http服务客户端feign内置了ribbon，用来做客户端负载均衡，去调用服务注册中心的服务。feign的使用方式是:使用feign的注解定义接口，调用这个接口，就可以调用服务注册中心的服务。

<dependency>
    <groupid>org.springframework.cloud</groupid>
    <artifactid>spring-cloud-starter-feign</artifactid>
</dependency>

openfeign是spring cloud在feign的基础上支持了springmvc的注解，如@requesmapping等等。openfeign的@feignclient可以解析springmvc的@requestmapping注解下的接口，并通过动态代理的方式产生实现类，实现类中做负载均衡并调用其他服务。

<dependency>
    <groupid>org.springframework.cloud</groupid>
    <artifactid>spring-cloud-starter-openfeign</artifactid>
</dependency>

5、feign的简单使用

1)openfeign的使用

1.添加依赖

    <!-- openfeign 远程调用 -->
    <dependency>
        <groupid>org.springframework.cloud</groupid>
        <artifactid>spring-cloud-starter-openfeign</artifactid>
    </dependency>

2.编写接口

@feignclient注解

value值的要调用的微服务名称

@feignclient(value = "mall-order",path = "/order")
public interface orderfeignservice {

    @requestmapping("/findorderbyuserid/{userid}")
    r findorderbyuserid(@pathvariable("userid") integer userid);


}

3.主启动类添加注解

@enablefeignclients

4.测试

2)feign的使用

1.添加依赖

    <!-- feign调用依赖 -->
    <dependency>
        <groupid>com.netflix.feign</groupid>
        <artifactid>feign-core</artifactid>
        <version>8.18.0</version>
    </dependency>
    <dependency>
        <groupid>com.netflix.feign</groupid>
        <artifactid>feign-jackson</artifactid>
        <version>8.18.0</version>
    </dependency>

2.编写接口

public interface feigndemo {


    @headers({"content-type: application/json","accept: application/json"})
    @requestline("get /order/findorderbyuserid/{userid}")
    r findorderbyuserid(@param("userid") integer userid);
}

3.测试

public class feigntest {

    public static void main(string[] args) {
        //基于json
        // encoder指定对象编码方式，decoder指定对象解码方式
        feigndemo service = feign.builder()
                .encoder(new jacksonencoder())
                .decoder(new jacksondecoder())
                .options(new request.options(1000, 3500))
                //.retryer(new retryer.default(5000, 5000, 3))
                .target(feigndemo.class, "http://localhost:8020/");

        system.out.println(service.findorderbyuserid(1));
    }
}

4.结果

6、openfeign自定义配置

1)日志配置

有时候我们遇到 bug，比如接口调用失败、参数没收到等问题，或者想看看调用性能，就需要配置 feign 的

日志了，以此让 feign 把请求信息输出来。

openfeign日志等级有四种分别为

none:不输出日志

basic:只输出请求方法的 url 和响应的状态码以及接口执行的时间。

headers：将 basic 信息和请求头信息输出。

full：输出完整的请求信息。

方式一:全局配置

1.编写配置类引入相关bean

@configuration
public class feignconfig {

    /**
     * 日志级别
     * 通过源码可以看到日志等级有 4 种，分别是：
     * none：不输出日志。
     * basic：只输出请求方法的 url 和响应的状态码以及接口执行的时间。
     * headers：将 basic 信息和请求头信息输出。
     * full：输出完整的请求信息。
     *
     * @return
     */
    @bean
    public logger.level feignloggerlevel() {
        return logger.level.full;
    }
}

2.修改配置文件

logging:
  level:
    com.tuling.mall.feigndemo.feign: debug #指定feign接口的路径

3.测试

方式二:局部配置

1.编写配置（不能主启动类扫描到),否则就成为了全局配置

@configuration
public class feignconfig {

    /**
     * 日志级别
     * 通过源码可以看到日志等级有 4 种，分别是：
     * none：不输出日志。
     * basic：只输出请求方法的 url 和响应的状态码以及接口执行的时间。
     * headers：将 basic 信息和请求头信息输出。
     * full：输出完整的请求信息。
     *
     * @return
     */
    @bean
    public logger.level feignloggerlevel() {
        return logger.level.full;
    }
}

2.配置文件

logging:
  level:
   com.qianyue.mall.openfeign: debug

3.修改注解信息

@feignclient(value = "mall-order",configuration = feignconfig.class) //指定配置
public interface orderfeignservice {

    @requestmapping("/order/findorderbyuserid/{userid}")
    r findorderbyuserid(@pathvariable("userid") integer userid);

}

说明：局部配置也可用通过配置文件方式配置

feign:
  client:
    config:
     mall-account:
      loggerlevel: full

2)契约配置

spring cloud 在 feign 的基础上做了扩展，可以让 feign 支持 spring mvc 的注解来调用。原生的 feign 是不支持 spring mvc 注解的，如果你想在 spring cloud 中使用原生的注解方式来定义客户端也是可以的，通过配置契约来改变这个配置，spring cloud 中默认的是 springmvccontract。

修改锲约配置步骤如下:

1.修改契约配置，支持feign原生的注解

    @bean
    public contract feigncontract(){
        return new contract.default();
    }

2.修改接口

此时将不再支持mvc的注解

@feignclient(value = "mall-order")
public interface orderfeignservice {

    @requestline("get /order/findorderbyuserid/{userid}")
    public r findorderbyuserid(@param("userid") integer userid);


}

3.补充，也可用通过yml配置锲约

feign:
  client:
    config:
     mall-order:
      loggerlevel: full
      contract: feign.contract.default #指定feign原生注解契约配置

3)拦截器配置

通常我们调用的接口都是有权限控制的，很多时候可能认证的值是通过参数去传递的，还有就是通过请求头去传递认证信息，比如 basic 认证方式。

方式一 basic认证

1.在配置类直接配置basic认证

    @bean
    public basicauthrequestinterceptor basicauthrequestinterceptor() {
        return new basicauthrequestinterceptor("qianyue", "123456");
    }

2.效果

调用接口会携带编码后的认证去访问接口

方式二 requestinterceptor认证

每次 feign 发起http调用之前，会去执行拦截器中的逻辑。

使用场景

统一添加 header 信息；
对 body 中的信息做修改或替换；

1.自定义拦截器实现认证逻辑

public class feignauthrequestinterceptor implements requestinterceptor {
    @override
    public void apply(requesttemplate template) {
        // 业务逻辑  模拟认证逻辑
        string access_token = uuid.randomuuid().tostring();
        template.header("authorization",access_token);
    }
}

2.拦截器添加到容器中

    @bean
    public feignauthrequestinterceptor feignauthrequestinterceptor(){
        return new feignauthrequestinterceptor();
    }

3.结果

4.也可用在yaml配置拦截器

feign:
  client:
    config:
     mall-order:
      requestinterceptors[0]:  #配置拦截器
       com.qianyue.mall.interceptor.feignauthrequestinterceptor

4)超时时间配置

通过 options 可以配置连接超时时间和读取超时时间，options 的第一个参数是连接的超时时间（ms），默认值是 2s；第二个是请求处理的超时时间（ms），默认值是 5s。

      @bean
      public request.options options(){
          return new request.options(5000, 5000);
      }

或者是在yaml中配置

feign:
  client:
    config:
     mall-order:
      connecttimeout: 5000  # 连接超时时间，默认2s
      readtimeout: 3000 #请求处理超时时间，默认5s

补充说明： feign的底层用的是ribbon，但超时时间以feign配置为准

5)客户端组件配置

feign 中默认使用 jdk 原生的 urlconnection 发送 http 请求，我们可以集成别的组件来替换掉

urlconnection，比如 apache httpclient，okhttp。

使用httpclient

1.引入依赖

        <!-- feign调用依赖 -->
        <dependency>
            <groupid>com.netflix.feign</groupid>
            <artifactid>feign-core</artifactid>
            <version>8.18.0</version>
        </dependency>
        <dependency>
            <groupid>com.netflix.feign</groupid>
            <artifactid>feign-jackson</artifactid>
            <version>8.18.0</version>
        </dependency>

2.添加配置

feign:
  httpclient:
    enabled: true #其实默认就是true

3.测试会调用apachehttpclient的execute方法

使用okclient

1.引入依赖

    <dependency>
    <groupid>io.github.openfeign</groupid>
    <artifactid>feign-okhttp</artifactid>
    </dependency>

2.修改yaml

feign:
  httpclient:
    enabled: false
  okhttp:
    enabled: true

3.测试

会调用okhttpclient的execute方法

关于这一块的配置可用参考feign的自动配置类feignautoconfiguration

6)压缩配置

开启压缩可以有效节约网络资源，提升接口性能，我们可以配置 gzip 来压缩数据：

开启配置

feign:
  httpclient:
    enabled: true
#  okhttp:
#    enabled: true
  compression:
    request:
      enabled: true
      # 配置压缩的类型
      mime-types: text/xml,application/xml,application/json
      # 最小压缩值
      min-request-size: 2048
    response:
      enabled: true

结果

注意：只有当 feign 的 http client 不是 okhttp3 的时候，压缩才会生效，配置源码在 feignacceptgzipencodingautoconfiguration

7)编码器解码器

feign 中提供了自定义的编码解码器设置，同时也提供了多种编码器的实现，比如 gson、jaxb、jackson。我们可以用不同的编码解码器来处理数据的传输。如果你想传输 xml 格式的数据，可以自定义 xml 编码解码器来实现获取使用官方提供的 jaxb

public interface encoder { 
    void encode(object object, type bodytype, requesttemplate template) throws encodeexcepti on; 
     } 
public interface decoder { 
    object decode(response response, type type) throws ioexception, decodeexception, feignex ception; 
}

javaconfig配置

    @bean
    public decoder decoder(){
            return new jacksondecoder();
    }

    @bean
    public encoder encoder(){
        return new jacksonencoder();
    }

yaml配置

feign:
  client:
    config:
     mall-order:
       encoder: feign.jackson.jacksonencoder
       decoder: feign.jackson.jacksondecoder

7、springcloud整合dubbo

1)生产者服务抽离

新建一个api工程,存放我们的dubbo接口如下

public interface userservice {

	list<user> list();
	user getbyid(integer id);

}

2)生产者代码

1.依赖

    <dependencies>
        <dependency>
            <groupid>com.alibaba.cloud</groupid>
            <artifactid>spring-cloud-starter-dubbo</artifactid>
        </dependency>

        <dependency>
            <groupid>com.alibaba.cloud</groupid>
            <artifactid>spring-cloud-starter-alibaba-nacos-discovery</artifactid>
        </dependency>


        <dependency>
            <groupid>com.qianyue.mall</groupid>
            <artifactid>mall-common</artifactid>
            <version>0.0.1-snapshot</version>
            <scope>compile</scope>
        </dependency>
        <dependency>
            <groupid>com.qianyue.spring-cloud-alibaba</groupid>
            <artifactid>mall-dubbo-api</artifactid>
            <version>0.0.1-snapshot</version>
            <scope>compile</scope>
        </dependency>

    </dependencies>

2.yaml配置

dubbo:
  scan:
    base-packages: com.qianyue.mall.service #服务实现类的扫描基准包	
  protocol:
    name: dubbo
    port: -1
spring:
  application:
    name: mall-order-dubbo
  datasource:
    type: com.alibaba.druid.pool.druiddatasource
    druid:
      driver-class-name: com.mysql.cj.jdbc.driver
      url: jdbc:mysql://localhost:3306/ms_order?useunicode=true&characterencoding=utf-8&servertimezone=asia/shanghai
      username: root
      password: 199787
      initial-size: 10
      max-active: 100
      min-idle: 10
      max-wait: 60000
      pool-prepared-statements: true
      max-pool-prepared-statement-per-connection-size: 20
      time-between-eviction-runs-millis: 60000
      min-evictable-idle-time-millis: 300000
      test-while-idle: true
      test-on-borrow: false
      test-on-return: false
      stat-view-servlet:
        enabled: true
        url-pattern: /druid/*
      filter:
        stat:
          log-slow-sql: true
          slow-sql-millis: 1000
          merge-sql: false
        wall:
          config:
            multi-statement-allow: true
  main:
    allow-bean-definition-overriding: true
  cloud:
    nacos:
      discovery:
        server-addr: 192.168.26.129


#mybatis-plus
mybatis-plus:
  mapper-locations: classpath*:/mapper/**/*.xml
  #实体扫描，多个package用逗号或者分号分隔
  typealiasespackage: com.qianyue.mall.entity
  global-config:
    #数据库相关配置
    db-config:
      #主键类型  auto:"数据库id自增"
      id-type: auto
      logic-delete-value: -1
      logic-not-delete-value: 0
      banner: false
    #原生配置
    configuration:
      map-underscore-to-camel-case: true
      cache-enabled: false
      call-setters-on-nulls: true
      jdbc-type-for-null: 'null'
server:
  port: 8510

3.服务实现类

@dubboservice
@slf4j
public class userserviceimpl implements userservice {


	@override
	public list<user> list() {
		log.info("查询user列表");
		list<user> list = new arraylist<>();
		return list;
	}

	@override
	public user getbyid(integer id) {
		return null;
	}


}

3)消费者代码

1.引入依赖

dependencies>
        <dependency>
            <groupid>com.alibaba.cloud</groupid>
            <artifactid>spring-cloud-starter-dubbo</artifactid>
        </dependency>

        <dependency>
            <groupid>com.alibaba.cloud</groupid>
            <artifactid>spring-cloud-starter-alibaba-nacos-discovery</artifactid>
        </dependency>

        <dependency>
            <groupid>com.qianyue.mall</groupid>
            <artifactid>mall-common</artifactid>
            <version>0.0.1-snapshot</version>
        </dependency>
        <dependency>
            <groupid>com.qianyue.spring-cloud-alibaba</groupid>
            <artifactid>mall-dubbo-api</artifactid>
            <version>0.0.1-snapshot</version>
            <scope>compile</scope>
        </dependency>
    </dependencies>

2.yaml配置

dubbo:
  cloud:
    subscribed-services: mall-order-dubbo #指定订阅的服务
  protocol:
    name: dubbo
    port: -1

spring:
  application:
    name: mall-user-dubbo
  datasource:
    type: com.alibaba.druid.pool.druiddatasource
    druid:
      driver-class-name: com.mysql.cj.jdbc.driver
      url: jdbc:mysql://localhost:3306/ms_order?useunicode=true&characterencoding=utf-8&servertimezone=asia/shanghai
      username: root
      password: 199787
      initial-size: 10
      max-active: 100
      min-idle: 10
      max-wait: 60000
      pool-prepared-statements: true
      max-pool-prepared-statement-per-connection-size: 20
      time-between-eviction-runs-millis: 60000
      min-evictable-idle-time-millis: 300000
      test-while-idle: true
      test-on-borrow: false
      test-on-return: false
      stat-view-servlet:
        enabled: true
        url-pattern: /druid/*
      filter:
        stat:
          log-slow-sql: true
          slow-sql-millis: 1000
          merge-sql: false
        wall:
          config:
            multi-statement-allow: true
  main:
    allow-bean-definition-overriding: true
  cloud:
    nacos:
      discovery:
        server-addr: 192.168.26.129
server:
  port: 8610

3.服务调用

@restcontroller
@requestmapping("/user")
@slf4j
public class usercontroller {

    @dubboreference
    userservice userservice;

    @requestmapping("/findorderbyuserid/{userid}")
    public user findorderbyuserid(@pathvariable("userid") integer userid){
        user user = userservice.getbyid(userid);
        return user;
    }

}