SpringCloud搭建微服务之OpenFeign远程调用

导读:本篇文章讲解 SpringCloud搭建微服务之OpenFeign远程调用,希望对大家有帮助,欢迎收藏,转发!站点地址:www.bmabk.com

1. 概述

Feign是一个声明式WebService客户端,其使用方法是定义一个服务接口,然在接口上添加注解,Spring Cloud对Feign进行了封装,使其支持Spring MVC标准注解和HttpMessageConverters,Feign可以与Eureka和Ribbon组合使用以支持负载均衡

2. 引入核心依赖

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

3. 编写application.yml文件

server:
  port: 8790
spring:
  application:
    name: cloud-openfeign
eureka:
  client:
    register-with-eureka: false
    service-url:
      defaultZone: http://localhost:8761/eureka

4. 编写主启动类

@SpringBootApplication
@EnableEurekaClient
@EnableFeignClients
public class OpenFeignApplication {

    public static void main(String[] args) {
        SpringApplication.run(OpenFeignApplication.class, args);
    }
}

5. 编写服务提供接口

@FeignClient(value = "CLOUD-PROVIDER", configuration = FeignConfiguration.class)
public interface ProviderClient {

    @GetMapping(value = "/provider/getProviderInfo/{message}", consumes = "application/json")
    String getProviderInfo(@PathVariable("message") String message);
}

注意
value:是服务提供者在Eureka注册中心的名称
configuration:自定义Feign配置,比如日志级别,安全校验等

6. 编写业务访问接口类

@RestController
@RequestMapping("/openfeign")
public class OpenFeignController {

    @Autowired
    private ProviderClient providerClient;

    @GetMapping("/getOpenFeignInfo/{message}")
    public String getOpenFeignInfo(@PathVariable("message") String message) {
        String providerInfo = providerClient.getProviderInfo(message);
        return "This is openfeign consumer, from provider get info is " + providerInfo;
    }
}

7. 验证

依次启动Eureka Server、Provider和Feign Consumer微服务,浏览器地址输入http://localhost:8790/openfeign/getOpenFeignInfo/world
feign接口访问

8. OpenFeign超时控制

在服务提供端新增超时测试方法

@GetMapping("/getProviderTimeout")
public String getProviderTimeout() {
    try {
        TimeUnit.SECONDS.sleep(3);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    return "This is provider, The port is " + serverPort;
}

在服务消费端新增超时测试feign接口和业务测试接口

@GetMapping(value = "/provider/getProviderTimeout")
String getProviderTimeout();
@GetMapping(value = "/timeout")
public String openFeignTimeOUt() {
    return providerClient.getProviderTimeout();
}

分别启动Eureka Server、Provider和consumer,浏览器地址输入http://localhost:8790/openfeign/timeout
超时验证
查看服务端控制台日志,提示Read timed out
超时日志
OpenFeign客户端默认只等待一秒钟,服务端处理业务超过1秒钟,导致Feign客户端不等待了,直接返回错误,为了避免这样的情况,需要在yml配置文件中配置Feign超时配置

feign:
  client:
    config:
      default:
        connectTimeout: 5000 #连接超时
        readTimeout: 5000 #读取超时

再次启动客户端服务,浏览器输入http://localhost:8790/openfeign/timeout
超时测试

9. OpenFeign日志打印

OpenFeign提供日志打印功能,可以通过配置来调整日志级别,从而了解Feign中Http请求的细节,也就是对Feign接口的调用情况进行监控和输出

9.1. 日志级别

Feign的日志级别有以下四种

  • NONE:默认,不显示任何日志
  • BASIC:记录请求方法、URL、响应状态码及执行时间
  • HEADERS:记录请求方法、URL、响应状态码及执行时间、请求和响应头信息
  • FULL:记录请求方法、URL、响应状态码及执行时间、请求和响应头信息、请求和响应的正文和元数据

9.2. 配置日志级别

新增Feign配置类,添加日志Bean

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

在yml配置文件中开启日志的Feign客户端

logging:
  level:
    com.xlhj.cloud.openfeign.api.ProviderClient: debug

重新启动Feign客户端,查看控制台日志
Feign日志

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

文章由极客之家整理,本文链接:https://www.bmabk.com/index.php/post/76751.html

(0)
小半的头像小半

相关推荐

极客之家——专业性很强的中文编程技术网站,欢迎收藏到浏览器,订阅我们!