springcloud学习总结

springcloud

构建微服务项目步骤

1. 导入依赖
2. 编写配置文件
3. 开启这个功能 @Enablexxx
4. 配置类

• 于2023年2月24日下午17点38分开始学习
• 于2023年3月17日晚上20点26分学完总结
• 代码地址：https://gitee.com/liang-weihao/StudySpringcloud
• 学习笔记地址：https://www.kuangstudy.com/bbs/1374942542566551554

简介

SpringCloud,基于SpringBoot提供了一套微服务解决方案，包括服务注册与发现，配置中心，全链路监控，服务网关，负载均衡，熔断器等组件，除了基于NetFlix的开源组件做高度抽象封装之外，还有一些选型中立的开源组件。

• springcloud就是为了分布式，通过rpc远程调用或http来互相通信访问
• spring boot的核心自动装配，约定大于配置
• 常用组件

Spring cloud有哪些常用组件，作用是什么?

1. Eureka:注册中心
2. Nacos:注册中心、配置中心
3. Consul: 注册中心、配置中心
4. Spring Cloud Config:配置中心
5. Feign/OpenFeign:RPC调用
6. Kong:服务网关
7. Zuul:服务网关
8. Spring Cloud Gateway: 服务网关
9. Ribbon:负载均衡
10. Spring CLoud sleuth: 链路追踪
11. Zipkin:链路追踪
12. Seata:分布式事务
13. Dubbo:RPC调用
14. Sentinel: 服务熔断
15. Hystrix:服务熔断

springcloud和springboot的关系

• SpringBoot专注于快速方便的开发单个个体微服务。 -Jar
• SpringCloud是关注全局的微服务协调整理治理框架，它将SpringBoot开发的一个个单体微服务整合并管理起来，为各个微服务之间提供: 配置管理，服务发现，断路器，路由，微代理，事件总线，全局锁，决策竞选，分布式会话等等集成服务。
• SpringBoot可以离开SpringClooud独立使用，开发项目，但是SpringCloud离不开SpringBoot，属于依赖关系
• SpringBoot专注于快速、方便的开发单个个体微服务，SpringCloud关注全局的服务治理框架

dubbo

• rpc框架
• dubbo专门的rpc远程调用
  
• spring cloudNetflix 2018年停更
  
  
• 微服务就是将传统一站式根据业务拆分成一个一个服务，彻底去耦合，一个微服务处理一件事情
• 微服务的优缺点
  
• 每个进程一个端口
  
• 微服务的技术栈
  
• 返回类型就是类点class

RestTemplate远程服务调用

 @Autowired//返回类型：（url，实体map，返回类型Class<T> responseType）
private RestTemplate restTemplate;//提供多种便捷访问http服务的方法，简单的restful服务模板

package com.liang.springcloud.controller;import com.liang.springcloud.pojo.Dept;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.client.RestTemplate;import java.util.List;@Controller
@ResponseBody
public class DeptConsumerController {//理解：消费者，不应该有service层//RestTemplate很多方法给我们直接调用，注册到spring中@Autowired//返回类型：（url，实体map，返回类型Class<T> responseType）private RestTemplate restTemplate;//提供多种便捷访问http服务的方法，简单的restful服务模板private static final String REST_URL_PREFIX = "http://localhost:8001";@RequestMapping("/consumer/dept/add")public boolean add(Dept dept){return restTemplate.postForObject(REST_URL_PREFIX+"/dept/add",dept, Boolean.class);}//http://localhost:8001/dept/list要从这个地址拿到数据@RequestMapping("/consumer/dept/get/{id}")public Dept get(@PathVariable("id") Long id){return restTemplate.getForObject(REST_URL_PREFIX+"/dept/get/"+id,Dept.class);}@RequestMapping("/consumer/dept/list")public List<Dept> list(){return restTemplate.getForObject(REST_URL_PREFIX+"dept/list", List.class);}
}

Eureka服务注册与发现

• 主需要在主启动类上加注解@EnableEurekaServer

@SpringBootApplication
@EnableEurekaServer //服务端的启动类，可以接受别人注册进来
public class EurekaService_7001 {public static void main(String[] args) {SpringApplication.run(EurekaService_7001.class,args);}
}

• 在其他服务配置文件，配置好eureka配置，然后在主启动类加上注解自动注册

@EnableEurekaClient//cs架构，自动在服务启动后自动注册到eureka中

什么是eureka？

Eureka: 怎么读?

