Python微信订餐小程序课程视频
https://blog.csdn.net/m0_56069948/article/details/122285951
Python实战量化交易理财系统
https://blog.csdn.net/m0_56069948/article/details/122285941
1、微服务简述
? 微服务,是一个小型的服务,也是一种设计理念,将一个大型繁杂的系统拆分为多个小型的服务,进行独立部署,这些服务在独立进程中运行,通过特定的协议进行通信
? 优点:
- 轻量化:一个服务不再像一个系统一个繁杂,更加小巧,功能相对单一
- 低耦合:不同的服务模块之间的依赖性降低,可以更加专注于一个功能的开发
- 灵活性高:可以进行独立的部署,也可以支持不同开发语言之间进行服务的调用
- 运维成本高:微服务架构项目往往是由多个微服务构成,随着服务的增多,项目出现异常时不易查询根源
- 重复性高:微服务的工具类不能够被其他服务调用,所以每个微服务都需要进行重复添加该类,导致重复
- 接口调整成本高:一个被多个服务调用的服务一旦更改了接口,那么其他的接口也要做相应的修改,这一修改造成的成本会明显提高
- SpringCloud:SpringBoot基础上构建的微服务框架,通用组件较多,通信方式基于HTTP的rest方式
- Dubbo:阿里巴巴的服务框架,使用RPC通信
1.2 微服务经常考虑的问题
- 网关:提供统一的服务入口
- 服务间调用
- 服务发现:负载均衡时发现可用服务,下线不可用
- 容错:服务调用失败的处理方式
- 熔断:在特定场景下关闭服务的调用,防止错误的扩散
- 限流和降级:请求数量过载,进行请求拒绝(限流)或者返回一个预先设置的返回值(降级)
? SpringCloud是基于SpringBoot实现的微服务框架,为开发人员提供了很多快速构建分布式系统中常见模式的工具,包括配置管理、服务发现、断路器、智能路由、微代理,控制总线等。
2.1 常用的一些组件
- Netflix-Eureka:服务注册与发现
- Netflix-Ribbon:负载均衡,分发请求到不同的服务器,缓解服务器压力
- Netflix-Hystrix:服务保护与熔断机制
- Netflix-Zuul:服务网关
- Feign:服务间通讯
- Config:配置中心
- Distributed/versioned configuration——?分布式/版本化配置?
- Service registration and discovery——?服务注册和发现?
- Routing——?路由?
- Service-to-service calls——?服务到服务呼叫?
- Load balancing——负载平衡?
- Circuit Breakers——?断路器?
- Global locks——?全局锁?
- Leadership election and cluster state——主节点投选与聚集状态
- Distributed messaging——?分布式消息传递?
- SpringBoot是基于Spring的快速配置脚手架,而SpringCloud是基于SpringBoot的云应用开发工具
- SpringBoot专注于开发单个微服务,SpringCloud关注全局的微服务协调治理框架,用于整合管理SpringBoot开发的一个个微服务
- SpringBoot可以离开SpringCloud独立开发使用,而SpringCloud离不开SpringBoot
- Spring Cloud中文网-官方文档中文版:https://www.springcloud.cc
- Spring Cloud中文API文档:https://www.springcloud.cc/spring-cloud-dalston.html
- Spring Cloud中国社区:http://springcloud.cn/
? Eureka是Netflix开发的基于Rest的服务发现框架,SpringCloud基于此进行二次封装,实现服务的管理。
? 创建一个Eureka服务:https://blog.csdn.net/william-m/p/15991511.html
如果没有Eureka,如何进行服务之间的调用?
? 使用Rest进行调用,先将RestTemplate注册到Bean,然后:
@RestController
public class MyController {
private static final String REST_URL_PREFIX="http://localhost:8082";
@Autowired
private RestTemplate restTemplate;
@GetMapping("user/getAll")
public User getById(@RequestParam Long id){
return restTemplate.getForObject(REST_URL_PREFIX+"/user/getAll/"+id,User.class);
}}
3.1 三个角色
- 注册中心
- 服务提供者
- 服务消费者
3.2 AP原则
C - consistency 强一致性? Eureka遵循的是AP原则,Eureka各个节点都是平等的,部分服务节点的下线不会影响正常服务的调用,只要该服务还剩下一个节点在线就可以进行正常的服务访问,即保证了服务可用,但是并不能保证查询到的信息是最新的。Zookeeper的CP原则与之不同,Zookeeper会有一个master节点来保证一致性,一旦master节点挂掉,剩余的节点会重新选举一个leader,而选择的过程需要时间,这期间会使得该服务瘫痪,所以需要满足高可用的话该情况是不能够容忍的。
A - availability 可用性
P - partition tolerance 分区容错性
4、Ribbon 负载均衡
? Spring Cloud Ribbon是一个基于HTTP和TCP的客户端负载均衡工具,基于Netflix Ribbon实现,通过轮询、随机等算法选择一个可用服务。
? 目的:将用户的请求平摊的分配到多个服务上,实现高可用
4.1 客户端负载均衡与服务器端负载均衡的区别 [外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-D5J0iLD4-1650129360545)(https://img2022.cnblogs.com/blog/2383643/202204/2383643-20220416172918783-2129175872.svg)]
? 最大区别:服务清单所存储的位置
- 服务器端负载均衡
- 客户端负载均衡
4.2 服务调用 ? 逻辑时序:RestTemplate发起请求 → 负载均衡器拦截器拦截 → LoadBalanceClient获取ILoadBalance → 获取服务列表 → 根据负载均衡器选择一个server → 发起请求 → 记录调用信息
4.3 负载均衡算法重写
public class MyBalanceRule extends AbstractLoadBalancerRule {// 继承AbstractLoadBalancerRule并重写choose算法
@Override
public Server choose(Object key) {
return choose(getLoadBalancer(), key);
}public Server choose(ILoadBalancer lb, Object key) {
if (lb == null) {
return null;
}
Server server = null;
while (server == null) {
if (Thread.interrupted()) {
return null;
}
List upList = lb.getReachableServers();
// 获取活着的服务
List allList = lb.getAllServers();
// 获取所有服务
int serverCount = allList.size();
if (serverCount == 0) {
return null;
} // =============================================
// 自定义负载均衡算法
// server = ......
//===============================================
if (server == null) {
Thread.yield();
continue;
}
if (server.isAlive()) {
return (server);
}
server = null;
Thread.yield();
}
return server;
}
}// 添加配置类,指定负载均衡算法
@Configuration
public class MyRuleConfig {
@Bean
public IRule myRule(){
return new MyBalanceRule();
}
}
5、Feign负载均衡
? Feign是声明式的 web service 客户端,SpringCloud对Feign进行了封装,可以与Ribbon和Eureka使用以支持负载均衡,只需要创建一个接口并添加**@FeignClient(“服务名”)**注解即可。
5.1 Feign和Ribbon的区别
- Application注解
Feign使用@EnableFeignClients
2. 服务的指定
Ribbon在@RibbonClient注解上声明
Feign在接口中使用@FeignClient声明
3. 服务的调用
? Ribbon基于HTTP和TCP客户端的负载均衡器可以自己构建HTTP请求,使用RestTemplate发送服务
? Feign基于Ribbon进行改进,采用接口的方式,将需要调用的服务的方法定义成抽象方法
5.2 Feign的使用 Consumer应用
启动类
@EnableFeignClients
@EnableDiscoveryClient
@SpringBootApplication
public class ConsumerApplication {
public static void main(String[] args) {
SpringApplication.run(ChannelApplication.class, args);
}
}
为了调用Product应用服务的接口类
@FeignClient(value = "https://www.it610.com/article/Product")
public interface ProductService {@RequestMapping(value = "https://www.it610.com/user/selectById", method = RequestMethod.GET)
User selectById(@RequestParam(value = "https://www.it610.com/article/id") Long id);
}
Product应用
【计算机|SpringCloud入门简述】controller
@RequestMapping("/user")
@RestController
public class ProductController {@RequestMapping(value = "https://www.it610.com/article/selectById", method = RequestMethod.GET)
User selectById(@RequestParam(value = "https://www.it610.com/article/id") Long id){
return "";
}}
6 、Hystrix 熔断
? Hystrix是一个服务容错与保护的组件,用于服务降级、服务熔断、服务限流等等,能够保证在其中一个服务出现问题的时候,不会出现级联故障,防止雪崩,提高分布式服务的健壮性。
**服务雪崩:**微服务之间进行调用的时候,服务F同时被多个服务A、B、C、D调用,此时服务F发生故障(响应时间过长或者不可用等),对于服务ABCD的调用会占用越来越多的系统资源,引起系统整体的崩溃。6.1 服务降级 ? 将某些服务停掉会i这不进行业务处理,释放资源来维持主要服务的功能。
也就是说一个微服务的失败会引发整个系统的崩溃,像雪崩一样。
6.1.1 使用场景:
- 服务器压力剧增,为了保证核心业务的正常运行,对于一些不重要的服务进行有策略地不处理或者简单处理,保证不会和核心业务抢占资源
- 某些服务不可用时,为了避免长时间的等待造成服务的卡顿雪崩,调用该服务时执行备用的降级逻辑,返回友好的提示,保障主题业务不受故障影响
- 接口拒绝服务:页面可以访问,进行增删改时提示服务器繁忙
- 页面拒绝服务:页面提示繁忙他,跳转到其他静态页面
- 延迟持久化:涉及增删改时提示稍后查看结构,不立即处理,将数据添加到异步队列,服务器空闲时处理
- 随机拒绝服务:随机拒绝用户的访问,用户体验差,较少采用
? 为了应对某个服务故障的情况,保证系统的整体可用性,熔断器会切断对该服务的请求,返回一个比较友好的错误响应,直到服务恢复正常
6.2.1 三种状态 ? 熔断机制的三种状态:
- 熔断关闭状态:业务正常访问时,熔断器关闭,服务可以正常调用
- 熔断开启状态:服务调用出错率达到阈值,开启熔断,对该服务的所有请求将会被切断,执行降级方法
- 半熔断状态:服务开启一段时间后进入半熔断状态,尝试恢复服务的调用,允许部分请求的调用并同时进行监控,如果成功率达到预期,则关闭熔断器,恢复服务的正常调用,否则开启熔断。
- 当服务出现故障使得服务的调用失败率达到一个阈值,熔断器开启
- 在熔断器开启时,对该服务的调用会转向设置的fallback降级方法,防止雪崩
- 当熔断器开启达到一定的时间,进入半熔断状态,允许部分请求的调用,同时监控其成功率
- 如果该服务的调用成功率达到预期,关闭熔断器,恢复原有服务的调用逻辑,否则继续开启熔断,重复234
// 在getUserById方法出现故障时执行getUserFallBack方法
@HystrixCommand(fallbackMethod = "getUserFallBack")
@GetMapping(value="https://www.it610.com/article/getUserNameById")
public String getUserById(Long id){
return UserService.selectById(id);
}public String getUserFallBack(){
return "请稍后再试";
}
6.3 熔断、降级、限流处理服务 熔断:直接切断服务的调用
降级:牺牲非核心业务保证核心服务的正常
限流:服务访问量达到阈值后拒绝多余的调用
7、Zuul网关
? Zuul是一个微服务网关。网关:是一个网络系统的前置入口。也就是说要想访问一个有网关的网络系统请求相应的服务,需要先进入网关,然后路由到相应的服务。
? 通常是组成一个系统的微服务很多、或者有权限要求时需要用到网关。
7.1 网关的作用
- 统一入口
(如:多个微服务组成的系统拥有一个统一的请求入口)
- 鉴权校验
(如:校验用户的请求权限)
- 动态路由
- 减少耦合
7.2 过滤器 ? Zuul提供一个过滤器,父类为ZuulFilter,用来过滤代理请求,提供额外的功能逻辑(这点类似于AOP),包括前置过滤、路由后过滤、后置过滤、异常过滤。
? ZuulFilter包含的抽象方法:filterType、filterOrder、shouldFilter、run
- filterType
+ pre:前置过滤,在请求路由之前执行,如:身份认证、日志记录等
+ router:在路由执行后,服务调用前被调用
+ error:处理请求发生错误时调用
+ post:请求到达服务之后执行,如:添加响应头,记录响应日志
? [外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-TRxsicJc-1650129360549)(https://img2022.cnblogs.com/blog/2383643/202204/2383643-20220416172938688-1379348706.svg)]
- filterOrder
- shouldFilter
- run
8、Config配置中心
? 当微服务众多的时候,想要管理各个服务的配置时过于繁杂,SpringCloud Config则可以用来对每个微服务的配置进行集中的管理。可以实现权限管控、灰度发布、版本管理、格式检验、安全配置等。
**灰度发布:**在进行产品研发时,新版本的发布可能存在一定的风险,那么让一部分用户继续使用A特性,并且提供B特性让部分用户使用,如果B特性口碑良好,产品稳定,就可以逐渐进行用户的迁移。灰度发布保证发生问题可以及时解决。就像是打游戏有个测试版本,如果测试用户对该版本满意,则可以继续发布到正式,用户不满意就能及时补救,反正没有发布到正式。作用:
- 集中管理配置文件
- 在服务运行期间实现动态的配置刷新
- 实现属性值的加密解密
- 可以实现基于GIT进行版本管理
- 中心化管理
- 不限语言
- 灵活的版本控制
推荐阅读
- 广州酷狗计算机科技在线测评题 Android岗位
- 历史上的今天|【历史上的今天】4 月 15 日(美国通用电气公司成立;第一届西海岸计算机展览会;Amiga 创始人出生)
- python|微服务简单实现最终一致性
- 其他|如何写出高质量的代码(优秀的程序员都是这样做的)
- 进程|进程 线程 计算机 英语,2022计算机考研408知识点:进程和线程的区别
- 计算机|计算机界的最高奖项—“图灵奖”
- 计算机|我要当程序员,但我没有任何基础,请问要学什么()
- 计算机网络|计算机网络的 166 个核心概念
- 历史上的今天|【历史上的今天】1 月 14 日(IBM 计算机先驱诞生;Windows 7 寿终正寝;诺基亚收购阿尔卡特)