一.服务的调用-Ribbon + RestTemplate(独立的组件)
1.Ribbon
Ribbon是一个客户端的负载均衡器,用来进行SpringCloud间的微服务负载均衡调用
2.服务器端的负载均衡与客户端的负载均衡
如下图所示:
负载均衡的方式:
(1)客户端负载均衡
(2)服务端负载均衡
- 网络4层负载
- 网络7层负载 - nginx
3.Ribbon+RestTemplate的使用
(1)再创建一个微服务(班级服务),用于后续的服务间调用
(2)在主动的调用方(学生服务 -> 班级服务,学生服务就是主动调用方)添加ribbon依赖
<!-- 添加ribbon依赖 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
</dependency>
(3)启动类中声明RestTemplate组件
@Bean
@LoadBalanced//负载均衡
public RestTemplate getRest(){
return new RestTemplate();
}
(4)编写服务调用代码
//根据班级id,调用班级服务,查询班级信息
//关键 调用地址 MICRO-CLASSES 必须写一个微服务的名称
String classInfo = restTemplate
.getForObject("http://MICRO-CLASSES/cls/queryClsName?cid=1",String.class);
4.Ribbon的负载均衡
若微服务名称相同,那么就是集群关系
spring:
application:
name: micro-classes
(1)Ribbon的负载均衡策略
默认是轮询,如下是随机负载均衡规则
/**
* 切换负载均衡策略
* @return
*/
@Bean
public IRule getRule(){
return new RandomRule();
}
二.服务的调用-Feign
1.Feign
Feign底层也调用了Ribbon,Feign其实本质上是Ribbon + Hystrix(豪猪)的集合体,因为Ribbon本身的写法不够面向对象,很多Java程序员对这种写法会很不习惯。
2.使用
(1)调用方添加feign的依赖
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
(2)编写一个Feign接口(关键)
@FeignClient("MIRCO-TEACHER")
public interface ITeacherFeign {
@RequestMapping("/tea/queryTeaName")
String queryTeaName(@RequestParam("tid") Integer tid);
}
(3)在需要调用微服务的地方,注入改接口
@Autowired
private ITeacherFeign teacherFeign;
...
//远程调用教师服务
String s = teacherFeign.queryTeaName(cid);
(4)配置启动类注解
@SpringBootApplication(scanBasePackages = "com.qf")
@EnableEurekaClient
//表示启动feign,而且这个注解需要找到Feign接口所在的包,默认去启动类所在包下找
//所有如果Feign接口没有在启动类的包下,就需要手动配置扫描
@EnableFeignClients(basePackages = "com.qf.feign")
public class ClassesApplication {
public static void main(String[] args) {
SpringApplication.run(ClassesApplication.class, args);
}
}
3.Feign的超时与重试
Feign默认超时时间为1S,如果1S内,被调用方没有返回结果,就默认失败,然后重试1次。
有些时候,如果不加干预,可能引起请求的重复发送,导致出现各种问题
注意:Feign自带超时和重试的功能,但是默认是关闭的。所以我们看到的超时和重试的效果,是底层Ribbon提供的。如果开启了Feign的超时重试就会覆盖掉Ribbon的设置
(1)设置Feign的超时和重试:
#配置ribbon的超时和重试
ribbon:
#配置的是连接超时
ConnectTimeout: 1000
#配置读超时
ReadTimeout: 1000
#配置ribbon的重试次数,默认是0
MaxAutoRetries: 0
#配置ribbon的下个服务的重试次数,默认是1
MaxAutoRetriesNextServer: 0
#MaxAutoRetriesNextServer为m, 表示会重试(m + 1)个实例
#MaxAutoRetries为n,表示单实例重试(n + 1)次
#总的执行次数 (n + 1) * (m + 1)
#配置Feign的超时,一旦配置了Feign的超时,ribbon的重试和超时会全部失效
feign:
client:
config:
MIRCO-TEACHER: #可以针对不同的微服务配置不同的超时时间
connectTimeout: 1000
readTimeout: 6000
MIRCO-STUDENT:
connectTimeout: 1000
readTimeout: 2000
三.Hystrix(断路器)
1.Hystrix
(1)断路器 - 就是微服务架构的保险丝.
(2)在微服务架构中,根据业务会拆分成一个一个的微服务,服务于服务之间可以互相调用。为了保证高可用性,单个服务通常会集群部署,但是由于网络等原因,不能保证服务100%可用。如果单个服务出现问题,调用这个服务的服务就有可能出现线程阻塞,刚好这个时候大量的请求在访问当前服务,就会导致当前服务的线程资源不足,从而导致服务瘫痪,形成故障转移,导致"服务雪崩"
2.Hystrix是如何解决服务间调用问题的
(1)资源隔离:鸡蛋不要放在一个篮子里(线程池隔离、信号量隔离)
(2)服务降级:当调用目标服务出问题(超时、报错....)时,会自动的调用一个本地的方法,返回一个默认值
(3)请求熔断:一旦确定目标服务出问题(失败比例),Hystrix的熔断器会自动打开,拦截后续的所有请求,立刻判定失败,进行服务降级。过了单位时间之后,熔断器变成半开状态,放行一个请求,如果还是失败,继续全开,拦截请求,否则熔断器关闭.