SpringCloud
2023-11-07 09:08:07 10 举报AI智能生成
Spring Cloud Netflix 和 Spring Cloud Alibaba
作者其他创作
大纲/内容
Spring Cloud Netflix
Spring Cloud Eureka
一个基于 Rest 服务的服务治理组件，包括服务注册中心、服务注册与服务发现机制的实现，实现了云端负载均衡和中间层服务器的故障转移。
Eureka 两大组件
Eureka Server
Eureka Client
Eureka 服务注册与发现
服务注册中心（Register Service）
服务提供者（Provider Service）
服务消费者（Consumer Service）
Eureka 实现服务注册与发现的流程
1. 搭建一个 Eureka Server 作为服务注册中心；
2. 服务提供者 Eureka Client 启动时，会把当前服务器的信息以服务名（spring.application.name）的方式注册到服务注册中心；
3. 服务消费者 Eureka Client 启动时，也会向服务注册中心注册；
4. 服务消费者还会获取一份可用服务列表，该列表中包含了所有注册到服务注册中心的服务信息（包括服务提供者和自身的信息）；
5. 在获得了可用服务列表后，服务消费者通过 HTTP 或消息中间件远程调用服务提供者提供的服务。
Spring Cloud Ribbon
Ribbon简介
Ribbon是一个客户端负载均衡器，用于在服务消费者和服务提供者之间分发请求。它可以根据配置的负载均衡策略选择合适的服务实例进行请求转发。
Ribbon特性
1. 客户端负载均衡：Ribbon在客户端实现了负载均衡功能，可以根据配置的负载均衡规则选择合适的服务实例。
2. 多种负载均衡策略：Ribbon提供了多种负载均衡策略，包括轮询、随机、权重等。
3. 故障转移和容错：Ribbon支持故障转移和容错功能，当某个服务实例不可用时，可以自动切换到其他可用的实例。
4. 可插拔的负载均衡规则：Ribbon支持自定义负载均衡规则，可以根据实际需求定制负载均衡策略。
Ribbon使用步骤
1. 引入依赖：在项目的pom.xml文件中添加Ribbon的依赖。
2. 创建RestTemplate：通过RestTemplate发送HTTP请求。
3. 配置负载均衡规则：在配置文件中配置负载均衡规则，如轮询、随机等。
4. 发送请求：通过RestTemplate发送请求，Ribbon会根据配置的负载均衡规则选择合适的服务实例进行请求转发。
Ribbon负载均衡策略
1. 轮询（Round Robin）：按照顺序依次选择服务实例。
2. 随机（Random）：随机选择一个服务实例。
3. 权重（Weighted）：根据服务实例的权重选择实例，权重越高被选中的概率越大。
4. 最少连接（Least Connections）：选择当前连接数最少的服务实例。
5. Hash（Hashing）：根据请求的hash值选择服务实例，同一个请求的hash值将始终选择同一个服务实例。
Ribbon自定义负载均衡规则
1. 创建自定义规则类：实现IRule接口，定义自定义的负载均衡规则。
2. 注册自定义规则：在配置类中使用RibbonClient注解注册自定义规则。
Ribbon与Eureka的集成
1. 引入依赖：在项目的pom.xml文件中添加Eureka和Ribbon的依赖。
2. 配置Eureka客户端：在配置文件中配置Eureka客户端相关信息。
3. 配置Ribbon负载均衡规则：在配置文件中配置Ribbon的负载均衡规则。
4. 使用RestTemplate发送请求：通过RestTemplate发送请求，Ribbon会根据配置的负载均衡规则选择合适的服务实例进行请求转发。
Ribbon与Spring Cloud LoadBalancer的比较
1. Ribbon是Netflix开源的负载均衡器，而Spring Cloud LoadBalancer是Spring Cloud官方提供的负载均衡器。
2. Ribbon支持更多的负载均衡策略，而Spring Cloud LoadBalancer目前只支持轮询和随机策略。
3. Ribbon可以与Eureka等注册中心集成，而Spring Cloud LoadBalancer可以与Spring Cloud Gateway等网关集成。
4. Ribbon需要通过配置文件来配置负载均衡规则，而Spring Cloud LoadBalancer可以通过代码来配置。
参考资料
1. Spring Cloud Ribbon官方文档：
Spring Cloud Hystrix
Hystrix介绍
Hystrix是Netflix开源的一款容错框架，用于处理分布式系统中的延迟和故障。
Hystrix能够提供线程隔离、请求缓存、请求合并、服务降级和服务熔断等功能。
Hystrix通过隔离服务之间的访问点，防止故障的扩散，从而提高了系统的可靠性和弹性。
Hystrix的核心概念
Command
Command用于包装一段需要保护的代码，可以通过配置超时时间、线程池大小等来控制执行的行为。
Hystrix会为每个Command创建一个独立的线程池，从而实现隔离。
Command的执行结果可以被缓存，以便在相同请求下直接返回结果，提高系统性能。
Circuit Breaker
Circuit Breaker用于监控Command的执行情况，当Command的失败率超过阈值时，会触发熔断操作。
熔断后，所有对该Command的请求都会直接返回，不再执行实际的业务逻辑。
在一段时间后，熔断器会尝试半开状态，允许部分请求通过，以检测服务是否恢复正常。
Fallback
Fallback是指当Command执行失败或熔断时，提供一个备选方案来返回结果。
可以通过实现Fallback逻辑，返回一个默认值或者从缓存中读取数据，保证系统的可用性。
Request Collapsing
Request Collapsing用于将多个请求合并成一个批量请求，从而减少网络开销和提高系统性能。
Hystrix会将一段时间内的请求合并成一个批量请求，并在收到响应后拆分成单个结果返回。
Hystrix的应用场景
服务降级
当某个服务不可用或响应时间过长时，可以通过降级操作返回一个默认值或者从缓存中读取数据。
服务降级可以保证系统的可用性，避免故障的扩散。
服务熔断
当某个服务的失败率超过阈值时，可以触发熔断操作，直接返回错误结果，避免继续调用失败的服务。
熔断操作可以减少不必要的资源消耗，保护系统的稳定性。
限流
通过控制并发请求数量，可以避免系统被过多的请求压垮。
Hystrix提供了线程池隔离和信号量隔离两种限流模式，可以根据实际情况选择合适的模式。
Hystrix的使用步骤
添加依赖
在项目的pom.xml文件中添加Spring Cloud Hystrix的依赖。
配置Hystrix
在Spring Boot的配置文件中，配置Hystrix的相关属性，如超时时间、线程池大小等。
添加注解
- 在需要保护的方法上添加HystrixCommand注解，指定Command的相关配置。
实现Fallback逻辑
在HystrixCommand注解的fallbackMethod属性中，指定一个方法作为Fallback逻辑的实现。
Spring Cloud OpenFeign
概述
Spring Cloud OpenFeign是一个基于Spring Cloud的声明式Web服务客户端，它简化了编写服务间调用的代码。它使用了注解和接口来定义和实现服务调用，并且支持负载均衡、服务熔断和服务降级等功能。
特点
1. 声明式服务调用：通过注解和接口定义服务调用，无需编写具体的实现代码。
2. 支持负载均衡：集成了Ribbon，可以自动实现服务的负载均衡。
3. 支持服务熔断和服务降级：集成了Hystrix，可以实现服务的熔断和降级。
4. 支持服务发现：集成了Eureka，可以自动发现注册的服务。
5. 支持自定义拦截器：可以自定义拦截器对请求进行处理。
使用步骤
1. 添加依赖：在项目的pom.xml文件中添加Spring Cloud OpenFeign的依赖。
2. 启用Feign客户端：在Spring Boot应用程序的启动类上添加FeignClients注解，启用Feign客户端。
3. 定义接口：创建一个接口，并使用FeignClient注解指定要调用的服务名称。
4. 调用服务：在业务逻辑中通过接口调用服务。
注解说明
1. FeignClient：用于定义一个Feign客户端，指定要调用的服务名称和相关配置。
2. RequestMapping：用于定义请求的URL路径和请求方法。
3. PathVariable：用于获取URL路径中的参数。
4. RequestParam：用于获取请求参数。
5. RequestBody：用于获取请求体中的参数。
6. RequestHeader：用于获取请求头中的参数。
配置说明
1. feign.client.config.default.*：默认配置，用于全局配置Feign客户端。
2. feign.client.config..*：指定客户端名称的配置，用于配置指定的Feign客户端。
3. feign.client.name：指定Feign客户端的名称。
4. feign.hystrix.enabled：是否启用Hystrix熔断器，默认为true。
5. feign.ribbon.enabled：是否启用Ribbon负载均衡，默认为true。
示例代码
1. 添加依赖：
org.springframework.cloud
spring-cloud-starter-openfeign
2. 启用Feign客户端：
在启动类上添加FeignClients注解。
3. 定义接口：
使用FeignClient注解指定要调用的服务名称，并定义接口方法。
4. 调用服务：
在业务逻辑中通过接口调用服务。
参考资料
1. 官方文档：https://spring.io/projects/spring-cloud-openfeign
2. Spring Cloud OpenFeign GitHub：https://github.com/spring-cloud/spring-cloud-openfeign
Spring Cloud Gateway
概述
Spring Cloud Gateway是Spring Cloud生态系统中的一个全新项目，用于构建基于Spring WebFlux的API网关。它旨在提供一种简单而有效的方式来路由请求，并为微服务架构中的服务提供一些强大的过滤功能。
特性
1. 动态路由：根据请求的路径，将请求路由到不同的目标服务。
2. 过滤器：在路由前或路由后对请求进行修改或处理。
3. 负载均衡：支持多种负载均衡算法，如轮询、随机等。
4. 断路器：在目标服务不可用时，提供断路器功能，防止级联故障。
5.限流：根据配置的限流规则，对请求进行限制。
6.重试：在请求失败时，支持自动重试。
7. 监控：提供了一些监控指标，如请求次数、请求耗时等。
架构
Spring Cloud Gateway的架构包含以下几个核心概念：
1. Route（路由）：定义了请求的匹配规则和转发目标。
2. Predicate（断言）：用于匹配请求的条件，如请求路径、请求方法等。
3. Filter（过滤器）：用于在路由前或路由后对请求进行修改或处理。
使用步骤
1. 添加依赖：在项目的pom.xml文件中添加spring-cloud-starter-gateway依赖。
2. 配置路由：在配置文件中定义路由规则，包括断言和过滤器的配置。
3. 启动应用：启动Spring Boot应用程序。
参考资料
1. 官方文档：https://cloud.spring.io/spring-cloud-gateway/reference/html/
2. Spring Cloud Gateway示例代码：https://github.com/spring-cloud-samples/spring-cloud-gateway-sample
Spring Cloud Config
Spring Cloud Alibaba
Spring Cloud Alibaba是一个基于Spring Cloud的开源框架，用于构建微服务应用程序。
Nacos
Nacos是一个动态服务发现、配置管理和服务管理平台。
Sentinel
Sentinel是一个轻量级的流量控制和熔断框架。
Seata
Seata是一个分布式事务解决方案。
Dubbo
Dubbo是一种高性能的Java RPC框架。
RocketMQ
RocketMQ是一个分布式消息队列。
Alibaba Cloud ACM
ACM是一种配置管理工具，用于管理应用程序的配置。
Alibaba Cloud OSS
OSS是一种对象存储服务，用于存储和访问大量非结构化数据。
Alibaba Cloud SMS
SMS是一种短信服务，用于发送短信通知。
Alibaba Cloud SchedulerX
SchedulerX是一种分布式任务调度服务。
Alibaba Cloud SLS
SLS是一种日志服务，用于收集、存储和查询日志数据。
Alibaba Cloud RDS
RDS是一种关系型数据库服务，用于存储和管理结构化数据。
Alibaba Cloud ECS
ECS是一种弹性计算服务，用于提供可伸缩的云服务器。
Alibaba Cloud ESS
ESS是一种弹性伸缩服务，用于自动调整云服务器数量。
Alibaba Cloud VPC
VPC是一种虚拟私有云服务，用于构建隔离和安全的网络环境。
Alibaba Cloud CDN
CDN是一种内容分发网络服务，用于加速静态资源的传输。
Alibaba Cloud API Gateway
API Gateway是一种API网关服务，用于管理和调度API请求。
Alibaba Cloud Log Service
Log Service是一种日志服务，用于收集、存储和分析日志数据。
Alibaba Cloud Message Service
Message Service是一种消息队列服务，用于异步通信和解耦。
Alibaba Cloud StreamCompute
StreamCompute是一种流计算服务，用于实时处理和分析数据。
Alibaba Cloud Function Compute
Function Compute是一种无服务器计算服务，用于运行事件驱动的函数。
Alibaba Cloud Container Service
Container Service是一种容器服务，用于部署和管理容器化应用程序。
Alibaba Cloud Serverless Workflow
Serverless Workflow是一种无服务器工作流服务，用于编排和管理无服务器应用程序的工作流程。
Alibaba Cloud Kubernetes Service
Kubernetes Service是一种容器编排服务，用于管理和调度容器化应用程序。
Alibaba Cloud FunctionGraph
FunctionGraph是一种无服务器函数计算服务，用于运行事件驱动的函数。
Alibaba Cloud LogSearch
LogSearch是一种日志搜索和分析服务，用于快速查询和分析大量日志数据。
Alibaba Cloud Data Lake Analytics
Data Lake Analytics是一种大数据分析服务，用于处理和分析大规模数据。
Alibaba Cloud MaxCompute
MaxCompute是一种大数据计算服务，用于处理和分析海量数据。
Alibaba Cloud DataWorks
DataWorks是一种数据集成和数据开发平台，用于构建和管理数据流程。
Alibaba Cloud Table Store
Table Store是一种分布式NoSQL数据库服务，用于存储和查询结构化数据。
Alibaba Cloud DataHub
DataHub是一种实时数据流服务，用于收集、传输和处理实时数据。
Alibaba Cloud DTS
DTS是一种数据传输服务，用于数据迁移和同步。
Alibaba Cloud Data Transmission Service
Data Transmission Service是一种数据传输服务，用于数据迁移和同步。
0 条评论
下一页
