前言:OpenFeign是可以跨服务、跨进程的调用方式。
什么是Feign
Feign是Netflix开发的声明式、模版化的HTTP客户端。
优势:
Feign可以做到使用 HTTP 请求远程服务时就像调用本地方法一样的体验,开发者完全感知不到这是远程方法,更感知不到这是个 HTTP 请求,开发者无需关注与远程的交互细节,更无需关注分布式环境开发。
Spring Cloud Alibaba快速整合OpenFeign
1、引入依赖,谁远程调用谁引入这个依赖
<!-- openfeign 远程调用 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
2、编写调用接口
package com.by.controller;
import cn.by.moder.OrderDTO;
import cn.by.moder.OrderOkDTO;
import cn.by.moder.OrderQueryDTO;
import cn.hutool.core.thread.ThreadUtil;
import cn.hutool.core.util.StrUtil;
import org.springframework.web.bind.annotation.*;
import java.math.BigDecimal;
import java.util.List;
import java.util.stream.Collectors;
@RestController
@RequestMapping("/api/order")
public class OrderController {
@GetMapping("/test")
public String test() {
return "咸蛋超人杨order";
}
@GetMapping("/ordering")
public String ordering() {
return "咸蛋超人杨";
}
@GetMapping("/ordering1")
public OrderOkDTO ordering1() {
OrderOkDTO build = OrderOkDTO.builder().id(10086L).needPay(new BigDecimal(100)).build();
return build;
}
@PostMapping("/ordering2")
public OrderOkDTO ordering2(@RequestBody OrderDTO orderDTO) {
List<String> names = orderDTO.getProducts().stream().map(item->item.getName()).collect(Collectors.toList());
String join = StrUtil.join(",", names);
OrderOkDTO build = OrderOkDTO.builder().id(10086L).needPay(new BigDecimal(100)).msg(join).build();
return build;
}
@GetMapping("/select")
public String select(OrderQueryDTO queryDTO) {
String empty = StrUtil.EMPTY;
if (queryDTO.getId() != null) {
empty = "通过Id查询"+queryDTO.getId();
}
if (queryDTO.getUserId()!= null) {
empty = "通过UserId查询"+queryDTO.getUserId();
}
return empty;
}
@GetMapping("/sleep")
public String sleep(@RequestParam Integer time) {
ThreadUtil.safeSleep(time*1000);
return "你睡眠了"+time+"秒";
}
}
3、在创建一个调用端,调用端在启动类上添加@EnableFeignClients注解,并创建service接口+@FeignClient注解
接口
package com.by.service;
import cn.by.moder.OrderDTO;
import cn.by.moder.OrderOkDTO;
import cn.by.moder.OrderQueryDTO;
import com.by.config.FeignConfig;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.cloud.openfeign.SpringQueryMap;
import org.springframework.web.bind.annotation.*;
//如果想单独配置某个服务的日志级别,使用configuration单独配置
// @FeignClient(name = "order-service-app",configuration = FeignConfig.class)
@FeignClient(name = "order-service-app")
@RequestMapping("/api/order")
public interface OrderService {
@GetMapping("/ordering")
String ordering();
@GetMapping("/ordering1")
OrderOkDTO ordering1();
@PostMapping("/ordering2")
OrderOkDTO ordering2(@RequestBody OrderDTO orderDTO);
@GetMapping("/select")
String select(@SpringQueryMap OrderQueryDTO queryDTO);
@GetMapping("/sleep")
String sleep(@RequestParam Integer time);
}
4、发起调用,像调用本地方法一样调用远程服务
高级配置
1、全局配置
注意一:此处配置@Configuration注解就会全局生效,如果想指定对应某一个服务生效,就不能配置.
注意二: 因为feign调试日志是debug级别输出,springboot默认的日志级别是info,所以feign的debug日志级别就不会输出,一定要结合
package com.by.config;
import feign.Logger;
import feign.Request;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.util.concurrent.TimeUnit;
@Configuration //全局配置 结合properties中的logging.level.com.by = debug使用
public class FeignConfig {
// @Bean
// Logger.Level feignLoggerLevel(){
// // 这里记录所有请求和响应的详细信息,包括头信息等
// return Logger.Level.FULL;
// }
@Bean
public Request.Options options(){
return new Request.Options(10, TimeUnit.SECONDS,20, TimeUnit.SECONDS,true);
}
}
2 、局部配置
局部配置,让调用的微服务生效,在@FeignClient 注解中指定使用的配置类
3、 在配置文件配置
logging.level.com.beiyou = debug
开启日志
##配置feign 的日志级别
#-- default 全局配置
feign.client.config.default.loggerLevel=NONE
#-- nacos-a 具体服务名
feign.client.config.nacos-a.loggerLevel=FULL
超时配置
全局配置
配置文件配置
#全局配置
feign.client.config.default.connectTimeout=5000
feign.client.config.default.readTimeout=10000
这里default 是一个特殊的客户端名称,用于表示全局配置。设置 connectTimeout 和 readTimeout 属性的值来定义全局的连接超时时间和读取超时时间。
#局部配置 请将 <clientName> 替换为实际的Feign客户端名称。
feign.client.config.<clientName>.connectTimeout=5000
feign.client.config.<clientName>.readTimeout=10000
feign.client.config.order-service.connectTimeout=5000 # 连接超时时间,默认10s order-service: #对应微服务
feign.client.config.order-service.readTimeout=10000 # 请求处理超时时间,默认60s