草庐IT

20230322整理

@富士山下 2023-10-27 原文

1.什么是SpringCloud?

Spring Cloud是一系列框架的有序集合。它利用Spring Boot的开发便利性巧妙地简化了分布式系统基础设施的开发,如服务发现注册、配置中心、智能路由、消息总线、负载均衡、断路器、数据监控等,都可以用Spring Boot的开发风格做到一键启动和部署。
Spring Cloud并没有重复制造轮子,它只是将各家公司开发的比较成熟、经得起实际考验的服务框架组合起来,通过Spring Boot风格进行再封装屏蔽掉了复杂的配置和实现原理,最终给开发者留出了一套简单易懂、易部署和易维护的分布式系统开发工具包

2.SpringCloud的组成

这就有很多了,我讲几个开发中最重要的
Spring Cloud Eureka:服务注册与发现
Spring Cloud Zuul:服务网关
Spring Cloud Ribbon:客户端负载均衡
Spring Cloud Feign:声明性的Web服务客户端
Spring Cloud Hystrix:断路器
Spring Cloud Confifig:分布式统一配置管理

3.Spring Cloud 和dubbo区别?

(1)服务调用方式:dubbo是RPC , springcloud 是 Rest Api
(2)注册中心:dubbo 是zookeeper ,springcloud是eureka,也可以是zookeeper
(3)服务网关,dubbo本身没有实现,只能通过其他第三方技术整合,springcloud有Zuul路由网关,作为路由服务器,进行消费者的请求分发,springcloud支持断路器,与git完美集成配置文件支持版本控制,事物总线实现配置文件的更新与服务自动装配等等一系列的微服务架构要素

4.什么是Eureka?

Eureka作为SpringCloud的服务注册功能服务器,他是服务注册中心,系统中的其他服务使用Eureka的客户端将其连接到Eureka Service中,并且保持心跳,这样工作人员可以通过EurekaService来监控各个微服务是否运行正常。

5.Eureka怎么实现高可用

集群吧,注册多台Eureka,然后把SpringCloud服务互相注册,客户端从Eureka获取信息时,按照Eureka的顺序来访问。

6. 什么是Eureka的自我保护模式

默认情况下,如果Eureka Service在一定时间内没有接收到某个微服务的心跳,Eureka Service会进入自我保护模式,在该模式下Eureka Service会保护服务注册表中的信息,不在删除注册表中的数据,当网络故障恢复后,Eureka Servic 节点会自动退出自我保护模式。

7.Eureka和ZooKeeper都可以提供服务注册与发现的功能,请说说两个的区别

1.ZooKeeper中的节点服务挂了就要选举 在选举期间注册服务瘫痪,虽然服务最终会恢复,但是选举期间不可用的, 选举就是改微服务做了集群,必须有一台主其他的都是从
2.Eureka各个节点是平等关系,服务器挂了没关系,只要有一台Eureka就可以保证服务可用,数据都是最新的。 如果查询到的数据并不是最新的,就是因为Eureka的自我保护模式导致的
3.Eureka本质上是一个工程,而ZooKeeper只是一个进程
4.Eureka可以很好的应对因网络故障导致部分节点失去联系的情况,而不会像ZooKeeper 一样使得整个注册系统瘫痪
5.ZooKeeper保证的是CP,Eureka保证的是AP
CAP: C:一致性>Consistency; 取舍:(强一致性、单调一致性、会话一致性、最终一致性、弱一致性) A:可用性>Availability; P:分区容错性>Partition tolerance;

8.谈谈服务雪崩

多个微服务之间调用的时候,假设微服务A调用微服务B和微服务C,微服务B和微服务C又调用其他的微服务,这就是所谓的“ 扇出 ”(像一把打开的折扇)。如果扇出的链路上某个微服务的调用响应时间过长或者不可用,对微服务A的调用就会占用越来越多的系统资源,进而引起系统崩溃,这就是所谓的” 雪崩效应 “。也就是系统的 高可用 受到了破坏。

9.什么是断路器?

当一个服务调用另外一个服务由于网络原因或者自身原因出现问题,调用者就会等待被调用者的响应,当更多的服务请求到这些资源导致更多的请求等待,发生连锁效应(雪崩效应)
断路器有三种状态:
打开状态:一段时间内,达到一定的次数无法调用,并且多次监测没有恢复的迹象,断路器完全打开,那么下次请求就不会请求到该服务。
半开状态:短时间内,有恢复迹象,断路器会讲部分请求发给该服务,正常调用时,断路器关闭。
关闭状态:当服务一直处于正常状态,能正常调用。

10.什么是Hystrix?

在分布式系统,我们一定会依赖各种服务,那么这些个服务一定会出现失败的情况,就会导致雪崩,Hystrix就是这样的一个工具,防雪崩力气,他具有服务降级,服务熔断,服务隔离,监控等一些防止雪崩的技术。

