Feign 声明式服务调用

2019-10-16 0 By admin

Spring Cloud Feign 基于Netflix Feign 实现,整合了Spring Cloud Ribbon 与 Spring Cloud Hystrix ,除了提供这两者的强大功能之外,还提供了一种声明式的WEB 服务客户端定义方式。

Feign是Netflix开发的声明式、模块化的HTTP客户端,其灵感来自Retrofit、JAXRS-2.0以及WebSocket。Feign可帮组我们更加便捷、优雅的调用HTTP API。
在Spring Cloud中,使用Feign非常简单,通过创建一个接口,并在接口上添加一些注解,代码就完成了。Feign支持多种注解,例如Feign自带的注解或者JAX-RS注解等。
Spring Cloud对feign进行了增强,使Feign支持了Spring MVC注解,并整合了Ribbon和Eureka,从而让Feign的使用更加便捷。

为Eureka 的服务消费者整合Feign

新建 Spring Boot 工程,工程名称 springcloud-eureka-feign

一、POM文件依赖

<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>

二、工程启动类编辑

添加注解 @EnableDiscoveryClient,@EnableFeignClients

package com.miniooc.eurekafeign;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.openfeign.EnableFeignClients;
 
/**
 * EurekaFeignApplication
 * 应用程序启动类,程序入口
 */
@EnableDiscoveryClient // 启用 Eureka 服务发现
@EnableFeignClients // 启用 Feign
@SpringBootApplication
public class EurekaFeignApplication {
 
    public static void main(String[] args) {
        SpringApplication.run(EurekaFeignApplication.class, args);
    }
}

三、消费者的服务类

package com.miniooc.eurekafeign.service;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.stereotype.Service;
import org.springframework.web.bind.annotation.RequestMapping;
 
/**
 * EurekaFeignService
 * 服务消费者,调用服务提供者提供的服务,实现业务
 */
@FeignClient(value = "eureka-client") // 调用的服务的名称(Eureka 提供者的名称)
public interface EurekaFeignService {
 
    @RequestMapping(value = "/info") // 调用Eureka 提供者的URL
    String getInfo();
 
}

四、消费者的控制类

package com.miniooc.eurekafeign.controller;
import com.miniooc.eurekafeign.service.EurekaFeignService;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
 
/**
 * EurekaFeignController
 * 服务消费控制器类,对用户提供服务
 */
@RestController
public class EurekaFeignController {
 
    @Resource
    private EurekaFeignService eurekaFeignService;
 
    @RequestMapping("/feignInfo")
    public String feignInfo() {
        String message = eurekaFeignService.getInfo();
        return "获取到的信息:" + message;
    }
}

五、工程的配置文件

server:
  port: 52620
spring:
  application:
      name: eureka-discovery-feign
eureka:
  instance:
    hostname: localhost
    # 表示eureka client间隔多久去拉取服务注册信息,默认为30秒,如果要迅速获取服务注册状态,可以缩小该值
    lease-renewal-interval-in-seconds: 5
    # 表示eureka server至上一次收到client的心跳之后,等待下一次心跳的超时时间,在这个时间内若没收到下一次心跳,则将移除该instance。
    # 默认为90秒
    # 如果该值太大,则很可能将流量转发过去的时候,该instance已经不存活了。
    # 如果该值设置太小了,则instance则很可能因为临时的网络抖动而被摘除掉。
    # 该值至少应该大于 leaseRenewalIntervalInSeconds
    lease-expiration-duration-in-seconds: 10
  client:
    serviceUrl:
      defaultZone: http://localhost:9527/eureka/