SpringCloud(二)

一.服务的调用-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的熔断器会自动打开,拦截后续的所有请求,立刻判定失败,进行服务降级。过了单位时间之后,熔断器变成半开状态,放行一个请求,如果还是失败,继续全开,拦截请求,否则熔断器关闭.

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。