Hystrix有四种防雪崩方式:
服务降级(Fall Back):假设微服务A要调用的服务B不可用了,需要服务B提供一个兜底的解决方法,而不是让服务A在那里傻等,耗死。不让客户端等待并立刻返回一个友好提示,比如像客户端提示服务器忙,请稍后再试等。哪些情况会触发服务降级呢?比如 程序运行异常 、 超时 、 服务熔断触发服务降级 、 线程池/信号量打满 也会导致服务降级。
服务熔断(Break):服务熔断就相当于物理上的 熔断保险丝 。类比保险丝达到最大服务访问后,直接拒绝访问,拉闸断电,然后调用服务降级的方法并返回友好提示。
**服务隔离:**隔离服务之间相互影响,线程池/信号量隔离
应用系统会被完全保护起来,即使其中一个服务线程池满了,也不会影响到应用的其他服务。
当引入一个新的客户端的时候,如果发生问题,只会影响新的服务,并不会影响其他服务。
当一个失败的服务恢复正常时,系统会立即恢复正常的性能。
如果我们的应用系统一些参数配置错误,那么线程池的运行状况将会很快被检测出来,如延迟、超时、拒绝等。同时可以通过动态属性实时执行来处理纠正错误的参数配置。
如果服务的性能有变化需要调整,可以通过线程池指标动态属性修改,不会影响其他服务请求。
Hystrix拥有专门的线程池可提供内置的并发功能,可以在同步调用之上构建异步外观模式。
线程池隔离的缺陷:增加了计算的开销,每个业务请求在执行的时候,会涉及请求排队、线程调度、上下文切换等处理
服务监控:在服务发生调用时,会讲每秒请求数,成功请求数等运行指标记录下来

原来的主逻辑如何恢复呢? => 当熔断器打开后,对主逻辑进行熔断之后,Hystrix会启动一个 休眠时间窗 , 在这个时间窗内,降级逻辑是临时的主逻辑,当休眠时间窗到期,熔断器会进入半开状态,释放一次请求到原来的主逻辑上,如果此次请求能够正常访问,则熔断器会进入闭合状态,从而恢复主逻辑,如果注册请求依然有问题,则熔断器继续保持打开状态,并且休眠时间窗重新计时。

11.SpringCloud Fegin

原理:主程序入口添加了@EnableFeignClients注解开启对FeignClient扫描加载处理。根据Feign Client的开发规范,定义接口并加@FeignClientd注解。
当程序启动时,会进行包扫描,扫描所有@FeignClients的注解的类,并且将这些信息注入Spring IOC容器中,当定义的的Feign接口中的方法被调用时,通过JDK的代理方式,来生成具体的RequestTemplate.
当生成代理时,Feign会为每个接口方法创建一个RequestTemplate对象,该对象封装了HTTP请求需要的全部信息,如请求参数名,请求方法等信息都是在这个过程中确定的。然后RequestTemplate生成Request,然后把Request交给Client去处理,这里指的是Client可以是JDK原生的URLConnection,Apache的HttpClient,也可以是OKhttp,最后Client被封装到LoadBalanceClient类,这个类结合Ribbon负载均衡发起服务之间的调用。

结合工作经验自定义Fegin能力:
启动之后执行生成controller逻辑,通过实现CommandLineRunner注解,然后执行底下的run方法,这是一个模版设计模式,注解handdler,扫描包路径下有关注解的接口,然后构建类的信息,如类名,引入内容,方法列表等元信息,然后执行javacodeHanddler的exc接口,根据元信息生成对应的内容,完善元信息,然后再继续执行javaCompleHanddle的方法,拿到所有的元信息,反射所有的controller类,最后获取defaultListableBeanFactory,defaultListableBeanFactory.registerBeanDefinition 注册每一个bean,反射RequestMappingHandlerMapping的detectHandlerMethods方法,将该类的加入,目的是为了让springmvc能找得到。

12.为什么要从单体应用转到微服务架构

单体应用是指所有的代码和功能都集中在一个应用程序中,而微服务架构则将应用程序拆分成多个小型服务,每个服务都专注于执行一个特定的功能或业务流程。

升级成微服务架构的原因有以下几点:

可扩展性:单体应用通常很难水平扩展,因为它们的所有组件都是紧密耦合的。微服务架构允许您将每个服务分别扩展,从而更容易地满足增长的需求。

灵活性:微服务架构使您可以在不影响其他服务的情况下更轻松地修改和部署单个服务。这样可以提高开发速度和部署频率。

可靠性:由于每个微服务只关注一个功能,因此故障只会影响单个服务而不是整个应用程序。这使得故障排除和修复更加容易。

