首先,在正式的工作使用场景下,由于项目的复杂结构和庞大的代码量,不会将所有代码放到一个项目里。这时就用到微服务CAP理论的P(分区容错性),将其分为多个项目。
分成多个项目,服务之间就不能像传统的dao,service那样直接调用,服务之间的通信发生改变。
在传统的Eureka全家桶中,创建服务注册中心,多个服务注册进去,进行相互调用,调用时为了提升速度和防止服务挂掉,可指定负载均衡的服务调用的策略。负载均衡服务调用有两种方式:Ribbon和Feign。
1:Ribbon的实现方式是ribbon+restTemplate,ribbon设置负载均衡的实现方式(轮询、随机等),restTemplate进行接口的调用。代码可读较差,需要用到restTemplate的内置方法。
2:Feign已经停更,所以这里直接介绍OpenFeign,OpenFeign相较于Feign的基础上做了强化,添加了对SpringMVC的支持。实现方式为定义一个服务接口,并添加@FeignClient注解,指定要调用的微服务的名称,即可像调用service那样调用其他服务接口,更加符合面向接口编程。
<!--添加openFeign依赖-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
指定获取服务的注册中心,多个注册中心为集群。
#Eureka配置
eureka:
client:
register-with-eureka: false #是否注册进服务中心
service-url:
#注册中心地址 集群为多个配置
defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka
@EnableFeignClients,代表在这个项目中激活并使用Feign进行服务调用和负载均衡。
@SpringBootApplication
//激活openFeign
@EnableFeignClients
public class ConsumerFeign80 {
public static void main(String[] args) {
SpringApplication.run(ConsumerFeign80.class, args);
}
}
该接口可以抽离成公共方法,供多个服务使用。这里抽成公共的,所以添加了Component注解注册到容器中,主要是FeignClient注解后的微服务名称不要写错,和下面的接口路径要和所调用服务提供的接口全路径一致,不然会找不到。
/**
* Feign调用微服务
* FeignClient注解需要添加所需要调用的微服务的名称
*/
@Component
@FeignClient(value = "cloud-eureka-provider")
public interface PaymentFeignService {
/**
* 通过id查询支付信息
*
* @param id
* @return
*/
@GetMapping("/api/v1/payment/selById/{id}")
CommonResult selPaymentById(@PathVariable("id") Long id);
}
接口创建好之后,我们可以直接依赖注入使用,如同调用普通接口一样。
@Slf4j
@RestController
public class OrderFeignController {
@Autowired
private PaymentFeignService paymentFeignService;
/**
* 通过id查询支付信息
*
* @param id
* @return
*/
@GetMapping("/consumer/payment/selById/{id}")
public CommonResult selPaymentById(@PathVariable("id") Long id) {
return paymentFeignService.selPaymentById(id);
}
}
调用接口,测试是否服务调用成功。
OpenFeign的默认服务调用时间为一秒钟,即一秒后如果还没有调用成功,则直接报错Timeout。
如果我们的业务确实需要较长时间,则需要手动设置超长时间。
只需要添加两个配置即可,新旧版本配置不同,老的依赖使用Ribbon的配置。
#新版Feign连接超时这样配置,旧版使用Ribbon配置
feign:
client:
config:
default:
#建立连接所用的时间,适用于网络正常的情况下,两端连接所用的时间
connect-timeout: 5000
#连接后从服务器获取可用资源的时间
read-timeout: 5000
Feign提供了日志打印的功能,供我们了解服务调用的详细操作,便于问题的排查。
有两种方式,直接在配置添加或者配置类添加的方式实现。
feign:
client:
config:
default: #default表示全局配置,也可以单独写某个微服务的名称,进行微服务的单独配置
loggerLevel: FULL #日志级别有:NONE、BASIC、HEADERS、FULL
注意,使用配置类添加,在配置文件中也是要引用的。
/**
* Feign日志配置类
*/
@Configuration
public class FeignConfig {
@Bean
Logger.Level feignLoggerLevel() {
//FULL 代表全的日志
return Logger.Level.FULL;
}
}
#以什么级别监控哪个接口
logging:
level:
com.aaa.springcloud.service.PaymentFeignService: debug
使用过程中有时会产生这个错误,The bean xxx could not be registered
简单来说,就是一个项目中存在多个接口使用@FeignClient调用同一个服务,正常来说一个服务只能用@FeignClient使用一次。
可以添加配置将其放开,允许多个调用。
#配置Spring(不配置报错)
spring:
main:
#允许存在多个Feign调用相同Service的接口
allow-bean-definition-overriding: true
好了,到这里OpenFeign的基本使用就介绍完了,希望能够帮到大家,一起学习进步。
因篇幅问题不能全部显示,请点此查看更多更全内容