• Netflix 在设计Eureka时，遵循的就是AP原则
  Eureka是Netflix的一个子模块，也是核心模块之一。Eureka是一个基于REST的服务，用于定位服务，以实现云端中间层服务发现和故障转移，服务注册与发现对于微服务来说是非常重要的，有了服务发现与注册，只需要使用服务的标识符，就可以访问到服务，而不需要修改服务调用的配置文件了，功能类似于Dubbo的注册中心，比如Zookeeper;

• 心跳监测机制，五秒不回复证明挂掉，就会把服务节点移掉

• 自我保护机制（宁可保留全部服务，也不盲目注销任何健康的服务）

• 注意yml文件，编写要空一格

• 搭建eureka集群，对应配置文件加上绑定互联

• 创建三个服务端口分别为，注册中心（7001,7002,7003）
  

server:port: 7003# eureka配置
eureka:instance:hostname: eureka7003.com #Eureka服务端的实例名称client:register-with-eureka: false # 表示是否向eureka注册中心注册自己fetch-registry: false # fetch-registry 如果为false，则表示自己为注册中心service-url: # 监控页面defaultZone: http://eureka7002.com:7002/eureka/,http://eureka7001.com:7001/eureka/

• 集群信息
  
• 把注册的提供服务8001启动，就会注册到对应的服务里