技术异构性:单体应用通常使用一种编程语言和技术栈,而微服务架构允许您使用不同的语言和技术栈来开发不同的服务。这样可以更好地利用新技术和工具,并避免被锁定在单一技术栈中。

团队协作:微服务架构可以促进团队协作,因为每个服务都是独立的,并且可以由不同的团队来开发和维护。这样可以提高开发效率并减少对其他团队的依赖。

总之,微服务架构是一种强大的架构模式,可以提高应用程序的可扩展性、灵活性、可靠性和团队协作能力,使得应用程序更加易于开发、部署和维护。

13.MQ跟kafka的区别

MQ (Message Queue) 和 Kafka 都是常见的消息队列系统,它们都用于在分布式系统中异步传输消息,但是它们有以下不同之处:

架构设计:Kafka 是分布式发布-订阅消息系统,可以在多个生产者和消费者之间传递消息,而 MQ 通常是点对点传递模式。Kafka使用消息发布-订阅的模型,使得多个消费者可以消费同一组消息,从而实现高可扩展性和高吞吐量。而MQ使用队列模型,生产者把消息放到队列中,消费者从队列中取出消息进行处理。

性能:Kafka 是为高吞吐量和低延迟而设计的,具有非常高的性能和可伸缩性。它通过批量发送消息来优化性能,支持百万级别的消息传输,能够轻松处理大量数据。MQ 通常也具有很高的性能,但是在处理大量数据时可能会出现瓶颈。

数据存储:Kafka 使用基于磁盘的数据存储,允许消息在磁盘上长期存储,并支持消息的随机读取和检索。而 MQ 通常采用内存存储,消息在磁盘上的存储可能会导致性能问题。

数据可靠性:Kafka 对于消息的可靠性有很高的保障。它使用分区和副本机制来确保消息不会丢失,并支持数据备份和恢复。MQ 也有类似的机制来确保消息不会丢失,但是它通常不支持数据备份和恢复。

社区和生态系统:Kafka 拥有一个庞大的社区和生态系统,有许多第三方工具和插件可以与之集成,例如Kafka Connect和Kafka Streams。MQ也拥有自己的社区和生态系统,但是与Kafka相比较小。

总之,Kafka 和 MQ 都是可靠的消息队列系统,它们的设计目标、性能和功能略有不同,选择哪种系统取决于具体的应用场景和需求。如果需要高吞吐量和大量数据的处理,则Kafka是更好的选择;如果需要点对点消息传递和更简单的部署,则MQ可能更适合。

