springCloudAlibaba
Nacos
什么是nacos
nacos (Nacos：Dynamic Naming and Configuration Service) 一个更易于构建云原生应用的动态服务发
现，配置管理和服务管理中心
Nacos就是注册中心+配置中心的组合 等价于 netflix版本的 Eureka+Config+Bus+zik
解决了什么痛点
- 之前我们在netflix版本遇到的配置需要手动的区分发信息，
- 杜绝了我们需要专门自己建一个注册中心的包，阿里给我们提供了开箱即用的发行版本，我们只需要简单的配置，直接脚本启动
- 可以直接查看到集群信息，和调用链路
如何获得和社区文档
下载地址 ：https://github.com/alibaba/Nacos
中文文档地址 ：https://nacos.io/zh-cn/index.html
主流注册中心对比
安装nacos
环境：
- java 8
- Maven
解压安装包，直接运行bin目录下的startup.cmd
2.xx版本，需要修改单机版本，然后用命令启动 startup.cmd -m standalone
命令运行成功后直接访问http://localhost:8848/nacos
就是这么简单
作为服务注册中心
我们新建两个模块
基于nacos的服务提供者集群：cloudalibaba-provider-payment9001
基于nacos的服务提供者集群：cloudalibaba-provider-payment9002
cloudalibaba-provider-payment9001
nacos需要的主要依赖包
<dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-actuator</artifactId> </dependency>
核心配置文件
server: port: 9001 spring: application: name: nacos-payment-provider cloud: #注册到nacos nacos: discovery: server-addr: localhost:8848 #配置Nacos地址 management: endpoints: web: exposure: include: '*'
配置注意项
- 一定要导入服务暴露
- 配置的时候 要加入 nacos的地址
编写一个方法测试
package com.atguigu.springcloud.alibaba.controller; import org.springframework.beans.factory.annotation.Value; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RestController; @RestController public class PaymentController { @Value("${server.port}") private String serverPort; @GetMapping(value = "/payment/nacos/{id}") public String getPayment(@PathVariable("id") Integer id) { return "nacos registry, serverPort: "+ serverPort+"\t id"+id; } }
主启动类加上注解
import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.client.discovery.EnableDiscoveryClient; @EnableDiscoveryClient @SpringBootApplication public class PaymentMain9001 { public static void main(String[] args) { SpringApplication.run(PaymentMain9001.class,args); } }
启动服务，就可以在nacos中看到我们的服务了
集群另一个模块 参考 9001的编写方式
作为服务配置中心
我们来建一个demo来体验一下，nacos的动态配置
配置模块 ：cloudalibaba-config-nacos-client3377
基础配置
导入需要的jar包
<dependencies> <!--nacos-config--> <dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId> </dependency> <!--nacos-discovery--> <dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId> </dependency> <!--web + actuator--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-actuator</artifactId> </dependency> <!--一般基础配置--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-devtools</artifactId> <scope>runtime</scope> <optional>true</optional> </dependency> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> <optional>true</optional> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> </dependencies>
编写配置文件
这里引入一个概念
bootstrap的启动优先级比application高
为了确保我们的nacos上的配置被加载成功
server: port: 3377 spring: application: name: nacos-config-client cloud: nacos: discovery: server-addr: localhost:8848 #服务注册中心地址 config: server-addr: localhost:8848 #配置中心地址 file-extension: yaml #指定yaml格式的配置
编写一个查看测试信息的controller
package com.atguigu.springcloud.alibaba.controller; import org.springframework.beans.factory.annotation.Value; import org.springframework.cloud.context.config.annotation.RefreshScope; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RestController; @RestController @RefreshScope public class ConfigClientController { @Value("${config.info}") private String configInfo; @GetMapping("/config/info") public String getConfigInfo() { return configInfo; } }
RefreshScope 我们可以使用 cloud的原生注解，来实现动态查看配置刷新，
创建一个nacos上的配置
nacos 中的配置规则
之后启动就可以在nacos上更改配置了
nacos配置持久化
我们可以试验一下，配置都时候 nacos是自带了一个嵌入式数据库derby
我们这里可以修改设置，到自己的mysql上
先去nacos的文件夹中找到，nacos的sql的脚本
导入到mysql中 创建一个数据库 nacos_config
之后找到application文件
修改配置
spring.datasource.platform=mysql db.num=1 db.url.0=jdbc:mysql://127.0.0.1:3306/nacos_config_tmall?characterEncoding=utf8&connectTimeout=1000&socketTimeout=3000&autoReconnect=true&serverTimezone=UTC db.user=root db.password=root
之后启动nacos ，就会看到全新的naocs 我们之后再创建的各种配置，就会保存在我们自己创建的数据库中
小结
使用过Eureka之后，使用nacos，感受到nacos是十分优秀的一款注册中心，我们可以快速启动，省去了很多的配置，这个技术简化了我们想要使用注册中心和动态配置查看链路需要的繁琐配置，
Sentinel
Sentinel是什么
独立于项目外的 服务流量控制台，可以用于熔断 防止服务崩溃无响应，服务重启，流量限制等
能做什么 针对于什么场景
sentinel给我们带来的服务
- Sentinel 独立于项目外，开箱即用
- 控制台可以可视化的实时监控和服务规则配置
- 可以无缝配合cloud的注册中心 最佳匹配 nacos，也可以使用其他的如 Eureka apollo zookeeper等
解决了什么场景问题
- 服务雪崩
- 服务降级
- 服务熔断
- 服务限流
如何获取
下载地址 ：sentinel下载地址
文档地址 ：sentinel文档地址
Sentinel 组件由两部分组成
- 使用sentinel的服务
- sentinel的服务控制台
安装环境我们只需要有 java 8 以上就可以了
下载完成之后，直接运行java -jar 启动查看即可java -jar sentinel-dashboard-1.7.0.jar
我们只需要访问 默认的启动端口就可以看到 sentinel的控制台了
账号和密码均为 ：sentinel
演示工程 8401
我们主要以介绍sentinel实战，对于演示工程，选核心部分展示
核心依赖
<dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId> </dependency> <dependency> <groupId>com.alibaba.csp</groupId> <artifactId>sentinel-datasource-nacos</artifactId> </dependency> <dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId> </dependency>
演示项目配置
server: port: 8401 spring: application: name: cloudalibaba-sentinel-service cloud: nacos: discovery: server-addr: localhost:8848 sentinel: transport: dashboard: localhost:8080 port: 8719 #默认8719，假如被占用了会自动从8719开始依次+1扫描。直至找到未被占用的端口 management: endpoints: web: exposure: include: '*'
编写一个controller 来演示
@RestController public class FlowLimitController { @GetMapping("/testA") public String testA() { return "------testA"; } @GetMapping("/testB") public String testB() { return "------testB"; } }
之后启动nacos和 sentinel 这个时候你访问sentinel 会发现什么也没有
为什么？
应为 sentinel是懒加载的，我们访问其中一个方法，就会在sentinel中看到我们项目
流控规则
基础流控
我们可以看到面板
- 资源名:唯一名称，默认请求路径
- 针对来源: Sentinel可以针对调用者进行限流，填写微服务名，默认default (不区分来源)阈值类型/单机阈值:
- QPs(每秒钟的请求数量):当调用该api的QPS达到阈值的时候，进行限流。线程数:当调用该api的线程数达到阈值的时候，进行限流
- 是否集群:不需要集群
- 流控模式:
- 直接: api达到限流条件时，直接限流
- 关联:当关联的资源达到阈值时，就限流自己
- 链路:只记录指定链路上的流量（指定资源从入口资源进来的流量，如果达到阈值，就进行限流)【api级别的针对来源】
- 流控效果:
- 快速失败:直接失败，抛异常
- Warm Up:根据codeFactor (冷加载因子，默认3)的值，从阈值codeFactor，经过预热时长，才达到设置的QPS阈值
- 排队等待:匀速排队，让请求以匀速的速度通过，阈值类型必须设置为QPS，否则无效
直接失败
快速失败，配置如下：
之后我们快速访问 testa 就会发现 Blocked by Sentinel (flow limiting)
触发了 sentinel的默认提示
关联
当关联的资源达到阈值时，就限流自己
只要我们访问b 超过了 qps a就会把自己限流
高级配置
预热 Warm Up
Warm Up ( RuleConstant.CONTROL_BEHAVIOR_UARM_uP）方式，即预热/冷启动方式。当系统长期处于低水位的情况下，当流量突然增加时，直接把系统拉升到高水位可能瞬间把系统压垮。通过"冷启动”，让通过的流量缓慢增加，在一定时间内逐渐增加到阈值上限，给冷系统一个预热的时间，避免冷系统被压垮。详细文档可以参考流量控制-Warm Up文档，具体的例子可以参见
WarmUpFlowDemo。
公式：阈值除以coldFactor（默认值为3），经过预热时长后才会达到阈值
默认coldFactor为3，即请求QPS从threshold/3开始，经预热时长逐渐升至设定的QPS阈值。
适合应用场景
大量数据情况 ： 如秒杀
这里设置好之后，我们去访问，会发现，当到了阈值之后，慢慢的还是可以访问，直到10
排队等待
匀速排队
匀速排队（ RuleConstant.CONTROL_BEHAVIOR_RATE_LTIMITER）方式会严格控制请求通过的间隔时间，也即是让请求以均匀的速度通过，对应的是漏桶算法。详细文档可以参考流星控制–匀速器模式，具体的例子可以参见PaceFlowDemo。
匀速排队，阈值必须设置为QPS
在一定时间内，逐渐处理进入到的请求，而不是第一时间拒绝请求
总结
Sentinel这个控制台，十分到强大，给我们带来了很多很多可以使用的服务规则，我们这里主要介绍了流控，这只是Sentinel的冰山一角，
Sentinel 可以看到，还有很多模块可以根据不同的场景和需求是了解，
天道酬勤，我们一起进步吧
SpringCloud Alibaba-springcloudalibaba（二）https://developer.aliyun.com/article/1469554