server:port: 8001#mybatis的配置
mybatis:type-aliases-package: com.liang.springcloud.pojoconfig-location: classpath:mybatis/mybatis-config.xmlmapper-locations: classpath:mybatis/mapper/*.xml#spring的配置
spring:application:name: springcloud-provider-deptdatasource:type: com.alibaba.druid.pool.DruidDataSourcedriver-class-name: com.mysql.jdbc.Driverurl: jdbc:mysql://localhost:3306/db01?useUnicode=true&characterEncoding=utf-8username: rootpassword: root# Eureka的配置，服务注册到哪里
eureka:client:service-url:defaultZone: http://localhost:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/instance:instance-id: springcloud-provider-dept8001-liangwh #修改的是eureka status默认的描述信息
#info配置
info:app.name: liangwh-springcloudcompany.name: liangwh123321.com

zookeeper和eureka的区别

• cap原则，一个分布式系统不可能同时满足三个

• 作为服务注册中心，Eureka比Zookeeper好在哪里?

  • 著名的CAP理论指出，一个分布式系统不可能同时满足C(一致性)、A (可用性)、P (容错性)。由于分区容错性P在分布式系统中是必须要保证的，因此我们只能在A和C之间进行权衡

    。Zookeeper保证的是CP;
    。Eureka保证的是AP:
    

ribbon负载均衡

• Spring Cloud Ribbon是基于Netflix Ribbon实现的一套客户端负载均衡的工具（轮询和随机）

• 简单的说，Ribbon是Netflix发布的开源项目，主要功能是提供客户端的软件负载均衡算法，将NetFlix的中间层服务连接在一起。Ribbon的客户端组件提供一系列完整的配置项如: 连接超时、重试等等。简单的说，就是在配置文件中列出LoadBalancer (简称LB: 负载均衡)后面所有的机器，Ribbon会自动的帮助你基于某种规则(如简单轮询，随机连接等等) 去连接这些机器。我们也很容易使用Ribbon实现自定义的负载均衡算法

• 负载均衡，把用户的请求平摊到多个服务上，达到高可用

ribbon能干嘛?
。LB，即负载均衡 (Load Balance) ，在微服务或分布式集群中经常用的一种应用。
。负载均衡简单的说就是将用户的请求平摊的分配到多个服务上，从而达到系统的HA(高可用)
。常见的负载均衡软件有 Nginx，Lvs 等等
·dubbo、 SpringCloud中均给我们提供了负载均衡，SpringCloud的负载均衡算法可以自定义
。负载均衡简单分类:
集中式LB0
即在服务的消费方和提供方之间使用独立的LB设施，如Nginx（反向代理），由该设施负责把访问请求通过某种策略转发至服务的提供方!
进程式LB，将LB逻辑集成到消费方，消费方从服务注册中心获知有哪些地址可用，然后自己再从这些地址中选出一个合适的服务器
Ribbon就属于进程内LB它只是一个类库，集成于消费方进程，消费方通过它来获取到服务提供方的地址!

• 注意报错 - @org.springframework.beans.factory.annotation.Autowired(required=true)

表明引用的类没有注入到bean中需要在该类加上注解 @Bean

@Configuration
public class ConfigBean {
//配置负载均衡实现RestTemplate@Bean@LoadBalanced//ribbonpublic RestTemplate getRestTemplate(){return  new RestTemplate();}
}

• @Bean一般和@Configuration一起使用

• idea显示数据库

• 集群，三个服务提供者对应三个不同的数据库，通过ribbon实现负载均衡访问不同数据库（轮询）
  
  

ribbon默认算法

//ribbon 和 eureka整合以后，客户端可以直接调用，不用关心ip 和 端口号
//消费者主启动类
@SpringBootApplication
@EnableEurekaClient
//在微服务启动的时候就能去加载我们自定义的ribbon类
@RibbonClient(name = "SPRINGCLOUD-PROVIDER-DEPT",configuration = liangRule.class)
public class DeptConsumer_88 {public static void main(String[] args) {SpringApplication.run(DeptConsumer_88.class, args);}}

• 注意自定义类要在主启动类上一级
  

package com.liang.myrule;
import com.netflix.client.config.IClientConfig;
import com.netflix.loadbalancer.AbstractLoadBalancerRule;
import com.netflix.loadbalancer.ILoadBalancer;
import com.netflix.loadbalancer.Server;import java.util.List;
import java.util.concurrent.ThreadLocalRandom;public class LiangRandomRule extends AbstractLoadBalancerRule {//每个服务，访问6次，换下一个服务（3个）//total=0，默认=0，如果=6，指向下一个服务节点//index= 0,默认=0，如果total = 5，index+1private  int total = 0; //被调用的次数private int currentIndex = 0; //当前谁提供的服务@SuppressWarnings({"RCN_REDUNDANT_NULLCHECK_OF_NULL_VALUE"})public Server choose(ILoadBalancer lb, Object key) {if (lb == null) {return null;} else {Server server = null;while(server == null) {if (Thread.interrupted()) {return null;}List<Server> upList = lb.getReachableServers();//获得可访问服务器List<Server> allList = lb.getAllServers();//获取全部服务int serverCount = allList.size();if (serverCount == 0) {return null;}//                int index = this.chooseRandomInt(serverCount);//生成区间随机数
//                server = (Server)upList.get(index);//从活着的服务中，随机获取一个// -自定义算法开始==============================if (total<5){server = upList.get(currentIndex);total++;}else {total = 0;currentIndex ++;if (currentIndex>=upList.size()){currentIndex = 0;}server = upList.get(currentIndex);//从活着的服务中，获得指定的服务来操作}// -自定义算法结束==============================if (server == null) {Thread.yield();} else {if (server.isAlive()) {return server;}server = null;Thread.yield();}}return server;}}protected int chooseRandomInt(int serverCount) {return ThreadLocalRandom.current().nextInt(serverCount);}public Server choose(Object key) {return this.choose(this.getLoadBalancer(), key);}public void initWithNiwsConfig(IClientConfig clientConfig) {}
}

@Configuration
public class liangRule {@Beanpublic IRule myRule(){return new LiangRandomRule();//默认是轮询，现在我们自定义访问自己定义的算法}
}

Feign负载均衡

简介

• feign是声明式的web service客户端，它让微服务之间的调用变得更简单了，类似controller调用service。SpringCloud集成了Ribbon和Eureka，可在使用Feign时提供负载均衡的http客户端。
  只需要创建一个接口，然后添加注解即可!
  feign ，主要是社区，大家都习惯面向接口编程。这个是很多开发人员的规范。调用微服务访问两种方法
  1.微服务名字 (ribbon]
  2.接口和注解 [feign ]
• 主要靠接口和注解就可以使用

在service加上注解

@FeignClient(value = "SPRINGCLOUD-PROVIDER-DEPT")

• 接口

@Component//注入到容器
@FeignClient(value = "SPRINGCLOUD-PROVIDER-DEPT")
public interface DeptClientService {@GetMapping("/dept/get/{id}")public Dept queryById(@PathVariable("id")Long id);@GetMapping("/dept/list")public List<Dept> queryAll();@PostMapping("/dept/add")public boolean addDept(Dept dept);
}

• controller 层

@RestController
public class DeptConsumerController {//理解：消费者，不应该有service层//RestTemplate很多方法给我们直接调用，注册到spring中@Autowired//返回类型：（url，实体map，返回类型Class<T> responseType）private RestTemplate restTemplate;//提供多种便捷访问http服务的方法，简单的restful服务模板//ribbon（负载均衡） 我们这里的地址应该是一个变量，通过服务访问
//    private static final String REST_URL_PREFIX = "http://localhost:8001";
//    private static final String REST_URL_PREFIX = "http://SPRINGCLOUD-PROVIDER-DEPT";@Autowiredprivate DeptClientService deptClientService;@RequestMapping("/consumer/dept/add")public boolean add(Dept dept){return this.deptClientService.addDept(dept);}//http://localhost:8001/dept/list要从这个地址拿到数据@RequestMapping("/consumer/dept/get/{id}")public Dept get(@PathVariable("id") Long id){return deptClientService.queryById(id);}@RequestMapping("/consumer/dept/list")public List<Dept> list(){return this.deptClientService.queryAll();}

• 主启动类

@SpringBootApplication
@EnableEurekaClient
@EnableFeignClients(basePackages = {"com.liang.springcloud"})
public class FeignDeptConsumer_88 {public static void main(String[] args) {SpringApplication.run(FeignDeptConsumer_88.class, args);}}

Hystrix服务熔断降级

简介

Hvstrix是一个用于处理分布式系统的延迟和容错的开源库，在分布式系统里，许多依赖不可避免的会调用失败，比如超时，异常等，Hystrix能够保证在一个依赖出问题的情况下，不会导致整体服务失败，避免级联故障以提高分布式系统的弹性。
"断路器"本身是一种开关装置，当某个服务单元发生故障之后，通过断路器的故障监控(类似熔断保险丝)，向调用方返回一个服务预期的，可处理的备选响应(FallBack)，而不是长时间的等待或者抛出调用方法无法处理的异常，这样就可以保证了服务调用方的线程不会被长时间，不必要的占用，从而避免了故喷在分布式系统中的蔓延，乃至雪崩

Hystrix能干嘛

。服务降级
。服务熔断
。服务限流
。接近实时的监控

• 服务雪崩
  
• ‘弃车保帅’

服务熔断

服务熔断是什么？

• 熔断机制是对应雪崩效应的一种微服务链路保护机制
  当扇出链路的某个微服务不可用或者响应时间太长时，会进行服务的降级，进而熔断该节点微服务的调用，快速返回 错误的响应信息。当检测到该节点微服务调用响应正常后恢复调用链路。在Springloud框架里熔断机制通过Hystrix实现。Hvstrix会监控微服务间调用的状况，当失败的调用到一定闻值，5秒内20次调用失败就会启动熔断机制。
  熔断机制的注解是 @HystrixCommand。

• 在主启动类加上注解@EnableCircuitBreaker//添加对熔断的支持

• 链式编程注解（在对应实体类加上即可）

@Accessors(chain = true)//链式写法	
@Data
@NoArgsConstructor
@Accessors(chain = true)//链式写法
public class Dept implements Serializable {private Long deptno;//主键private String dname;private String db_source;//一个服务对应一个数据库，数据库存的字段public Dept(String dname) {this.dname = dname;}
}

• 写法

   //备选方法@GetMapping("/dept/get/{id}")public Dept hystrixGet(@PathVariable("id") Long id){return  new Dept().setDeptno(id).setDname("id=>"+id+"没有对应信息，null==@hystrix").setDb_source("no this database in mysql");}

• hystrix服务熔断调用其他方法

    @GetMapping("/dept/get/{id}")@HystrixCommand(fallbackMethod = "hystrixGet")//只要失败就调用其他方法public Dept get(@PathVariable("id") Long id){Dept dept = deptService.queryById(id);if (dept == null){throw  new RuntimeException("id=>"+id+"不存在这个id");}return  dept;}//备选方法public Dept hystrixGet(@PathVariable("id") Long id){return  new Dept().setDeptno(id).setDname("id=>"+id+"没有对应信息，null==@hystrix").setDb_source("no this database in mysql");}

服务降级

• 先开启eureka注册中心7001再开启服务提供者8001最后开启消费者88，然后把8001提供者挂掉，降级就会默认返回自定义信息，而不是直接访问不到数据库
  
• 对应消费者配置文件加上降级

#开启降级 feign.hystrix
feign:hystrix:enabled: true

@Component//注入到容器
@FeignClient(value = "SPRINGCLOUD-PROVIDER-DEPT",fallbackFactory = DeptClientServiceFactory.class)
public interface DeptClientService {@GetMapping("/dept/get/{id}")public Dept queryById(@PathVariable("id")Long id);@GetMapping("/dept/list")public List<Dept> queryAll();@PostMapping("/dept/add")public boolean addDept(Dept dept);
}

//降级~
@Component
public class DeptClientServiceFactory implements FallbackFactory {@Overridepublic DeptClientService create(Throwable throwable) {return new DeptClientService() {@Overridepublic Dept queryById(Long id) {return new Dept().setDeptno(id).setDname("id=>"+id+"没有对应的信息，客户端提供了降级的信息，这个服务现在已经被关闭").setDb_source("no数据");}}

总结

• 服务熔断

  • 服务端（某个服务超时或者异常，引起熔断）

• 服务降级

  • 客户端 （从整体网站请求负载考虑，当某个服务熔断关闭之后，服务将不被调用），服务就不被调用
  • 可以在客户端自定义回调fallbackFactory，返回一个默认值，整体服务下降，但是能用比挂掉强

  dashboard监控

  • 在主启动类加上注解@EnableHystrixDashboard //开启
  • 配置好端口

• 直接访问

• 填写监测路径
  
• 去对应的请求刷新，这边监测页面会对应刷新
  
  绿色代表健康红色危险

Zuul路由网关

概述

• 什么是Zuul?

  • Zuul包含了对请求的路由和过滤两个最主要的功能!
    其中路由功能负责将外部请求转发到具体的微服务实例上，是实现外部访问统一入口的基础，而过滤器功能则负责对请求的处理过程进行干预，是实现请求校验，服务聚合等功能的基础。Zuul和Eureka进行整合，将Zuul自身注册为Eureka服务治理下的应用，同时从Eureka中获得其他微服务的消息，也即以后的访问微服务都是通过Zuul跳转后获得
    注意: Zuul服务最终还是会注册进Eureka
    提供:代理 + 路由 + 过滤 三大功能!
    Zuul能干嘛?

• 路由

• 过滤

• 主启动类加上注解@EnableZuulProxy //zuul启动

访问地址：http://www.liangstudy.com:9527/springcloud-provider-dept/dept/get/1

zuul:routes:mydept.serviceId: springcloud-provider-dept  # 配置自定义路径mydept.path: /mydept/**ignored-services: "*"  # 忽略全部#ignored-services: springcloud-provider-dept  #不能再使用这个路径访问prefix: /liang #设置访问公共的前缀

• http://www.liangstudy.com:9527/mydept/dept/get/1

• http://www.liangstudy.com:9527/liang/mydept/dept/get/1

config配置中心

概述
分布式系统面临的–配置文件的问题

• 微服务意味着要将单体应用中的业务拆分成一个个子服务，每个服务的粒度相对较小，因此系统中会出现大量的服务，由于每个服务都需要必要的配置信息才能运行，所以一套集中式的，动态的配置管理设施是必不可少的。SpringCloud提供了ConfigServer来解决这个问题，我们每一个微服务自己带着一个application.yml，那上百的的配置文件要修改起来，岂不是要发疯!

• Spring loud Config 为微服务架构中的微服务提供集中化的外部配置支持，配置服务器为各个不同微服务应用的所有环节提供了一个中心化的外部配置。

• springc config 分为服务端和客户端两部分

Springcloud config分布式配置中心能干嘛
。集中管理配置文件
。不同环境，不同配置，动态化的配置更新，分环境部署，比如 /dev /test/ /prod /beta /release

。运行期间动态调整配置，不再需要在每个服务部署的机器上编写配置文件，服务会向配置中心统一拉取配置自己的信息。
。当配置发生变动时，服务不需要重启，即可感知到配置的变化，并应用新的配置0
。将配置信息以REST接口的形式暴露

• Git clone代码的时候 下用ssh（需要公钥秘钥）报错的时候就用https得clone
  

Git

• Git add .添加到本地仓库

• Git status 查看当前文件的提交状态

• Git commit -m ‘描述信息’ 提交到本地暂存区

• Git push上传到远程服务器

• 修改git的配置

  • $ git config --global user.email "[e-mail]"
  • $ git config --list
  • $ git config --global user.name "liangweihao"

• 主启动类加上注解@EnableConfigServer

• 访问路径：http://localhost:3344/application-dev.yml

• 记得把Git仓库设为开源公开状态
  

• 客户端拿服务端的代码

• 拼接
  
  
  
  毕业啦！