SpringCloud: Ⅰ、基本组件业务场景介绍:
开发一个电商网站,要实现支付订单的功能,流程如下:
创建一个订单之后,如果用户立刻支付了这个订单,我们需要将订单状态更新为“已支付”
扣减相应的商品库存
通知仓储中心,进行发货
给用户的这次购物增加相应的积分
服务分析
订单服务、库存服务、仓储服务、积分服务
流程调用
用户针对一个订单完成支付之后,就会去找订单服务,更新订单状态
订单服务调用库存服务,完成相应功能
订单服务调用仓储服务,完成相应功能
订单服务调用积分服务,完成相应功能
1、SpringCloud核心组件:Eureka2、Spring Cloud核心组件:Feign
Eureka是微服务架构中的注册中心,专门负责服务的注册与发现。
订单服务想要调用库存服务、仓储服务,或者是积分服务,怎么调用?
订单服务压根儿就不知道人家库存服务在哪台机器上啊!他就算想要发起一个请求,都不知道发送给谁,有心无力!Eureka Client:负责将这个服务的信息注册到Eureka Server中
Eureka Server:注册中心,里面有一个注册表,保存了各个服务所在的机器和端口号
现在订单服务确实知道库存服务、积分服务、仓库服务在哪里了,同时也监听着哪些端口号了。
但是新问题又来了:如何从订单服务跟其他服务建立网络连接,接着发送请求过去。
4、Spring Cloud核心组件:Hystrix集群服务:库存服务部署在了5台机器上
192.168.169:9000
192.168.170:9000
192.168.171:9000
192.168.172:9000
192.168.173:9000
Ribbon就是专门解决这个问题的。它的作用是负载均衡,会帮你在每次请求时选择一台机器,均匀的把请求分发到各个机器上
首先Ribbon会从 Eureka Client里获取到对应的服务注册表,也就知道了所有的服务都部署在了哪些机器上,在监听哪些端口号。
然后Ribbon就可以使用默认的Round Robin算法,从中选择一台机器
5、Spring Cloud核心组件:Zuul在微服务架构里,一个系统会有很多的服务。
以上面的业务场景为例:订单服务在一个业务流程里需要调用三个服务。
现在假设订单服务自己最多只有100个线程可以处理请求,然后呢,积分服务不幸的挂了,每次订单服务调用积分服务的时候,都会卡住几秒钟,然后抛出—个超时异常
出现问题:微服务架构中的服务雪崩问题
如果系统处于高并发的场景下,大量请求涌过来的时候,订单服务的100个线程都会卡在请求积分服务这块。导致订单服务没有一个线程可以处理请求
然后就会导致别人请求订单服务的时候,发现订单服务也挂了,不响应任何请求了
Hystrix是隔离、熔断以及降级的一个框架。
比如订单服务请求库存服务是一个线程池,请求仓储服务是一个线程池,请求积分服务是一个线程池。
每个线程池里的线程就仅仅用于请求那个服务。
6、组件总和:这个组件是负责网络路由的。
一般微服务架构中都必然会设计一个网关在里面,像android、ios、pc前端、微信小程序、H5等等。
不用去关心后端有几百个服务,就知道有一个网关,所有请求都往网关走,网关会根据请求中的一些特征,将请求转发给后端的各个服务。
有一个网关之后,还有很多好处,比如可以做统一的降级、限流、认证授权、安全,等等。
7、流程Eureka:各个服务启动时,Eureka Client都会将服务注册到Eureka Server,并且Eureka Client还可以反过来从Eureka Server拉取注册表,从而知道其他服务在哪里
Ribbon:服务间发起请求的时候,基于Ribbon做负载均衡,从一个服务的多台机器中选择一台
Feign:基于Feign的动态代理机制,根据注解和选择的机器,拼接请求URL地址,发起请求
Hystrix:发起请求是通过Hystrix的线程池来走的,不同的服务走不同的线程池,实现了不同服务调用的隔离,避免了服务雪崩的问题
Zuul:如果前端、移动端要调用后端系统,统一从Zuul网关进入,由Zuul网关转发请求给对应的服务
Ⅱ、springCloud关系①、请求统一通过API网关(Zuul)来访问内部服务.
②、网关接收到请求后,从注册中心(Eureka)获取可用服务
③、由Ribbon进行均衡负载后,分发到后端具体实例
④、微服务之间通过Feign进行通信处理业务
⑤、Hystrix负责处理服务超时熔断
Spring Cloud 包含很多子项目: Netflix 和 Alibaba 两个标准使用最多
1、Spring Cloud Netflix 第一代2、Spring Cloud Alibaba 第二代针对多种 Netflix 组件提供的开发工具包,其中包括 Eureka、Ribbon、Feign、Hystrix、Zuul、Archaius 等。
Netflix Eureka:一个基于 Rest 服务的服务治理组件,包括服务注册中心、服务注册与服务发现机制的实现,实现了云端负载均衡和中间层服务器的故障转移。
Netflix Ribbon:客户端负载均衡的服务调用组件。
Netflix Hystrix:容错管理工具,实现断路器模式,通过控制服务的节点,从而对延迟和故障提供更强大的容错能力。
Netflix Feign:基于 Ribbon 和 Hystrix 的声明式服务调用组件。
Netflix Zuul:微服务网关,提供动态路由,访问过滤等服务。
Netflix Archaius:配置管理 API,包含一系列配置管理 API,提供动态类型化属性、线程安全配置操作、轮询框架、回调机制等功能
3、阿里开源组件同 Spring Cloud 一样,Spring Cloud Alibaba 也是一套微服务解决方案。
Spring Cloud Alibaba 致力于提供微服务开发的一站式解决方案。此项目包含开发分布式应用微服务的必需组件,方便开发者通过 Spring Cloud 编程模型轻松使用这些组件来开发分布式应用服务。
依托 Spring Cloud Alibaba,只需要添加一些注解和少量配置,就可以将 Spring Cloud 应用接入阿里微服务解决方案,通过阿里中间件来迅速搭建分布式应用系统。
4、阿里商业化组件Nacos:阿里巴巴开源产品,一个更易于构建云原生应用的动态服务发现、配置管理和服务管理平台。
Sentinel:面向分布式服务架构的轻量级流量控制产品,把流量作为切入点,从流量控制、熔断降级、系统负载保护等多个维度保护服务的稳定性。
RocketMQ:一款开源的分布式消息系统,基于高可用分布式集群技术,提供低延时的、高可靠的消息发布与订阅服务。
Dubbo:Apache Dubbo™ 是一款高性能 Java RPC 框架,用于实现服务通信。
Seata:阿里巴巴开源产品,一个易于使用的高性能微服务分布式事务解决方案。
5、SpringCloud常用组件Alibaba Cloud ACM:一款在分布式架构环境中对应用配置进行集中管理和推送的应用配置中心产品。
Alibaba Cloud OSS:阿里云对象存储服务(Object Storage Service,简称 OSS),是阿里云提供的海量、安全、低成本、高可靠的云存储服务。您可以在任何应用、任何时间、任何地点存储和访问任意类型的数据。
Alibaba Cloud SchedulerX:阿里中间件团队开发的一款分布式任务调度产品,提供秒级、精准、高可靠、高可用的定时(基于 Cron 表达式)任务调度服务。
Alibaba Cloud SMS:覆盖全球的短信服务,友好、高效、智能的互联化通讯能力,帮助企业迅速搭建客户触达通道。
二、nacos搭建 1、新建项目,将此项目作为父项目,给子类提供依赖Spring Cloud Netflix Eureka:服务注册中心。
Spring Cloud Zookeeper:服务注册中心。
Spring Cloud Consul:服务注册和配置管理中心。
Spring Cloud Netflix Ribbon:客户端负载均衡。
Spring Cloud Netflix Hystrix:服务容错保护。
Spring Cloud Netflix Feign:声明式服务调用。
Spring Cloud OpenFeign(可替代 Feign):OpenFeign 是 Spring Cloud 在 Feign 的基础上支持了Spring MVC 的注解,如 @RequesMapping等等。OpenFeign 的 @FeignClient 可以解析 SpringMVC的 @RequestMapping 注解下的接口,并通过动态代理的方式产生实现类,实现类中做负载均衡并调用其他服务。
Spring Cloud Netflix Zuul:API 网关服务,过滤、安全、监控、限流、路由。
Spring Cloud Gateway(可替代 Zuul):Spring Cloud Gateway 是 Spring 官方基于 Spring 5.0,SpringBoot 2.0 和 Project Reactor 等技术开发的网关,Spring Cloud Gateway 旨在为微服务架构提供一种简单而有效的统一的 API 路由管理方式。Spring Cloud Gateway 作为 Spring Cloud 生态系中的网关,目标是替代 Netflix Zuul,其不仅提供统一的路由方式,并且基于 Filter 链的方式提供了网关基本的功能,例如:安全,监控/埋点,和限流等。
Spring Cloud Security:安全认证。
Spring Cloud Config:分布式配置中心。配置管理工具,支持使用 Git 存储配置内容,支持应用配置的外部化存储,支持客户端配置信息刷新、加解密配置内容等。
Spring Cloud Bus:事件、消息总线,用于在集群(例如,配置变化事件)中传播状态变化,可与Spring Cloud Config 联合实现热部署。
Spring Cloud Stream:消息驱动微服务。
Spring Cloud Sleuth:分布式服务跟踪。
Spring Cloud Alibaba Nacos:阿里巴巴开源产品,一个更易于构建云原生应用的动态服务发现、配置管理和服务管理平台。
Spring Cloud Alibabasentinel:面向分布式服务架构的轻量级流量控制产品,把流量作为切入点,从流量控制、熔断降级、系统负载保护等多个维度保护服务的稳定性。
Spring Cloud Alibaba RocketMQ:一款开源的分布式消息系统,基于高可用分布式集群技术,提供低延时的、高可靠的消息发布与订阅服务。
Spring Cloud Alibaba Dubbo:Apache Dubbo™ 是一款高性能 Java RPC 框架,用于实现服务通信。
Spring Cloud Alibabaseata:阿里巴巴开源产品,一个易于使用的高性能微服务分布式事务解决方案。
不需勾选:
2、cloud01项目导入依赖packing(打包类型,默认为jar)
pom : 父级项目(pom项目里没有java代码,也不执行任何代码,只是为了聚合工程或传递依赖用的)
jar : 内部调用或者是作服务使用
war : 需要部署的项目
dependencyManagement(管理jar包的版本,让子项目中引用一个依赖而不用显示的列出版本号)
dependencyManagement与dependencies区别:
dependencies即使在子项目中不写该依赖项,那么子项目仍然会从父项目中继承该依赖项(全部继承)
dependencyManagement里只是声明依赖,并不实现引入,因此子项目需要显示的声明需要用的依赖。
如果不在子项目中声明依赖,是不会从父项目中继承下来的。
只有在子项目中写了该依赖项,并且没有指定具体版本,才会从父项目中继承该项,并且version和scope都读取自父pom。
另外如果子项目中指定了版本号,那么会使用子项目中指定的jar版本。
modules(用来管理同个项目中的各个模块)
<?xml version="1.0" encoding="UTF-8"?>
①、nacos官网:nacos官网
选择第二个:
②、启动服务:
咱们就使用cmd文件进行启动:
③、打开页面:
④、将自带的sql脚本导入数据库:
⑥、打开application.properties文件
新增连接数据库内容:并重新启动
spring.datasource.platform=mysqldb.num=1db.url.0=jdbc:mysql://127.0.0.1:3306/nacos?characterEncoding=utf-8&connectTimeout=1000&socketTimeout=3000&autoReconnect=true&useUnicode=true&useSSL=false&serverTimezone=UTCdb.user.0=rootdb.password.0=123456
2、新建子项目:生产者项目①、子项目需要认父:pom.xml
<?xml version="1.0" encoding="UTF-8"?>
②、父项目需要认子:pom.xml
spring: cloud: nacos: discovery: server-addr: 127.0.0.1:8848 application: name: providerserver: port: 8081
④、在启动类加入注解//开启服务发现@EnableDiscoveryClient
运行:
成功,并在nacos中产生服务
3、新建子项目:消费者项目①、子项目需要认父:pom.xml,将不需要的依赖删掉,如生产者的
②、父项目需要认子:pom.xml
spring: cloud: nacos: discovery: server-addr: 127.0.0.1:8848 application: name: providerserver: port: 8082
④、在启动类加入注解//开启服务发现@EnableDiscoveryClient
三、方法调用例子:生产者生产物品,消费者拿
1、生产者 ①、建个controller层:生产鸡腿package com.provider.code;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RestController;@RestControllerpublic class ProviderController { @RequestMapping("/run") public String run(){ return ""; }}
2、消费者 ①、 在启动类写域名访问的一个对象package com.consumer.code;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.client.discovery.EnableDiscoveryClient;import org.springframework.context.annotation.Bean;import org.springframework.web.client.RestTemplate;@SpringBootApplication@EnableDiscoveryClientpublic class NacosConsumerApplication { public static void main(String[] args) { SpringApplication.run(NacosConsumerApplication.class, args); } @Bean// 域名访问的一个对象 public RestTemplate restTemplate(){ return new RestTemplate(); }}
②、controller层调用对象:ConsumerControllerpackage com.consumer.code;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RestController;import org.springframework.web.client.RestTemplate;@RestControllerpublic class ConsumerController { private RestTemplate template; @Autowired public ConsumerController(RestTemplate template) { this.template = template; } @RequestMapping("/run") public String run(){// 消费者找生产者要一个鸡腿(跨服务器访问) return template.getForObject("http://127.0.0.1:8081/run",String.class); }}
3、消费者调用路径写死的解决方案 ①、去nacos中找到服务名称 ②、将此名称放入路径中return template.getForObject("http://nacos-provider/run",String.class);
③、在消费者内导入依赖(负载均衡) ribbon状态:停止更新
替代方案:Spring Cloud Loadbalancer
// 达到负载均衡的目的 @LoadBalanced
本期内容结束~~~~