有关20230322整理的更多相关文章

  1. H2数据库配置及相关使用方式一站式介绍(极为详细并整理官方文档) - 2

    目录H2数据库入门以及实际开发时的使用1.H2数据库的初识1.1H2数据库介绍1.2为什么要使用嵌入式数据库?1.3嵌入式数据库对比1.3.1性能对比1.4技术选型思考2.H2数据库实战2.1H2数据库下载搭建以及部署2.1.1H2数据库的下载2.1.2数据库启动2.1.2.1windows系统可以在bin目录下执行h2.bat2.1.2.2同理可以通过cmd直接使用命令进行启动:2.1.2.3启动后控制台页面:2.1.3spring整合H2数据库2.1.3.1引入依赖文件2.1.4数据库通过file模式实际保存数据的位置2.2H2数据库操作2.2.1Mysql兼容模式2.2.2Mysql模式

  2. 2023年B组蓝桥杯省赛考前好题整理 - 2

    蓝桥杯第十四届蓝桥杯模拟赛第三期考场应对攻略(C/C++)真题可以去此处寻找https://blog.csdn.net/weixin_46239370/article/details/105464885?spm=1001.2014.3001.5506考前准备考前五分钟,开十个源文件,并把头文件等必须写的部分写出来,写完的程序一定要有顺序地保留万能头可以尝试开一下#include试题1:问题描述请找到一个大于2022的最小数,这个数转换成十六进制之后,所有的数位(不含前导0)都为字母(A到F)。请将这个数的十进制形式作为答案提交。答案提交这是一道结果填空的题,你只需要算出结果后提交即可。本题的结

  3. Ruby:打印和整理数组的方法 - 2

    我不确定这个问题是不是太傻了,但我还没有找到解决办法。通常我会把一个数组放在一个循环中current_humans=[.....]current_humans.eachdo|characteristic|putscharacteristicend但是如果我有这个:classHumanattr_accessor:name,:country,:sex@@current_humans=[]defself.current_humans@@current_humansenddefself.print#@@current_humans.eachdo|characteristic|#putschar

  4. 零基础如何入门网络工程师?12年资深大佬,吐血整理最强学习指南 - 2

    最近收到好多学员的一些提问,零基础没经验,能不能转行到网络工程师?发展前景怎么样?薪资能有多少?应该有不少朋友都有这个疑问,那么,今天我尽量给大家做出一个详细的解答,希望能有所帮助。​内容可能比较长,大家可以点赞收藏,再慢慢阅读。零基础没经验,能不能转行到网络工程师?​想要快速学习并入门网工行业,最快速也是效率做高的方法就是考取行业的相关证书。就像其他行业一样,也有属于网工的认证。网络工程师这个行业,现在最具有含金量并被行业承认的两个认证:思科和华为。简单说一下两者的区别:​ 从含金量角度来看。两者的含金量其实差不多,HCIE是华为认证的最高等级证书,CCIE是思科认证的最高等级证书,两者在网

  5. eBPF verifier常见错误整理 @龙蜥社区eBPF SIG - 2

    如今eBPF程序的编写,很多都是基于bcc或者bpftrace进行,也有开发者直接基于libbpf库进行,但是不管怎样,编写的xx.bpf.c程序,在加载到内核时,都必须经过内核的verifier校验器进行各种边界和内存检查,经常会碰到各种奇奇怪怪的verifier报错,导致eBPF程序加载失败。有些错误,开发者可能要花费大量的时间去分析并修改程序,并祈祷程序能够加载成功。特别是在低版本的内核运行低版本Clang编译器编译的eBPF程序,错误提示非常糟糕,经常找不到出错点,这就大大增加了开发难度。为此,本文梳理了一些常见的eBPFverifier报错,避免更多的人走弯路,写出能成功加载的eBP

  6. Flink SQL管理平台flink-streaming-platform-web安装搭建-整理 - 2

    目录步骤安装第二步下载flink第三步安装flink-streaming-patform-web第四步配置flinkweb平台第五步运行demo在Flink学习的入门阶段,非常重要的一个过程就是Flink环境搭建,这是认识FLInk框架的第一步,也是为后续的理论学习和代码练习打下基础。今天加米谷大数据就为大家带来Flink环境搭建的步骤解析,帮助大家一步步来部署好Flink环境。步骤1、使用gitclone到本地后,使用IDEA打开项目2、修改数据库连接flink-streaming-web/src/main/resources/application.properties3、在本地数据库中创

  7. 微信小程序开发整理-mp3 - 2

    一、生命周期1、定义生命周期(LifeCycle)是指一个对象从创建>运行→>销毁的整个阶段,强调的是一个时间段。2、分类应用生命周期(app.js):特指小程序从启动->运行→销毁的过程App({//小程序初始化完成时,执行此函数,全局只触发一次。可以做一些初始化的工作。onLaunch:function(options){},//小程序启动,或从后台进入前台显示时触发。onShow:function(options){},//小程序从前台进入后台时触发。onHide:function(){}})页面生命周期(页面.js):特指小程序中,每个页面的加载→渲染→销毁的过程Page({onLoa

  8. 本科论文常见答辩问题整理 - 2

    这里写目录标题专业性问题你系统的整体设计是怎么样?用了什么技术?这些技术应用的好处是什么?框架,SSM,SSH这些有什么优势。前端,前端用了什么;你数据库整体的设计是怎么样的,某个表,某个字段作用是什么?MySQL,为什么用MySQL;有几个表;三范式;主键这些基础。数据库链接方式,数据库设计中的ER图、范式等。你系统核心功能怎么实现?业务,功能模块,老师对某个模块需要详细了解,问你是怎么做的,其实就是你的代码实现逻辑;功能怎么实现的。流程图,讲一下有角色的功能区别。一些软件工程,数据库的基础知识,比如时序图,ER图,范式之类的。前后端交互用什么;ajax等等软件测试Java基础,三大特性,有

  9. 3.2 报错整理 - 2

     报错1:报错:RuntimeError:DataLoaderworker(pid93789)iskilledbysignal:Killed.原因:显存不够报错2:报错:TqdmWarning:IProgressnotfound.Pleaseupdatejupyterandipywidgets.解决:pipinstallipywidgets报错3:报错:RuntimeError:CUDAerror:CUBLAS_STATUS_EXECUTION_FAILEDwhencalling`cublasSgemm(handle,opa,opb,m,n,k,&alpha,a,lda,b,ldb,&beta

  10. json - 整理大型非结构化 REST/JSON 响应 - 2

    我正忙于弄清楚如何将大型非结构化json响应解码为可用对象。这是一个示例响应(经过修剪以显示我遇到问题的部分)由于这是一个非常大的json响应,因此大大对其进行了修剪。为简单起见,我在下面也省略了结构标记。{"responseStatus":"ok","responseHeader":{"status":"ok","requestId":"blah"},"responseData":{"records":[{"name":"blah","site":{"id":1,"name":"west"},"somevar1":"someval","somevar2":{"x":2,"y":1},

随机推荐