Spring Cloud 1.1学习
2021-06-28 14:52:56 53 举报AI智能生成
登录查看完整内容
Spring Cloud学习
作者其他创作
大纲/内容
Spring Cloud 学习
1、微服务架构
https://gitee.com/moxi159753/LearningNotes/tree/master/SpringCloud/SpringCloud2020/
2、从2.2.x和H版开始说起
3、关于Cloud各种组件的停更/升级/替换
由停更引发的\"升级惨案\"
停更不停用
被动修复Bugs
不再接受合并请求
不再发布新版本
补充，O(∩_∩)O哈哈~
停课不停学
明细条目
SpringCloud 以前组件
Eureka 服务注册与发现
Netflix Ribbon 负载均衡
Netflix Feign 服务调用
Netflix Hystrix 服务熔断降级
Netflix Zuul 服务网关
Spring Cloud Config 服务分布式配置
Spring Boot 服务开发
Spring Cloud升级
服务注册中心
Eureka
Zookeeper
Consul
Nacos
负载均衡
Ribbon 客户端负载均衡、达到系统的HA（高可用）
LoadBalancer
服务调用
Feign
OpenFeign
服务降级
Hystrix
resilience4j
sentienl
服务网关
Zuul
Zuul2
gateway
服务配置
Config
服务总线
Bus
参考资料见官网
Spring Cloud
Spring Cloud英文文档
https://cloud.spring.io/spring-cloud-static/Hoxton.SR1/reference/htmlsingle/
Spring Cloud中文文档
https://www.bookstack.cn/read/spring-cloud-docs/docs-index.md
Spring Boot
https://docs.spring.io/spring-boot/docs/2.2.2.RELEASE/reference/htmlsingle/
4、微服务架构编码架构
约定 > 配置 > 编码
IDEA新建project工作空间
1、微服务cloud整体聚合父工程Project
父工程步骤
1、New Project
2、聚合总父工程名字
3、Maven选版本
4、工程名字
5、字符编码
6、注解生效激活
7、java编译版本选8
8、File Type过滤
9、多个微服务启动
2、父工程POM
3、Maven 工程落地 细节复习
Maven中的 DependencyManagement 和 Dependencies
Maven中跳过单元测试
4、父工程创建完成执行mvn:install将父工程发布到仓库方便子工程继承
5、MySql驱动说明
Rest微服务工程构建
1、构建步骤
1、cloud-provider-payment8001微服务提供者支付Module模块
1、建cloud-provider-payment8001
创建完成后请回到父工程查看pom文件变化
2、改POM
3、写YML
4、主启动
5、业务类
1、建表SQL
2、entity
主实体Payment
Json封装响应体
CommonResult<T>
ResponseCode
3、mapper
接口PaymentMapper
mybaits的映射文件PaymentMapper.xml
路径
src\\main\esources\\mapper\\PaymentMapper.xml
文件头
PaymentMapper.xml
4、service
接口PaymentService
实现类PaymentServiceImpl
5、controller
6、测试
postman模拟Get请求
http://localhost:8001/payment/get/1
postman模拟Post请求
http://localhost:8001/payment/create
第一步设置 Headers
第二部设置 Body
运行
通过修改idea的workspace.xml的方式来快速打开Run Dashboard窗口
开启Run DashBoard
部分同学可能由于idea版本不同，需要关闭重启
7、小总结
1、建module
2、热部署Devtools
1、Adding devtools to your project 下段配置我们粘贴进 8001 子项目中添加依赖
2、Adding plugin to your pom.xml下段配置我们粘贴进聚合父类总工程的pom.xml里
3、Enabling automatic build 勾选启用自动构建
4、Update the value of 更新值
①：快捷键 Ctrl + Shift + Alt + /
②：选择复选框
5、重启IDEA
3、cloud-consumer-order8080微服务消费者订单Module模块
1、建cloud-consumer-order8080
3、写YML application.yml
4、主启动 MainApp8080
entity
首说RestTemplate
是什么
官网及使用
config配置类
ApplicationContextConfig
controller
http://localhost:8080/consumer/payment/get/1
http://localhost:8080/consumer/payment/create?serial=金额100
4、工程重构 cloud-api-commons
观察问题
系统中有重复部分，重构
新建
cloud-api-commons
POM
maven命令clean install
订单80和支付8001分别改造
删除各自的原先有过的entities文件夹
各自粘贴POM内容
cloud-consumer-order8080
cloud-provider-payment8001
2、目前工程样图
5、Eureka服务注册与发现
Dubbo
Eureka基础知识
什么是服务治理
什么是服务注册
Eureka两组件
单机Eureka构建步骤
IDEA生成eurekaServer端服务注册中心类似物业公司cloud-eureka-server7001
建Module cloud-eureka-server7001
改POM
1.X和2.X的对比说明
写YML
主启动
@EnableEurekaServer
测试
http://localhost:7001/
结果页面
No application available 没有服务被发现 O(∩_∩)O因为没有注册服务进来当然不可能有服务被发现
EurekaClient端cloud-provider-payment8001将注册进EurekaServer成为服务提供者provider，类似学校对外提供授课服务
子主题
@EnableEurekaClient
先要启动EurekaServer
微服务注册名配置说明
自我保护机制
EurekaClient端cloud-consumer-order8080将注册进EurekaServer成为服务消费者consumer，类似上课消费的各位同学
YML
先要启动EurekaServer，7001服务
再要启动服务提供者provider，8001服务
eureka服务器
bug
集群Eureka构建步骤
Eureka集群原理说明
Eureka集群注册原理
EurekaServer集群环境构建步骤
1、参考cloud-eureka-server7001
2、新建cloud-eureka-server7002
3、改 cloud-eureka-server7002 POM
4、修改映射配置
找到C:\\Windows\\System32\\drivers\\etc路径下的hosts文件
修改映射配置添加进hosts文件
5、写 Eureka YML(以前单机)
Eureka 7001 yml文件
Eureka 7002 yml文件
6、主启动
7、浏览器访问注册中心
http://eureka7001.com:7001/
http://localhost:7002/
http://eureka7002.com:7002/
将支付服务8001微服务发布到上面2台Eureka集群配置中
将订单服务8080微服务发布到上面2台Eureka集群配置中
测试01
①、先要启动EurekaServer，7001/7002服务
②、再要启动服务提供者provider，8001
③、再要启动消费者，8080
④、查看消费者和生产者是否注册成功
⑤、http://localhost:8080/consumer/payment/get/1
ok
支付服务提供者8001集群环境构建
参考cloud-provider-payment8001
新建cloud-provider-payment8002
业务类
直接从8001粘
修改8001/8002的Controller
8001
8002
①、bug
订单服务(cloud-consumer-order8080) OrderController类中 访问地址不能写死
②、bug
订单服务(cloud-consumer-order8080) ApplicationContextConfig中不添加@LoadBalanced报异常
③、使用@LoadBalanced注解赋予RestTemplate负载均衡的能力
订单服务(cloud-consumer-order8080) ApplicationContextConfig中修改
提前说一下Ribbon的负载均衡功能
测试02
先要启动EurekaServer，7001/7002服务
再要启动服务提供者provider，8001/8002服务
结果
负载均衡效果达到
8001/8002端口交替出现
Ribbon和Eureka整合后Consumer可以直接调用服务而不用再关心地址和端口号，且该服务还有负载功能了。O(∩_∩)O
actuator微服务信息完善
主机名称:服务名称修改
解决的问题：含有主机名
修改cloud-provider-payment8001
修改部分
完整内容
修改之前 localhost:cloud-payment-service:8001
修改之后 payment8001
访问信息有IP信息提示
解决的问题：没有IP提示
修改之前 http://localhost:8001/actuator/info
修改之后 http://172.:8001/actuator/info
服务发现Discovery
对于注册进eureka里面的微服务，可以通过服务发现来获得该服务的信息
修改cloud-provider-payment8001的Controller
8001主启动类
@EnableDiscoveryClient
自测
再启动8001主启动类，需要稍等一会儿
http://localhost:8001/payment/discovery
Eureka自我保护
故障现象
导致原因
一句话：某时刻某一个微服务不可用了，Eureka不会立刻清理，依旧会对该微服务的信息进行保存
属于CAP里面的AP分支
怎么禁止自我保护
注册中心eureakeServer端7001
出厂默认，自我保护机制是开启的
eureka.server.enable-self-preservation=true
使用eureka.server.enable-self-preservation = false 可以禁用自我保护模式
关闭效果
在eurekaServer端7001处设置关闭自我保护机制
生产者客户端eureakeClient端8001
默认
eureka.instance.lease-renewal-interval-in-seconds=30
单位为秒(默认是30秒)
eureka.instance.lease-expiration-duration-in-seconds=90
单位为秒(默认是90秒)
配置
7001和8001都配置完成
先启动7001再启动8001访问结果
先关闭8001
马上被删除了
6、Zookeeper服务注册与发现
Eureka停止更新了你怎么办
https://github.com/Netflix/eureka/wiki
SpringCloud整合Zookeeper代替Eureka
Zookeeper Windows下载安装步骤地址
Windows环境下安装zookeeper 可参考：
https://blog.csdn.net/qq_33316784/article/details/88563482
http://www.manongjc.com/detail/6-gnqmxbkcmeasqxq.html
Windows环境下安装与使用
第一步：安装包下载路径 https://download.csdn.net/download/weixin_44954939/19235391
第二步：解压到常用的安装目录
第三步：将conf目录下的zoo_sample.cfg文件，复制一份，重命名为zoo.cfg
第四步：修改zoo.cfg配置文件
在配置文件中新增dataDir=D:\\\\apache-zookeeper-3.6.3-bin\\\\datadataLogDir=D:\\\\apache-zookeeper-3.6.3-bin\\\\logs
第五步：新建文件夹，需要在安装目录下面新建一个空的data文件夹和logs文件夹
第六步：zookeeper启动和控制台窗口
zookeeper启动
控制台窗口
Windows环境下zookeeper常用命令操作：
https://blog.csdn.net/zhangphil/article/details/100010629
注册中心Zookeeper
zookeeper是一个分布式协调工具，可以实现注册中心功能
关闭Linux服务器防火墙后启动zookeeper服务器
zookeeper服务器取代Eureka服务器，zk作为服务注册中心
服务提供者
新建cloud-provider-payment8004
主启动类
Controller
启动8004注册进zookeeper
启动后问题：zookeeper版本jar包冲突问题
why
解决zookeeper版本jar包冲突问题
排出zk冲突后的新POM
验证测试1
http://localhost:8004/payment/zk
验证测试2
获得json串后用在线工具查看试试
linux环境下zookeeper
windows环境下zookeeper
思考
服务节点是临时节点还是持久节点
ls /services/cloud-provider-payment
服务消费者
新建cloud-consumerzk-order8080
配置Bean
验证测试
访问测试地址
http://localhost:8080/consumer/payment/zk
7、Consul服务注册与发现
Consul简介
https://www.consul.io/intro/index.html
能干嘛
服务发现
提供HTTP和DNS两种发现方式。
健康监测
支持多种方式，HTTP、TCP、Docker、Shell脚本定制化监控
KV存储
Key、Value的存储方式
多数据中心
Consul支持多数据中心
可视化Web界面
下载和安装
①、下载地址
https://www.consul.io/downloads.html
②、windows版下载后的文件（你可以选择任何系统）
③、配置环境变量
添加 计算机 右键 属性 高级属性设置环境变量设置在path下加上：D:\\consul_1.9.5_windows_amd64
④、启动
第一步：Consul 默认启动为 dev 模式
第二步：consul agent -dev
⑤、校验
输入网址：http://localhost:8500
怎么玩
https://www.springcloud.cc/spring-cloud-consul.html
安装并运行Consul
官网安装说明
https://learn.hashicorp.com/consul/getting-started/install.html
下载完成后只有一个consul.exe文件，硬盘路径下双击运行，查看版本号信息
consul -version
使用开发模式启动
consul agent -dev
通过以下地址可以访问Consul的首页：http://localhost:8500
新建Module支付服务provider8006
cloud-providerconsul-payment8006
业务类Controller
http://localhost:8006/payment/consul
http://localhost:8500/ui/dc1/services
新建Module消费服务order8080
cloud-consumerconsul-order8080
http://localhost:8080/consumer/payment/consul
三个注册中心异同点
CAP
C:Consistency（强一致性）
A:Availability（可用性）
P:Partition tolerance（分区容错性）
CAP理论关注粒度是数据，而不是整体系统设计的策略
经典CAP图
AP(Eureka)
CP(Zookeeper/Consul)
8、Ribbon负载均衡服务器调用
概述
官网资料
https://github.com/Netflix/ribbon/wiki/Getting-Started
Ribbon目前也进入维护模式
未来替换方案
能干吗
LB（负载均衡）
集中式LB
进程内LB
前面我们讲解过了8080通过轮询负载访问8001/8002
一句话
负载均衡+RestTemplate调用
Ribbon负载均衡演示
架构说明
总结：Ribbon其实就是一个软负载均衡的客户端组件，他可以和其他所需请求的客户端结合使用，和eureka结合只是其中的一个实例。
二说RestTemplate的使用
官网
https://docs.spring.io/spring-framework/docs/5.2.2.RELEASE/javadoc-api/org/springframework/web/client/RestTemplate.html
getForObject方法/getForEntity方法
案例代码
postForObject/postForEntity
GET请求方法
POST请求方法
Ribbon核心组件IRule
IRule：根据特定算法中从服务列表中选取一个要访问的服务
com.netflix.loadbalancer.RoundRobinRule
轮询 （ruang 的 ruai 本如）
com.netflix.loadbalancer.RandomRule
随机
com.netflix.loadbalancer.RetryRule
先按照RoundRobinRule的策略获取服务，如果获取服务失败则在指定时间内会进行重试，获取可用的服务
WeightedResponseTimeRule
对RoundRobinRule的扩展，响应速度越快的实例选择权重越大，越容易被选择
BestAvailableRule
会先过滤掉由于多次访问故障而处于断路器跳闸状态的服务，然后选择一个并发量最小的服务
AvailabilityFilteringRule
先过滤掉故障实例，再选择并发较小的实例
ZoneAvoidanceRule
如何替换
修改cloud-consumer-order80
注意配置细节
①
②
新建package
com.wtl.myrule
上面包下新建MySelfRule规则类
主启动类添加@RibbonClient
Ribbon负载均衡算法
原理
RoundRobinRule源码
手写
自己试着写一个本地负载均衡器试试
7001/7002集群启动
8001/8002微服务改造
8080订单微服务改造
①、ApplicationContextBean去掉注解@LoadBalanced
②、新建com.wtl.springcloud.lb
③、LoadBalancer接口
④、新建com.wtl.springcloud.lb.impl
⑤、LoadBalancerImpl
⑥、OrderController
⑦、测试
http://localhost:8080/consumer/payment/lb
9、OpenFeign服务接口调用
OpenFeign是什么
Feign是一个声明式的Web服务客户端，让编写Web服务客户端变得非常容易，只需创建一个接口并在接口上添加注解即可
GitHub
https://github.com/spring-cloud/spring-cloud-openfeign
Feign和OpenFeign两者区别
OpenFeign使用步骤
接口+注解
微服务调用接口+@FeignClient
新建cloud-consumer-feign-order8080
Feign在消费端使用
@EnableFeignClients
EnableFeignClients
新建PaymentFeignService接口并新增注解@FeignClient
@FeignClient
控制层Controller
先启动2个eureka集群7001/7002
再启动2个微服务8001/8002
启动OpenFeign启动：cloud-consumer-feign-order8080
http://localhost:8080/orderFeign/consumer/payment/get/1
Feign自带负载均衡配置项
小总结
OpenFeign超时控制
超时设置，故意设置超时演示出错情况
服务提供方8001故意写暂停程序 controller
服务消费方8080添加超时方法PaymentFeignService
服务消费方8080添加超时方法OrderFeignController
http://localhost:8080/orderFeign/consumer/payment/feign/timeout
错误页面
OpenFeign默认等待1秒钟，超过后报错
OpenFeign默认支持Ribbon
服务消费方8080、YML文件里需要开启OpenFeign客户端超时控制
OpenFeign日志打印功能
日志打印功能
日志级别
配置日志bean
YML文件里需要开启日志的Feign客户端
后台日志查看
10、Hystrix断路器
分布式系统面临的问题
服务熔断
接近实时的监控
。。。。。。
https://github.com/Netflix/Hystrix/wiki/How-To-Use
Hystrix官宣，停更进维
https://github.com/Netflix/Hystrix
被动修复bugs
Hystrix重要概念
服务降级 fallback
服务器忙，请稍后再试，不让客户端等待并立刻返回一个友好提示，fallback
哪些情况会出发降级
程序运行异常
超时
服务熔断触发服务降级
线程池/信号量打满也会导致服务降级
服务熔断 break
类比保险丝达到最大服务访问后，直接拒绝访问，拉闸限电，然后调用服务降级的方法并返回友好提示
就是保险丝
服务的降级->进而熔断->恢复调用链路
服务限流 flowlimit
秒杀高并发等操作，严禁一窝蜂的过来拥挤，大家排队，一秒钟N个，有序进行
Hystrix案例
构建
新建cloud-provider-hystrix-payment8001
service
正常测试
①、启动eureka7001
②、启动cloud-provider-hystrix-payment8001
③、访问
success的方法
http://localhost:8001/payment/hystrix/ok/1
每次调用耗费3秒钟
http://localhost:8001/payment/hystrix/timeout/1
上述module均OK
以上述为根基平台，从正确->错误->降级熔断->恢复
高并发测试
上述在非高并发情形下，还能勉强满足 but......
Jmeter安装和使用
Jmeter 下载路径
https://download.csdn.net/download/weixin_44954939/19763454
Jmeter 启动
D:\\apache-jmeter-5.1.1\\binjmeter.bat
Jmeter 使用
新建线程组
Jmeter压测测试
①、开启Jmeter，来20000个并发压死8001，20000个请求都去访问paymentInfo_TimeOut服务
1、新建线程组
2、线程组数据信息配置
②、再来一个访问
1、Jmeter 新建 HTTP请求
2、HTTP请求参数配置
③、浏览器再次访问 http://localhost:8001/payment/hystrix/ok/1
④、看演示结果
两个都在自己转圈圈
为什么会被卡死
Jmeter压测结论
上面还是服务提供者8001自己测试，假如此时外部的消费者8080也来访问，那消费者只能干等，最终导致消费端8080不满意，服务端8001直接被拖死
看热闹不嫌弃事大，8080新建加入
cloud-consumer-feign-hystrix-order8080
PaymentHystrixService
OrderHystirxController
http://localhost:8080/consumer/payment/hystrix/ok/1
2W个线程压8001
消费端8080微服务再去访问正常的Ok微服务8001地址
消费者8080，o(╥﹏╥)o
要么转圈圈等待
要么消费端报超时错误
故障现象和导致原因
8001同一层次的其它接口服务被困死，因为tomcat线程池里面的工作线程已经被挤占完毕
8080此时调用8001，客户端访问响应缓慢，转圈圈
上诉结论
正因为有上述故障或不佳表现才有我们的降级/容错/限流等技术诞生
如何解决？解决的要求
超时导致服务器变慢(转圈)
超时不再等待
出错(宕机或程序运行出错)
出错要有兜底
解决
对方服务(8001)超时了，调用者(8080)不能一直卡死等待，必须有服务降级
对方服务(8001)down机了，调用者(8080)不能一直卡死等待，必须有服务降级
降级配置
@HystrixCommand
8001先从自身找问题
设置自身调用超时时间的峰值，峰值内可以正常运行，超过了需要有兜底的方法处理，作服务降级fallback
8001fallback
业务类启用
@HystrixCommand报异常后如何处理
一旦调用服务方法失败并抛出了错误信息后，会自动调用@HystrixCommand标注好的fallbackMethod调用类中的指定方法
图示
主启动类激活
添加新注解@EnableCircuitBreaker
8080fallback
题外话，切记
我们自己配置过的热部署方式对java代码的改动明显，但对@HystrixCommand内属性的修改建议重启微服务
8001业务类启用 PaymentService
8080 YML
8080 主启动
@EnableHystrix
8080 业务类
Service
http://localhost:8080/consumer/payment/hystrix/timeout/1
目前问题
每个业务方法对应一个兜底的方法，代码膨胀
统一和自定义的分开
解决问题
每个方法配置一个？？？膨胀
feign接口系列
@DefaultProperties(defaultFallback = \"\")
说明
controller配置
Controller中使用
http://localhost:8080/consumer/payment/hystrix/exception/2
和业务逻辑混一起？？？混乱
服务降级，客户端去调用服务端，碰上服务端宕机或关闭
本次案例服务降级处理是在客户端80实现完成的，与服务端8001没有关系只需要为Feign客户端定义的接口添加一个服务降级处理的实现类即可实现解耦
未来我们要面对的异常
宕机
再看我们的业务类PaymentController
修改cloud-consumer-feign-hystrix-order8080
根据cloud-consumer-feign-hystrix-order8080已经有的PaymentHystrixService接口，重新新建一个类(PaymentFallbackService)实现该接口，统一为接口里面的方法进行异常处理
PaymentFallbackService类实现PaymentHystrixService接口
PaymentHystrixService接口
单个eureka先启动7001
PaymentHystrixMain8001启动
OrderHystrixMain8080 启动
正常访问测试
故意关闭微服务8001
客户端自己调用提示
此时服务端provider已经down了，但是我们做了服务降级处理，让客户端在服务端不可用时也会获得提示信息而不会挂起耗死服务器
断路器
一句话就是家里的保险丝
熔断是什么
大神论文
https://martinfowler.com/bliki/CircuitBreaker.html
实操
修改cloud-provider-hystrix-payment8001
PaymentService
why配置这些参数
PaymentController
自测cloud-provider-hystrix-payment8001
正确
http://localhost:8001/payment/circuit/1
错误
http://localhost:8001/payment/circuit/-1
一次正确一次错误 try try
重点测试
多次进行错误请求测试，直到正确的请求后也错误 测试成功，然后在进行多次的正确请求、直到正确请求成功...
原理(小总结)
大神结论
熔断类型
熔断打开
请求不再进行调用当前服务，内部设置时钟一般为MTTR（平均故障处理时间)，当打开时长达到所设时钟则进入半熔断状态
熔断关闭
熔断关闭不会对服务进行熔断
熔断半开
部分请求根据规则调用当前服务，如果请求成功且符合规则则认为当前服务恢复正常，关闭熔断
官网断路器流程图
官网步骤
断路器在什么情况下开始起作用
断路器开启或者关闭的条件
1、当满足一定的阀值的时候（默认10秒内超过20个请求次数）
2、当失败率达到一定的时候（默认10秒内超过50%的请求失败）
3、到达以上阀值，断路器将会开启
4、当开启的时候，所有请求都不会进行转发
5、一段时间之后（默认是5秒），这个时候断路器是半开状态，会让其中一个请求进行转发。如果成功，断路器会关闭，若失败，继续开启。重复第4 和 第5步
断路器打开之后
All配置
服务限流
后面高级篇讲解alibaba的Sentinel说明
Hystrix工作流程
https://github.com/Netflix/Hystrix/wiki/How-it-Works
官网图例
蓝色：调用路径
红色：返回路径
完整的请求路线：
1、选择一个Hystrix注册方式
2、二选一即可
3、判断缓存中是否包含需要返回的内容（如果有直接返回）
4、断路器是否为打开状态（如果是，直接跳转到8，返回）
5、断路器为健康状态，判断是否有可用资源（没有，直接跳转8）
6、构造方法和Run方法
7、将正常，超时，异常的消息发送给断路器
8、调用getFallback方法，也就是服务降级
9、直接返回正确结果
步骤说明
服务监控HystrixDashboard
仪表盘9001
新建cloud-consumer-hystrix-dashboard9001
HystrixDashboardMain9001+新注解@EnableHystrixDashboard
所有Provider微服务提供类(8001/8002/8003)都需要监控依赖配置
启动cloud-consumer-hystrix-dashboard9001该微服务后续将监控微服务8001
http://localhost:9001/hystrix
断路器演示(服务监控hystrixDashboard)
1、pom.xml中一定要有这两个依赖
2、注意:新版本Hystrix需要在主启动类 MainAppHystrix8001中指定监控路径
3、Unable to connect to Command Metric Stream.
4、404
监控测试
启动1个eureka或者3个eureka集群均可
观察监控窗口
9001监控8001
填写监控地址
http://localhost:8001/hystrix.stream
测试地址
上述测试通过
先访问正确地址，再访问错误地址，再正确地址，会发现图示断路器都是慢慢放开的。
监控结果，成功
监控结果，失败
如何看？
7色
1圈
1线
整图说明
如图所示:
整图说明2
搞懂一个才能看懂复杂的
11、Zuul路由网关
概述简介
https://github.com/Netflix/zuul/wiki/Getting-Started
https://cloud.spring.io/spring-cloud-static/spring-cloud-netflix/2.2.1.RELEASE/reference/html/#router-and-filter-zuul
路由
过滤
灰度发布
又称金丝雀发布
路由基本配置
功能
路由功能负责将外部请求转发到具体的服务实例上去，是实现统一访问入口的基础
新建Module模块cloud-zuul-gateway9527
hosts修改
127.0.0.1 myzuul.com
@EnableZuulProxy
启动
三个eureka集群
一个服务提供类microservicecloud-provider-dept-8001
一个路由
不用路由
http://localhost:8001/paymentInfo
启用路由
zuul映射配置+注册中心注册后对外暴露的服务名称+rest调用地址
http://myzuul.com:9527/cloud-provider-payment/paymentInfo
路由访问映射规则
工程microservicecloud-zuul-gateway-9527
代理名称
此时问题
路由访问OK
http://myzuul.com:9527/weixin/paymentInfo
原路径访问OK
如果不想使用默认的路由规则，可以添加以下配置来忽略默认路由配置
原有真实服务名忽略
上一步配置后，cloud-provider-payment就不行了
单个具体，多个可以用\"*\"
路由转发和负载均衡功能
服务提供者SMS短信模块
建模块cloud-provider-sms8008
启动8008并成功注册进eureka服务器上
修改我们的zuul服务9527
修改YML，体现路由转发和负载均衡
由于Zuul自动集成了Ribbon和Hystrix，所以Zuul天生就有负载均衡和服务容错能力
http://myzuul.com:9527/mysms/sms
路由转发
微信服务找8001/8002
短信服务找8008
设置统一公共前缀
http://myzuul.com:9527/atguigu/weixin/paymentInfo
http://myzuul.com:9527/atguigu/mysms/sms
http://myzuul.com:9527/atguigu/cloud-provider-payment/paymentInfo
最后YML
查看路由信息
查看路由详细信息
http://localhost:9527/actuator/routes
过滤器
过滤功能负责对请求过程进行额外的处理，是请求校验过滤及服务聚合的基础。
过滤器的生命周期
ZuulFilter
过滤类型
pre：在请求被路由到目标服务前执行，比如权限校验、打印日志等功能；
routing：在请求被路由到目标服务时执行
post：在请求被路由到目标服务后执行，比如给目标服务的响应添加头信息，收集统计数据等功能；
error：请求在其他阶段发生错误时执行。
过滤顺序
数字小的先执行
过滤是否开启
shouldFilter方法为true走
执行逻辑
自己的业务逻辑
案例Case
前置过滤器，用于在请求路由到目标服务前打印请求日志
业务代码
在调用8008之前会打印日志
开关，YML配置
12、Gateway新一代网关
上一代zuul 1.X
https://github.com/Netflix/zuul/wiki
当前gateway
https://cloud.spring.io/spring-cloud-static/spring-cloud-gateway/2.2.1.RELEASE/reference/html/
一句话：
SpringCloud Gateway 使用的Webflux中的reactor-netty响应式编程组件，底层使用了Netty通讯框架。
源码架构
反向代理
鉴权
流量控制
熔断
日志监控
微服务架构中网关在哪里
有Zuul了怎么又出来了gateway
我们为什么选择Gateway？
1、neflix不太靠谱，zuul2.0一直跳票，迟迟不发布
2、SpringCloud Gateway具有如下特性
如图所示
3、SpringCloud Gateway 与 Zuul的区别
Zuul1.x模型
GateWay模型
WebFlux是什么
https://docs.spring.io/spring/docs/current/spring-framework-reference/web-reactive.html#webflux-new-framework
三大核心概念
Route(路由)
路由是构建网关的基本模块，它由ID，目标URI，一系列的断言和过滤器组成，如果断言为true则匹配该路由
Predicate(断言)
参考的是Java8的java.util.function.Predicate开发人员可以匹配HTTP请求中的所有内容(例如请求头或请求参数)，如果请求与断言相匹配则进行路由
Filter(过滤)
指的是Spring框架中GatewayFilter的实例，使用过滤器，可以在请求被路由前或者之后对请求进行修改。
总体
Gateway工作流程
官网总结
核心逻辑
路由转发+执行过滤器链
入门配置
新建Module
cloud-gateway-gateway9527
无
9527网关如何做路由映射那？？？
cloud-provider-payment8001看看controller的访问地址
get
lb
我们目前不想暴露8001端口，希望在8001外面套一层9527
YML新增网关配置
启动7001
启动8001
启动9527网关
访问说明
添加网关前
http://localhost:8001/payment/lb
添加网关后
http://localhost:9527/payment/get/1
http://localhost:9527/payment/lb
YML配置说明
Gateway网关路由有两种配置方式：
在配置文件yml中配置
见前面的步骤
代码中注入RouteLocator的Bean
官网案例
如图实例
百度国内新闻网址，需要外网
http://news.baidu.com/guonei
自己写一个
百度新闻
业务需求
通过9527网关访问到外网的百度新闻网址
编码
业务实现
config
http://localhost:9527/
通过微服务名实现动态路由
默认情况下Gateway会根据注册中心注册的服务列表，以注册中心上微服务名为路径创建动态路由进行转发，从而实现动态路由的功能
启动：
一个eureka7001 + 两个服务提供者8001/8002
需要注意的是uri的协议为lb，表示启用Gateway的负载均衡功能。
lb://serviceName是spring cloud gateway在微服务中自动为我们创建的负载均衡uri
8001/8002两个端口切换
Predicate的使用
启动我们的gateway9527
Route Predicate Factories这个是什么东东?
常用的Route Predicate
①、After Route Predicate
②、Before Route Predicate
③、Between Route Predicate
④、Cookie Route Predicate
不带cookies访问
curl http://localhost:9527/payment/lb
带上cookies访问
curl http://localhost:9527/payment/lb --cookie \"username=wtl\"
加入curl返回中文乱码 :Windows下安装使用Curl及解决中文乱码问题
⑤、Header Route Predicate
curl http://localhost:9527/payment/lb -H \"X-Request-Id:123\"
⑥、Host Route Predicate
curl http://localhost:9527/payment/lb -H \"Host:www.wtl.com\"
⑦、Method Route Predicate
curl http://localhost:9527/payment/lb -GET
⑧、Path Route Predicate
⑨、Query Route Predicate
http://localhost:9527/payment/lb?username=123
⑩、小总结
All
说白了，Predicate就是为了实现一组匹配规则，让请求过来找到对应的Route进行处理。
Filter的使用
Spring Cloud Gateway的Filter
生命周期，Only Two ：业务逻辑之前和业务逻辑之后
业务逻辑之前 pre
业务逻辑之后 post
种类，Only Two
单一的 GatewayFilter，31种之多
https://cloud.spring.io/spring-cloud-static/spring-cloud-gateway/2.2.1.RELEASE/reference/html/#gatewayfilter-factories
全局的 GlobalFilter，10种之多
https://cloud.spring.io/spring-cloud-static/spring-cloud-gateway/2.2.1.RELEASE/reference/html/#global-filters
常用的GatewayFilter
AddRequestParameter
省略
自定义过滤器
自定义全局GlobalFilter
两个主要接口介绍
implements font color=\"#d32f2f\
全局日志记录
统一网关鉴权
http://localhost:9527/payment/lb?uname=张三
没有参数uname
无法正常使用转发
13、SpringCloud Config 分布式配置中心
分布式系统面临的---配置问题
集中管理配置文件
不同环境不同配置，动态化的配置更新，分环境部署比如dev/test/prod/beta/release
运行期间动态调整配置，不再需要在每个服务部署的机器上编写配置文件，服务会向配置中心统一拉取配置自己的信息
当配置发生变动时，服务不需要重启即可感知到配置的变化并应用新的配置
将配置信息以REST接口的形式暴露
post、curl访问刷新均可......
与GitHub整合配置
https://cloud.spring.io/spring-cloud-static/spring-cloud-config/2.2.1.RELEASE/reference/html/
Config服务端配置 3344 与测试
用你自己的账号在GitHub上新建一个名为springcloud-config的新Repository（温馨提示:这里我用的gitee）
如图所示 https://gitee.com/wtl0616/springcloud-config
由上一步获得刚新建的git地址
git clone https://gitee.com/wtl0616/springcloud-config.git
本地硬盘目录上新建git仓库并clone
本地地址：E:\\cloud2021\\springcloud-config
git命令
此时在本地E盘符下E:\\cloud2021\\springCloud-config
表示多个环境的配置文件
保存格式必须为UTF-8
如果需要修改，此处模拟运维人员操作git和github
git add .
git commit -m \"init yml\"
git push origin master
E:\\cloud2021\\springcloud-config
新建Module模块 : cloud-config-center-3344它即为Cloud的配置中心模块cloudConfig Center
ConfigCenterMain3344
@EnableConfigServer
windows下修改hosts文件，增加映射
C:\\Windows\\System32\\drivers\\etc
127.0.0.1 config-3344.com
测试 : 通过Config微服务是否可以从GitHub上获取配置内容
启动注册中心：cloud-eureka-server7001
启动微服务：cloud-config-center-3344
http://config-3344.com:3344/master/config-dev.yml
配置读取规则
/{label}/{application}-{profile}.yml
master分支
http://config-3344.com:3344/master/config-test.yml
http://config-3344.com:3344/master/config-prod.yml
dev分支
http://config-3344.com:3344/dev/config-dev.yml
http://config-3344.com:3344/dev/config-test.yml
http://config-3344.com:3344/dev/config-prod.yml
/{application}-{profile}.yml
http://config-3344.com:3344/config-dev.yml
http://config-3344.com:3344/config-test.yml
http://config-3344.com:3344/config-prod.yml
http://config-3344.com:3344/config-xxxx.yml(不存在的配置)
/{application}/{profile}[/{label}]
http://config-3344.com:3344/config/dev/master
http://config-3344.com:3344/config/test/master
http://config-3344.com:3344/config/test/dev
重要配置细节总结
成功实现了用SpringCloud Config通过GitHub获取配置信息
Config客户端配置 3355 与测试
新建cloud-config-client-3355
bootstrap.yml
内容
修改config-dev.yml配置并提交到GitHub中，比如加个变量age或者版本号version
类ConfigClientMain3355
启动Config配置中心3344微服务并自测
启动3355作为Client准备访问
http://localhost:3355/configInfo
成功实现了客户端3355访问SpringCloud Config3344通过GitHub获取配置信息
问题随时而来，分布式配置的动态刷新问题
Linux运维修改GitHub上的配置文件内容做调整
刷新3344，发现ConfigServer配置中心立刻响应
刷新3355，发现ConfigClient客户端没有任何响应
3355没有变化除非自己重启或者重新加载
难到每次运维修改配置文件，客户端都需要重启？？噩梦
Config客户端之动态刷新
避免每次更新配置都要重启客户端微服务3355
动态刷新
步骤
修改3355模块
POM引入actuator监控
修改YML，暴露监控端口
@RefreshScope业务类Controller修改
此时修改github---> 3344 ---->3355
3355改变没有？？？
没有，/(ㄒoㄒ)/~~
How
需要运维人员发送Post请求刷新3355
必须是POST请求
curl -X POST \"http://localhost:3355/actuator/refresh\"
再次
OK，O(∩_∩)O
成功实现了客户端3355刷新到最新配置内容
避免了服务重启
想想还有什么问题？
假如有多个微服务客户端3355/3366/3377。。。。。。
每个微服务都要执行一次post请求，手动刷新？
可否广播，一次通知，处处生效？
我们想大范围的自动刷新，求方法
Config本地模拟真实项目配置
Config服务端配置 3344 本地项目
application.yml
项目结构
sm-config-dev.yml
http://localhost:3344/master/sm-config-dev.yml
Config客户端配置 3355 本地项目
此时修改3344 ---->3355
重启3344
14、SpringCloud Bus 消息总线
上一讲解的加深和扩充，一言以蔽之
分布式自动刷新配置功能
Spring Cloud Bus 配合 Spring Cloud Config 使用可以实现配置的动态刷新。
Bus支持两种消息代理：RabbitMQ 和 Kafka
为何被称为总线
RabbitMQ环境配置
安装Erlang，下载地址：
http://erlang.org/download/otp_win64_21.3.exe
小编博客免费下载地址：
https://download.csdn.net/download/weixin_44954939/19869656
直接下一步就可以
安装RabbitMQ，下载地址：
https://github.com/rabbitmq/rabbitmq-server/releases/download/v3.7.9-rc.3/rabbitmq-server-3.7.9-rc.3.exe
官网地址 http://www.rabbitmq.com/install-windows.html
https://download.csdn.net/download/weixin_44954939/19869640
环境配置也可参考
https://developers.blog.csdn.net/article/details/100892294
Erlang 环境变量配置
安装目录
新建 ERLANG_HOME
ERLANG_HOME
配置 path
%ERLANG_HOME%\\bin
RabbitMQ 环境变量配置
新建 RABBITMQ_SERVER
RABBITMQ_SERVER
%RABBITMQ_SERVER%\\sbin
验证环境配置完成
快捷键 Win + R 输入 cmd 打开命令行窗口输入 rabbitmq-service 验证环境配置完成
启动 RabbitMQ 输入以下命令启动管理功能
D:\abbitmq-server-3.7.9-rc\abbitmq_server-3.7.9-rc.3\\sbin
cmd
rabbitmq-plugins enable rabbitmq_management
测试 RabbitMQ 可视化插件 访问地址查看
http://localhost:15672/
输入账号密码并登录：guest guest
SpringCloud Bus动态刷新全局广播
必须先具备良好的RabbitMQ环境先
演示广播效果，增加复杂度，再以3355为模板再制作一个3366
新建 cloud-config-client-3366
设计思想
2）利用消息总线触发一个服务端ConfigServer的/bus/refresh端点，而刷新所有客户端的配置
图二的架构显然更加适合，图一不适合的原因如下
打破了微服务的职责单一性，因为微服务本身是业务模块，它本不应该承担配置刷新的职责。
破坏了微服务各节点的对等性。
有一定的局限性。例如，微服务在迁移时，它的网络地址常常会发生变化，此时如果想要做到自动刷新，那就会增加更多的修改
给cloud-config-center-3344配置中心服务端添加消息总线支持
给cloud-config-client-3355客户端添加消息总线支持
给cloud-config-client-3366客户端添加消息总线支持
运维工程师
修改Github上配置文件增加版本号
发送POST请求
curl -X POST \"http://localhost:3344/actuator/bus-refresh\"
一次发送，处处生效
配置中心
客户端
http://localhost:3366/configInfo
获取配置信息，发现都已经刷新了
一次修改，广播通知，处处生效
O(∩_∩)O
SpringCloud Bus动态刷新定点通知
不想全部通知，只想定点通知
只通知3355
不通知3366
简单一句话
指定具体某一个实例生效而不是全部
公式：http://localhost:配置中心的端口号/actuator/bus-refresh/{destination}
destination:服务名称+端口号
/bus/refresh请求不再发送到具体的服务实例上，而是发给config server并通过destination参数类指定需要更新配置的服务或实例
案例
我们这里以刷新运行在3355端口上的config-client为例
curl -X POST \"http://localhost:3344/actuator/bus-refresh/config-client:3355\"
通知总结All
15、SpringCloud Stream 消息驱动
消息驱动概述
https://spring.io/projects/spring-cloud-stream#overview
https://cloud.spring.io/spring-cloud-static/spring-cloud-stream/3.0.1.RELEASE/reference/html/
Spring Cloud Stream中文指导手册
https://m.wang1314.com/doc/webapp/topic/20971999.html
标准MQ
生产者/消费者之间靠消息媒介传递信息内容
Message
消息必须走特定的通道
消息通道MessageChannel
消息通道里的消息如何被消费呢，谁负责收发处理
消息通道MessageChannel的子接口SubscribableChannel，由MessageHandler消息处理器所订阅
为什么用Cloud Stream
stream凭什么可以统一底层差异？
Binder
INPUT对应于消费者
OUTPUT对应于生产者
Stream中的消息通信方式遵循了发布-订阅模式
Topic主题进行广播
在RabbitMQ就是Exchange
在Kakfa中就是Topic
Spring Cloud Stream标准流程套路
很方便的连接中间件，屏蔽差异
Channel
通道，是队列Queue的一种抽象，在消息通讯系统中就是实现存储和转发的媒介，通过Channel对队列进行配置
Source和Sink
简单的可理解为参照对象是Spring Cloud Stream自身，从Stream发布消息就是输出，接受消息就是输入。
编码API和常用注解
案例说明
RabbitMQ环境已经OK
工程中新建三个子模块
cloud-stream-rabbitmq-provider8801， 作为生产者进行发消息模块
cloud-stream-rabbitmq-consumer8802，作为消息接收模块
cloud-stream-rabbitmq-consumer8803 作为消息接收模块
消息驱动之生产者
新建Module : cloud-stream-rabbitmq-provider8801
主启动类StreamMQMain8801
发送消息接口
发送消息接口实现类
启动7001eureka
启动rabbitmq
启动8801
访问
http://localhost:8801/sendMessage
消息驱动之消费者
新建Module : cloud-stream-rabbitmq-consumer8802
主启动类StreamMQMain8802
测试8801发送8802接收消息
分组消费与持久化
依照8802，clone出来一份运行8803
cloud-stream-rabbitmq-consumer8803
RabbitMQ
7001
服务注册
8801
消息生产
8802
消息消费
8803
运行后有两个问题
有重复消费问题
消息持久化问题
消费
目前是8802/8803同时都收到了，存在重复消费问题
如何解决
分组和持久化属性group
重要
生产实际案例
分组
微服务应用放置于同一个group中，就能够保证消息只会被其中一个应用消费一次。不同的组是可以消费的，同一个组内会发生竞争关系，只有其中一个可以消费。
8802/8803都变成不同组，group两个不同
group: atguiguA、atguiguB
8802修改YML
8803修改YML
我们自己配置
结论
还是重复消费
8802/8803实现了轮询分组，每次只有一个消费者8801模块的发的消息只能被8802或8803其中一个接收到，这样避免了重复消费。
8802/8803都变成相同组，group两个相同
group: atguiguA
同一个组的多个微服务实例，每次只会有一个拿到
持久化
通过上述，解决了重复消费问题，再看看持久化
停止8802/8803并去除掉8802的分组group: atguiguA
8803的分组group: atguiguA没有去掉
8801先发送4条消息到rabbitmq
先启动8802，无分组属性配置，后台没有打出来消息
再启动8803，有分组属性配置，后台打出来了MQ上的消息
16、SpringCloud Sleuth 分布式请求链路跟踪
为什么会出现这个技术？需要解决哪些问题？
问题
https://github.com/spring-cloud/spring-cloud-sleuth
Spring Cloud Sleuth提供了一套完整的服务跟踪的解决方案
在分布式系统中提供追踪解决方案并且兼容支持了zipkin
搭建链路监控步骤
1、zipkin
下载
SpringCloud从F版起已不需要自己构建Zipkin Server了，只需调用jar包即可
https://dl.bintray.com/openzipkin/maven/io/zipkin/java/zipkin-server/
zipkin-server-2.12.9-exec.jar
运行jar
运行控制台
http://localhost:9411/zipkin/
术语
完整的调用链路
上图what
名词解释
Trace:类似于树结构的Span集合，表示一条调用链路，存在唯一标识
span:表示调用链路来源，通俗的理解span就是一次请求信息
2、服务提供者
业务类PaymentController
3、服务消费者(调用方)
cloud-consumer-order80
业务类OrderController
4、依次启动eureka7001/8001/80
80调用8001几次测试下
5、打开浏览器访问：http://localhost:9411
会出现以下界面
查看
查看依赖关系
17、SpringCloud Alibaba 入门简介
why会出现SpringCloud alibaba
Spring Cloud Netflix项目进入维护模式
https://spring.io/blog/2018/12/12/spring-cloud-greenwich-rc1-available-now
Spring Cloud Netflix Projects Entering Maintenance Mode
什么是维护模式
进入维护模式意味着什么呢？
SpringCloud alibaba带来了什么
去哪下
https://github.com/alibaba/spring-cloud-alibaba/blob/master/README-zh.md
SpringCloud alibaba学习资料获取
https://spring.io/projects/spring-cloud-alibaba#overview
英文
https://github.com/alibaba/spring-cloud-alibaba
https://spring-cloud-alibaba-group.github.io/github-pages/greenwich/spring-cloud-alibaba.html
中文
18、SpringCloud Alibaba Nacos服务注册和配置中心
Nacos简介
为什么叫Nacos
前四个字母分别为Naming和Configuration的前两个字母，最后的s为Service。
一个更易于构建云原生应用的动态服务发现、配置管理和服务管理平台。
Nacos: Dynamic Naming and Configuration Service
Nacos就是注册中心 + 配置中心的组合
等价于
Nacos = Eureka+Config +Bus
替代Eureka做服务注册中心
替代Config做服务配置中心
https://github.com/alibaba/Nacos
官网文档
https://nacos.io/zh-cn/index.html
https://spring-cloud-alibaba-group.github.io/github-pages/greenwich/spring-cloud-alibaba.html#_spring_cloud_alibaba_nacos_discovery
各种注册中心比较
安装并运行Nacos
本地Java8+Maven环境已经OK
先从官网下载Nacos
https://github.com/alibaba/nacos/releases
解压安装包，直接运行bin目录下的startup.cmd
命令运行成功后直接访问http://localhost:8848/nacos
默认账号密码都是nacos
Nacos作为服务注册中心演示
https://spring-cloud-alibaba-group.github.io/github-pages/greenwich/spring-cloud-alibaba.html#_spring_cloud_alibaba_nacos_config
基于Nacos的服务提供者
新建Module : cloudalibaba-provider-payment9001
父POM
本模块POM
http://localhost:9001/payment/nacos/1
nacos控制台
nacos服务注册中心+服务提供者9001都OK了
为了下一章节演示nacos的负载均衡，参照9001新建9002
新建cloudalibaba-provider-payment9002
9002其它步骤你懂的
或者取巧不想新建重复体力劳动，直接拷贝虚拟端口映射
基于Nacos的服务消费者
新建Module : cloudalibaba-consumer-nacos-order83
为什么nacos支持负载均衡
ApplicationContextBean
OrderNacosController
http://localhost:83/consumer/payment/nacos/13
83访问9001/9002，轮询负载OK
服务注册中心对比
各种注册中心对比
Nacos全景图所示
Nacos和CAP
切换
Nacos 支持AP和CP模式的切换
Nacos作为服务配置中心演示
Nacos作为配置中心-基础配置
cloudalibaba-config-nacos-client3377
why配置两个
bootstrap
application
ConfigClientController
@RefreshScope
在Nacos中添加配置信息
Nacos中的匹配规则
理论
Nacos中的dataid的组成格式及与SpringBoot配置文件中的匹配规则
配置新增
Nacos界面配置对应
设置DataId
公式：
${spring.application.name}-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
prefix 默认为 spring.application.name 的值
spring.profile.active 即为当前环境对应的 profile，可以通过配置项 spring.profile.active 来配置。
file-exetension 为配置内容的数据格式，可以通过配置项 spring.cloud.nacos.config.file-extension 来配置
小总结说明
历史配置
Nacos会记录配置文件的历史版本默认保留30天，此外还有一键回滚功能，回滚操作将会触发配置更新
回滚
启动前需要在nacos客户端-配置管理-配置管理栏目下有对应的yaml配置文件
运行cloud-config-nacos-client3377的主启动类
调用接口查看配置信息
http://localhost:3377/config/info
自带动态刷新
修改下Nacos中的yaml配置文件，再次调用查看配置的接口，就会发现配置已经刷新
Nacos作为配置中心-分类配置
多环境多项目管理
Nacos的图形化管理界面
配置管理
命名空间
Namespace+Group+Data ID三者关系？为什么这么设计？
Case
三种方案加载配置
DataID方案
指定spring.profile.active和配置文件的DataID来使不同环境下读取不同的配置
默认空间+默认分组+新建dev和test两个DataID
新建dev配置DataID
新建test配置DataID
通过spring.profile.active属性就能进行多环境下配置文件的读取
配置是什么就加载什么
test
Group方案
通过Group实现环境区分
新建Group
在nacos图形界面控制台上面新建配置文件DataID
bootstrap+application
在config下增加一条group的配置即可。可配置为DEV_GROUP或TEST_GROUP
Namespace方案
新建dev/test的Namespace
回到服务管理-服务列表查看
按照域名配置填写
Nacos集群和持久化配置（重要）
官网说明
https://nacos.io/zh-cn/docs/cluster-mode-quick-start.html
官网架构图(写的o(╥﹏╥)o)
上图官网翻译，真实情况
按照上述，我们需要mysql数据库
https://nacos.io/zh-cn/docs/deployment.html
重点说明
Nacos持久化配置解释
Nacos默认自带的是嵌入式数据库derby
https://github.com/alibaba/nacos/blob/develop/config/pom.xml
derby到mysql切换配置步骤
nacos-server-1.1.4\acos\\conf目录下找到sql脚本
nacos-mysql.sql
执行脚本
nacos-server-1.1.4\acos\\conf目录下找到application.properties
启动Nacos，可以看到是个全新的空记录界面，以前是记录进derby
Linux版Nacos+MySQL生产环境配置
预计需要，1个Nginx+3个nacos注册中心+1个mysql
Nacos下载Linux版
https://github.com/alibaba/nacos/releases/tag/1.1.4
nacos-server-1.1.4.tar.gz
解压后安装
集群配置步骤(重点)
1、Linux服务器上mysql数据库配置
SQL脚本在哪里
sql语句源文件
自己Linux机器上的Mysql数据库粘贴
执行后结果
2、application.properties 配置
位置
3、Linux服务器上nacos的集群配置cluster.conf
梳理出3台nacos集器的不同服务端口号
复制出cluster.conf
这个IP不能写127.0.0.1，必须是Linux命令hostname -i能够识别的IP
4、编辑Nacos的启动脚本startup.sh，使它能够接受不同的启动端口
/mynacos/nacos/bin 目录下有startup.sh
在什么地方，修改什么，怎么修改
修改内容
执行方式
5、Nginx的配置，由它作为负载均衡器
修改nginx的配置文件
nginx.conf
按照指定启动
6、截止到此处，1个Nginx+3个nacos注册中心+1个mysql
测试通过nginx访问nacos
http://192.168.111.144:1111/nacos/#/login
新建一个配置测试
linux服务器的mysql插入一条记录
微服务cloudalibaba-provider-payment9002启动注册进nacos集群
yml
高可用小总结
19、SpringCloud Alibaba Sentinel实现熔断与限流
Sentinel
https://github.com/alibaba/Sentinel
https://github.com/alibaba/Sentinel/wiki/%E4%BB%8B%E7%BB%8D
一句话解释，之前我们讲解过的Hystrix
https://github.com/alibaba/Sentinel/releases
https://spring-cloud-alibaba-group.github.io/github-pages/greenwich/spring-cloud-alibaba.html#_spring_cloud_alibaba_sentinel
服务使用中的各种问题
服务雪崩
安装Sentinel控制台
sentinel组件由2部分构成
后台
前台8080
安装步骤
下载到本地sentinel-dashboard-1.7.0.jar
运行命令
前提
java8环境OK
8080端口不能被占用
命令
java -jar sentinel-dashboard-1.7.0.jar
访问sentinel管理界面
http://localhost:8080
登录账号密码均为sentinel
初始化演示工程
启动Nacos8848成功
http://localhost:8848/nacos/#/login
Module
cloudalibaba-sentinel-service8401
业务类FlowLimitController
启动Sentinel8080
启动微服务8401
启动8401微服务后查看sentienl控制台
空空如也，啥都没有
Sentinel采用的懒加载说明
执行一次访问即可
http://localhost:8401/testA
http://localhost:8401/testB
效果
sentinel8080正在监控微服务8401
流控规则
基本介绍
进一步解释说明
流控模式
直接(默认)
直接->快速失败
系统默认
配置及说明
快速点击访问http://localhost:8401/testA
Blocked by Sentinel (flow limiting)
思考???
类似有个fallback的兜底方法？
关联
当关联的资源达到阈值时，就限流自己
当与A关联的资源B达到阀值后，就限流A自己
B惹事，A挂了
配置A
postman模拟并发密集访问testB
访问testB成功
postman里新建多线程集合组
将访问地址添加进新新线程组
Run
大批量线程高并发访问B，导致A失效了
运行后发现testA挂了
点击访问http://localhost:8401/testA
链路
多个请求调用了同一个微服务
家庭作业试试
流控效果
直接->快速失败(默认的流控处理)
直接失败，抛出异常
源码
com.alibaba.csp.sentinel.slots.block.flow.controller.DefaultController
预热
默认coldFactor为3，即请求 QPS 从 threshold / 3 开始，经预热时长逐渐升至设定的 QPS 阈值。
限流 冷启动
https://github.com/alibaba/Sentinel/wiki/%E9%99%90%E6%B5%81---%E5%86%B7%E5%90%AF%E5%8A%A8
com.alibaba.csp.sentinel.slots.block.flow.controller.WarmUpController
WarmUp配置
多次点击http://localhost:8401/testB
刚开始不行，后续慢慢OK
应用场景
排队等待
匀速排队，阈值必须设置为QPS
https://github.com/alibaba/Sentinel/wiki/%E6%B5%81%E9%87%8F%E6%8E%A7%E5%88%B6
com.alibaba.csp.sentinel.slots.block.flow.controller.RateLimiterController
降级规则
https://github.com/alibaba/Sentinel/wiki/%E7%86%94%E6%96%AD%E9%99%8D%E7%BA%A7
进一步说明
Sentinel的断路器是没有半开状态的
半开的状态系统自动去检测是否请求有异常，没有异常就关闭断路器恢复使用，有异常则继续打开断路器不可用。具体可以参考Hystrix
复习Hystrix
降级策略实战
RT
代码
jmeter压测
异常比例
jmeter
异常数
异常数是按照分钟统计的
热点key限流
https://github.com/alibaba/Sentinel/wiki/%E7%83%AD%E7%82%B9%E5%8F%82%E6%95%B0%E9%99%90%E6%B5%81
承上启下复习start
@SentinelResource
com.alibaba.csp.sentinel.slots.block.BlockException
1
@SentinelResource(value = \"testHotKey\")
异常打到了前台用户界面看到，不友好
2
@SentinelResource(value = \"testHotKey\
方法testHotKey里面第一个参数只要QPS超过每秒1次，马上降级处理
用了我们自己定义的
error
http://localhost:8401/testHotKey?p1=abc
http://localhost:8401/testHotKey?p1=abc&p2=33
right
http://localhost:8401/testHotKey?p2=abc
参数例外项
上述案例演示了第一个参数p1，当QPS超过1秒1次点击后马上被限流
特例情况
普通
超过1秒钟一个后，达到阈值1后马上被限流
我们期望p1参数当它是某个特殊值时，它的限流值和平时不一样
特例
假如当p1的值等于5时，它的阈值可以达到200
添加按钮不能忘
http://localhost:8401/testHotKey?p1=5
http://localhost:8401/testHotKey?p1=3
当p1等于5的时候，阈值变为200
当p1不等于5的时候，阈值就是平常的1
前提条件
热点参数的注意点，参数必须是基本类型或者String
其它
手贱添加异常看看....../(ㄒoㄒ)/~~
后面讲
系统规则
https://github.com/alibaba/Sentinel/wiki/%E7%B3%BB%E7%BB%9F%E8%87%AA%E9%80%82%E5%BA%94%E9%99%90%E6%B5%81
各项配置参数说明
配置全局QPS
按资源名称限流+后续处理
启动Nacos成功
启动Sentinel成功
业务类RateLimitController
配置流控规则
配置步骤
图形配置和代码关系
表示1秒钟内查询次数大于1，就跑到我们自定义的处流，限流
1秒钟点击1下，OK
超过上述，疯狂点击，返回了自己定义的限流处理信息，限流发生
额外问题
此时关闭问服务8401看看
Sentinel控制台，流控规则消失了？？？？？
临时/持久？
按照Url地址限流+后续处理
通过访问的URL来限流，会返回Sentinel自带默认的限流处理信息
访问一次
http://localhost:8401/rateLimit/byUrl
Sentinel控制台配置
疯狂点击http://localhost:8401/rateLimit/byUrl
上面兜底方案面临的问题
客户自定义限流处理逻辑
创建CustomerBlockHandler类用于自定义限流处理逻辑
自定义限流处理类
CustomerBlockHandler
RateLimitController
启动微服务后先调用一次
http://localhost:8401/rateLimit/customerBlockHandler
测试后我们自定义的出来了
更多注解属性说明
多说一句
Sentinel主要有三个核心Api
SphU定义资源
Tracer定义统计
ContextUtil定义了上下文
服务熔断功能
sentinel整合ribbon+openFeign+fallback
Ribbon系列
启动nacos和sentinel
提供者9003/9004
记得修改不同的端口号
http://localhost:9003/paymentSQL/1
消费者84
新建cloudalibaba-consumer-nacos-order84
CircleBreakerController
修改后请重启微服务
热部署对java代码级生效及时
对@SentinelResource注解内属性，有时效果不好
目的
fallback管运行异常
blockHandler管配置违规
http://localhost:84/consumer/fallback/1
没有任何配置
给客户error页面，不友好
只配置fallback
图说
本例sentinel无配置
只配置blockHandler
本例sentinel需配置
fallback和blockHandler都配置
忽略属性.......
程序异常打到前台了，对用户不友好
Feign系列
修改84模块
84消费者调用提供者9003
Feign组件一般是消费侧
激活Sentinel对Feign的支持
带@FeignClient注解的业务接口
fallback = PaymentFallbackService.class
添加@EnableFeignClients启动Feign的功能
http://localhost:84/consumer/paymentSQL/1
测试84调用9003，此时故意关闭9003微服务提供者，看84消费侧自动降级，不会被耗死
熔断框架比较
规则持久化
一旦我们重启应用，sentinel规则将消失，生产环境需要将配置规则进行持久化
将限流配置规则持久化进Nacos保存，只要刷新8401某个rest地址，sentinel控制台的流控规则就能看到，只要Nacos里面的配置不删除，针对8401上sentinel上的流控规则持续有效
添加Nacos数据源配置
添加Nacos业务规则配置
内容解析
启动8401后刷新sentinel发现业务规则有了
快速访问测试接口
停止8401再看sentinel
重新启动8401再看sentinel
乍一看还是没有，稍等一会儿
多次调用
重新配置出现了，持久化验证通过
20、SpringCloud Alibaba Seata处理分布式事务
21、知识点
22、Github代码地址:
收藏
0 条评论
回复 删除
下一页
