皮皮网

1.springcloud2022？
2.spring cloud zuul 原理简介及使用
3.springbootcloud组件
4.Jenkins持续集成的源码13种替代方案
5.Spring Cloud实战小贴士：Zuul统一异常处理（二）
6.gateway和zuul的区别与联系

springcloud2022？

       å¾®æœåŠ¡æ¡†æž¶ä¹‹SpringCloud简介

       åœ¨äº†è§£SpringCloud之前先了解一下微服务架构需要考量的核心关键点，如下图：

       å¯¹äºŽä»¥ä¸Šç­‰æ ¸å¿ƒå…³é”®ç‚¹çš„处理，不需要我们重复造车轮，SpringCloud已经帮我们集成了，它使用SpringBoot风格将一些比较成熟的微服务框架组合起来，屏蔽掉了复杂的配置和实现原理，为快速构建微服务架构的应用提供了一套基础设施工具和开发支持。

       SpringCloud所提供的核心功能包含：

       SpringCloud架构图

       SpringCloud子项目

       SpringCloud旗下的子项目大致可以分为两类：

       å¦‚下：

       1.SpringCloud与SpringBoot

       SpringBoot可以说是微服务架构的核心技术之一。通过在SpringBoot应用中添加SpringMVC依赖，就可以快速实现基于REST架构的服务接口，并且可以提供对HTTP标准动作的支持。而且SpringBoot默认提供JackJson序列化支持，可以让服务接口输入、输出支持JSON等。因此，当使用SpringCloud进行微服务架构开发时，使用SpringBoot是一条必经之路。

       2.SpringCloud与服务治理(Eureka)

       æœåŠ¡æ²»ç†æ˜¯SpringCloud的核心，在实现上其提供了两个选择，即Consul和Netflix的Eureka。

       Eureka提供了服务注册中心、服务发现客户端，以及注册服务的UI界面应用。

       åœ¨Eureka的实现中，节点之间相互平等，有部分注册中心“挂掉”也不会对整个应用造成影响，即使集群只剩一个节点存活，也可以正常地治理服务。即使所有服务注册节点都宕机，Eureka客户端中所缓存的服务实例列表信息，也可让服务消费者能够正常工作，从而保障微服务之间互相调用的健壮性和应用的弹性。

       3.SpringCloud与客户端负载均衡(Ribbon)

       Ribbon默认与Eureak进行无缝整合，当客户端启动的时候，从Eureka服务器中获取一份服务注册列表并维护在本地，当服务消费者需要调用服务时，Ribbon就会根据负载均衡策略选择一个合适的服务提供者实例并进行访问。

       SpringCloud通过集成Netflix的Feign项目，为开发者提供了声明式服务调用，从而简化了微服务之间的调用处理方式。并且默认Feign项目集成了Ribbon，使得声明式调用也支持客户端负载均衡功能。

       4.SpringCloud与微服务容错、降级(Hystrix)

       ä¸ºäº†ç»™å¾®æœåŠ¡æž¶æž„提供更大的弹性，在SpringCloud中，通过集成Netflix下子项目Hystrix，通过所提供的@HystrixCommand注解可以轻松为我们所开发的微服务提供容错、回退、降级等功能。此外，Hystrix也默认集成到Feign子项目中。

       Hystrix是根据“断路器”模式而创建。当Hystrix监控到某服务单元发生故障之后，就会进入服务熔断处理，并向调用方返回一个符合预期的服务降级处理（fallback），而不是长时间的等待或者抛出调用异常，从而保障服务调用方的线程不会被长时间、不必要地占用，避免故障在应用中的蔓延造成的雪崩效应。

       è€ŒHystrix的仪表盘项目（Dashboard）可以监控各个服务调用所消耗的时间、请求数、成功率等，通过这种近乎实时的监控和告警，可以及时发现系统中潜在问题并进行处理。

       5.SpringCloud与服务网关(Zuul)

       SpringCloud通过集成Netflix中的Zuul实现API服务网关功能，提供对请求的路由和过滤两个功能

       è·¯ç”±åŠŸèƒ½è´Ÿè´£å°†å¤–部请求转发到具体的微服务实例上，是实现外部访问统一入口的基础。

       è¿‡æ»¤å™¨åŠŸèƒ½åˆ™è´Ÿè´£å¯¹è¯·æ±‚的处理过程进行干预，是实现请求校验、服务聚合等功能的基础。

       é€šè¿‡Zuul，可以将细粒度的服务组合起来提供一个粗粒度的服务，所有请求都导入一个统一的入口，对外整个服务只需要暴露一个API接口，屏蔽了服务端的实现细节。通过Zuul的反向代理功能，可以实现路由寻址，将请求转发到后端的粗粒度服务上，并做一些通用的逻辑处理。此外，Zuul默认会与Eureka服务器进行整合，自动从Eureka服务器中获取所有注册的服务并进行路由映射，实现API服务网关自动配置。

       6.SpringCloud与消息中间件(Stream)

       SpringCloud为简化基于消息的开发，提供了Stream子项目，通过建立消息应用抽象层，构建了消息收发、分组消费和消息分片等功能处理，将业务应用中的消息收发与具体消息中间件进行解耦，使微服务应用开发中可以非常方便地与Kafka和RabbitMQ等消息中间件进行集成。

       SpringCloudBus基于Stream进行扩展，可以作为微服务之间的事件、消息总线，用于服务集群中状态变化的传播。

       æ¯”如SpringCloudConfig借助Bus，可以实现配置的动态刷新处理。

       7.SpringCloud与分布式配置中心(Config)

       é’ˆå¯¹å¾®æœåŠ¡æž¶æž„下的配置文件管理需求，SpringCloud提供了一个Config子项目。SpringCloudConfig具有中心化、版本控制、支持动态更新和语言独立等特性。

       åœ¨Config子项目中将微服务应用分为两种角色：配置服务器（ConfigServer）和配置客户端（ConfigClient）。使用配置服务器集中地管理所有配置属性文件，配置服务中心可以将配置属性文件存储到Git、SVN等具有版本管理仓库中，也可以存放在文件系统中。默认采用Git的方式进行存储，因此可以很容易地对配置文件进行修改，并实现版本控制。

       8.SpringCloud与微服务链路追踪(Sleuth)

       SpringCloud中的Sleuth子项目为开发者提供了微服务之间调用的链路追踪。

       Sleuth核心思想就是通过一个全局的ID将分布在各微服务服务节点上的请求处理串联起来，还原了调用关系，并借助数据埋点，实现对微服务调用链路上的性能数据的采集。

       å› æ­¤ï¼Œé€šè¿‡Sleuth可以很清楚地了解到一个用户请求经过了哪些服务、每个服务处理花费了多长时间，从而可以对用户的请求进行分析。此外，通过将采集的数据发送给Zipkin进行存储、统计和分析，从而可以实现可视化的分析和展示，帮助开发者对微服务实施优化处理。

       9.SpringCloud与微服务安全(Security)

       SpringCloudSecurity为我们提供了一个认证和鉴权的安全框架，实现了资源授权、令牌管理等功能，同时结合Zuul可以将认证信息在微服务调用过程中直接传递，简化了我们进行安全管控的开发。

       SpringCloudSecurity默认支持OAuth2.0认证协议，因此单点登录也可以非常容易实现，并且OAuth2.0所生成的令牌可以使用JWT的方式，进一步简化了微服务中的安全管理。

       .SpringCloud的其他子项目

       è‡ªå®šä¹‰springcloud-gateway熔断处理

       ä¸€ã€åœºæ™¯

       ä½¿ç”¨springcloudgateway后，有了熔断，问题也就随之而来，服务间调用有了hystrix可以及时的排除坏接口、坏服务的问题，对系统很有帮助。但是！不是所有的接口都是极短时间内完成的，不是所有的接口都可以设置一样的超时时间的！

       é‚£ä¹ˆæˆ‘们面临一个问题，那就是百分之的接口都可以在1s内完美完成，但是就是那几个特殊接口，需要十几秒，几十秒的等待时间，而默认熔断的时间又只有一个。

       äºŒã€åˆ†æž

       åœ¨å‰é¢springcloudgateway源码解析之请求篇中我们知道请求会经过一些列的过滤器（GatewayFilter）,而springcloudgateway的降级熔断处理就是由一个特殊的过滤器来处理的，通过源码分析我们关注到HystrixGatewayFilterFactory这个类，这个类的作用就是生产GatewayFilter用的，我们看下它的实现

       å¯ä»¥çœ‹åˆ°çº¢æ¡†å¤„最后构建了一个匿名的GatewayFilter对象返回，这个对象在接口请求过程中会被加载到过滤器链条中，仔细看到这里是创建了一个RouteHystrixCommand这个命令对象，最终调用command.toObservable()方法处理请求，如果超时熔断调用resumeWithFallback方法

       é€šè¿‡æºç åˆ†æžgateway在路由时可以指定HystrixCommandKey，并且对HystrixCommandKey设置超时时间

       ä¸‰ã€æ–¹æ¡ˆ

       çŸ¥é“网关熔断的原理就好办了,自定义熔断的过滤器配置到接口请求过程中，由过滤器来读取接口熔断配置并构建HystrixObservableCommand处理请求。

       è‡ªå®šä¹‰ä¸€ä¸ªç±»XXXGatewayFilterFactory继承AbstractGatewayFilterFactory，将api和对应的timeout配置化，来实现细化到具体接口的熔断配置，具体实现如下：

       packageorg.unicorn.framework.gateway.filter;

       importcn.hutool.core.collection.CollectionUtil;

       importcom.netflix.hystrix.HystrixCommandGroupKey;

       importcom.netflix.hystrix.HystrixCommandKey;

       importcom.netflix.hystrix.HystrixCommandProperties;

       importcom.netflix.hystrix.HystrixObservableCommand;

       importcom.netflix.hystrix.exception.HystrixRuntimeException;

       importorg.springframework.beans.factory.ObjectProvider;

       importorg.springframework.cloud.gateway.filter.GatewayFilter;

       importorg.springframework.cloud.gateway.filter.GatewayFilterChain;

       importorg.springframework.cloud.gateway.filter.factory.AbstractGatewayFilterFactory;

       importorg.springframework.cloud.gateway.support.ServerWebExchangeUtils;

       importorg.springframework.cloud.gateway.support.TimeoutException;

       importorg.springframework.core.annotation.AnnotatedElementUtils;

       importorg.springframework.mand;

       if(CollectionUtil.isNotEmpty(apiTimeoutList)){

       //request匹配属于那种模式

       ApiHystrixTimeoutapiHystrixTimeout=getApiHystrixTimeout(apiTimeoutList,path);

       command=newUnicornRouteHystrixCommand(config.getFallbackUri(),exchange,chain,initSetter(apiHystrixTimeout.getApiPattern(),apiHystrixTimeout.getTimeout()));

       }else{

       command=newUnicornRouteHystrixCommand(config.getFallbackUri(),exchange,chain,initSetter(serviceId(exchange),null));

       }

       returncommand;

       }

       /

**

       *@paramapiTimeoutList

       *@parampath

       *@return

       */

       privateApiHystrixTimeoutgetApiHystrixTimeout(ListapiTimeoutList,Stringpath){

       for(ApiHystrixTimeoutapiTimeoutPattern:apiTimeoutList){

       if(this.antPathMatcher.match(apiTimeoutPattern.getApiPattern(),path)){

       returnapiTimeoutPattern;

       }

       }

       ApiHystrixTimeoutapiHystrixTimeout=newApiHystrixTimeout();

       apiHystrixTimeout.setApiPattern("default");

       apiHystrixTimeout.timeout=null;

       returnapiHystrixTimeout;

       }

       @Override

       publicGatewayFilterapply(Configconfig){

       return(exchange,chain)-{

       UnicornRouteHystrixCommandcommand=initUnicornRouteHystrixCommand(exchange,chain,config);

       returnMono.create(s-{

       Subscriptionsub=command.toObservable().subscribe(s::success,s::error,s::success);

       s.onCancel(sub::unsubscribe);

       }).onErrorResume((Function)throwable-{

       if(throwableinstanceofHystrixRuntimeException){

       HystrixRuntimeExceptione=(HystrixRuntimeException)throwable;

       HystrixRuntimeException.FailureTypefailureType=e.getFailureType();

       switch(failureType){

       caseTIMEOUT:

       returnMono.error(newTimeoutException());

       caseCOMMAND_EXCEPTION:{

       Throwablecause=e.getCause();

       if(causeinstanceofResponseStatusException||AnnotatedElementUtils

       .findMergedAnnotation(cause.getClass(),ResponseStatus.class)!=null){

       returnMono.error(cause);

       }

       }

       default:

       break;

       }

       }

spring cloud zuul 原理简介及使用

       Zuul是Netflix开源的一个API Gateway服务器，它本质上是导入一个Web Servlet应用，主要用于路由、源码过滤和增强微服务架构的导入API调用。

       其工作原理主要包括过滤器机制。源码Zuul通过定义四种标准过滤器类型，导入记事软件源码如路由（ROUTE）、源码前置（PRE）、导入后置（POST）和错误（ERROR），源码来管理请求的导入生命周期。内置的源码过滤器如StaticResponseFilter和SurgicalDebugFilter提供了特殊的功能，如静态响应和调试日志。导入同时，源码用户还可以自定义过滤器来定制特定的导入行为，如直接生成响应，源码无需转发到后端服务。

       Zuul的dharma源码下载核心功能在于其动态过滤机制，通过在启动类上添加@EnableZuulProxy注解，能实现API网关的功能，如处理请求、路由规则配置、负载均衡、访问前缀设置等。例如，通过Eureka和Zuul的配合，可以自动配置路由，或者通过配置文件自定义路由规则。Ribbon和Hystrix的集成提供了内置的负载均衡和容错功能。

       实战中，你可以引入相关依赖，配置application.yml，启用Zuul的网关功能。通过操作如添加自定义过滤器、预约年检源码配置访问路径前缀，以及使用Spring Boot Actuator查看路由信息，深入了解Zuul的工作方式。相关源码和详细教程可以在gitee和微信公众号等平台找到。

springbootcloud组件

       .SpringBoot和SpringCloud的关系

       å¾ˆå¤šäººæ–°æ‰‹å¯¹äºŽSpringBoot和SpringCloud的关系说不清楚、理解不清楚，本文抽出点时间来进行分享下自己的理解，以帮助大家更好的理解两者之间的关系。

       å…¶è®¾è®¡ç›®çš„之初是用来简化Spring应用的初始搭建以及开发过程。很多东西都是配置好的，约定大于配置，使用注解替代了很多xml臃肿的配置，极大的简化了项目配置的消耗，提供了高效的编程脚手架。

       Cloud相当于利用了SpringBoot的开发便利性巧妙地简化了分布式系统基础设施的开发，像是服务注册发现、配置中心、消息总线、负载均衡、断路器、数据监控等，都可以用SpringBoot的开发风格做到一键启动和部署，SpringCloud并没有重复的造轮子，把各家公司成熟，经得起考验的服务框架组合起来，通过SpringBoot屏蔽调复杂的配置和实现原理，留给开发者一套简单易懂、容易部署、容易维护的分布式开发工具包。

       å…¶ä¸­çš„关系是：

       Spring-》SpingBoot-》SpringCloud

       Cloud的核心组件：

       æ„Ÿè§‰è¿™ä¸ªè¯é¢˜èƒ½å†™å¥½å¤šçš„东西，像是SpingCloud和Dubbbo的微服务选型等等再进行对比、比较优缺点，本篇就简单的进行了总结和介绍，希望能帮助到有困惑的朋友吧，后面有时间在写一些文章进行拓展和补充。

SpringCloud微服务体系的组成

       NetflixEureka是SpringCloud服务注册发现的基础组件

       Eureka提供RESTful风格(HTTP协议)的服务注册与发现

       Eureka采用C/S架构,SpringCloud内置客户端

       å¯ç”¨åº”用,访问

       Eureka客户端开发要点

       maven依赖spring-cloud-starter-netflix-eureka-clientapplication.yml

       é…ç½®eureka.client.service-url.defaultZone

       å…¥å£ç±»å¢žåŠ @EnableEurekaClient

       å…ˆå¯åŠ¨æ³¨å†Œä¸­å¿ƒ,在启动客户端,访问localhost:查看eureka注册中心,看到客户端注册

       Eureka名词概念

       Register-服务注册,向Eureka进行注册登记

       Renew-服务续约,秒/次心跳包健康检查.秒未收到剔除服务

       FetchRegistries-获取服务注册列表,获取其他微服务地址

       Cancel-服务下线,某个微服务通知注册中心暂停服务

       Eviction-服务剔除,秒未续约,从服务注册表进行剔除

       Eureka自我保护机制

       Eureka在运行期去统计心跳失败率在分钟之内是否低于%

       å¦‚果低于%，会将这些实例保护起来，让这些实例不会被剔除

       å…³é—­è‡ªæˆ‘保护:eureka.服务实例.

       enable-self-preservation:false

       PS:如非网络特别不稳定,建议关闭

       Eureka高可用配置步骤

       æœåŠ¡æä¾›è€…defaultZone指向其他的Eureka

       å®¢æˆ·ç«¯æ·»åŠ æ‰€æœ‰Eureka服务实例URL

       Actuator自动为微服务创建一系列的用于监控的端点

       Actuator在SpringBoot自带，SpringCloud进行扩展

       pom.xml依赖spring-boot-starter-actuator

       RestTemplate+@LoadBalanced显式调用

       OpenFeign隐藏微服务间通信细节

       Ribbon是RestTemplate与OpenFeign的通信基础

       Feign是一个开源声明式WebService客户端，用于简化服务通信

       Feign采用“接口+注解”方式开发，屏蔽了网络通信的细节

       OpenFeign是SpringCloud对Feign的增强，支持SpringMVC注解

       1.新建SpringbootWeb项目，applicationname为product-service

       åœ¨pom.xml中引入依赖

       spring-cloud-starter-alibaba-nacos-discovery作用为向Nacosserver注册服务。

       spring-cloud-starter-openfeign作用为实现服务调用。

       2.修改application.yml配置文件

       3.在启动类上添加@EnableDiscoveryClient、@EnableFeignClients注解

       4.编写OrderClientInterface

       æ³¨ï¼š/api/v1/order/test会在下面order-service声明。

       OrderClient.java

       5.编写Controller和service

       ProductController.java

       ProductService.java

       1.OpenFeign开启通信日志

       åŸºäºŽSpringBoot的logback输出,默认debug级别

       è®¾ç½®é¡¹ï¼šfeign.client.config.微服务id.loggerLevel

       å¾®æœåŠ¡id：default代表全局默认配置

       2.通信日志输出格式

       NONE:不输出任何通信日志

       BASIC:只包含URL、请求方法、状态码、执行时间

       HEADERS：在BASIC基础上，额外包含请求与响应头

       FULL：包含请求与响应内容最完整的信息

       3.OpenFeign日志配置项

       LoggerLevel开启通信日志

       ConnectionTimeout与ReadTimeout

       åˆ©ç”¨pose在Docker容器中创建和执行流水线。易于安装，适合企业，但缺乏某些功能，需要额外定制。

       GoCD是一个开源持续集成服务器，提供动态工作流程可视化，支持并行和顺序执行，允许部署任何版本。拥有活跃的社区支持。

       TeamCity是JetBrains的CI/CD工具，允许在提交代码前构建、springxml编程源码监控和运行自动化测试，保持代码库清洁。提供全面的VCS集成，支持Amazon EC2、Microsoft Azure和VMware vSphere集成。

       Buildkite是一个开源平台，提供CI流水线运行、代码控制集成和聊天功能，允许通过Web平台监视和控制所有流水线。但可能缺少一些DevOps流程，如源代码管理和安全测试。

       Zuul是一款开源CI工具，解决了Jenkins在CI测试方面的局限性。它能够跨多个存储库测试代码，执行速度快，对于企业级组织处理新更改非常有帮助。刀空源码

       综上所述，Jenkins虽然在许多开发团队中仍被使用，但并非唯一的持续集成解决方案。在追求更高效、更灵活的工作方式时，探索和采用不同的工具和技术是必要的。在使用传统方法的同时，不应忽视创新的重要性。选择适合自身需求的工具将有助于简化工作流程、加速开发周期并确保代码质量。

Spring Cloud实战小贴士：Zuul统一异常处理（二）

       在探讨Spring Cloud和Zuul的异常处理机制时，我们需要关注几个关键点，以便对现有方案进行优化和完善。在《Spring Cloud实战小贴士：Zuul统一异常处理（一）》中，我们了解了两种基本的异常处理方法：通过在过滤器中加入try-catch块来实现内部异常处理，以及利用error类型过滤器的生命周期特性，集中处理pre、route、post阶段的异常信息。通常，这两种方法可以结合使用，其中try-catch块是开发者的必备技能，而集中处理异常是对其的一种补充，以避免意外情况的发生。然而，深入分析和实践后，我们发现这些方案仍然存在不足之处。

       下面，我们将通过源码分析来揭示这些不足之处，并探讨如何进行进一步优化。在Zuul处理外部请求的流程中，我们注意到存在三个try-catch块分别对应pre、route、post三个阶段的过滤器调用。在这些catch块中，异常信息会被由error类型过滤器集中处理。然而，对于post阶段的异常，在error过滤器处理后，就没有其他过滤器能接手，这正是之前提到的不足之一。

       回顾之前实现的两种异常处理方法，它们的核心在于在异常处理时添加了一系列error.*参数，这些参数在post阶段的SendErrorFilter中被消费以组织内容返回给客户端。问题在于，当post阶段抛出异常时，这些error.*参数不会被SendErrorFilter消费，导致日志中没有异常信息，且请求响应内容为空。为了解决这一问题，我们可以通过修改ThrowExceptionFilter的filterType设置为post，然后移除try-catch块的异常处理逻辑，让它能够抛出异常。

       然而，直接在error过滤器中组织结果返回的方案存在代码重复的问题，不利于日后的代码维护。为了保持对异常返回处理逻辑的一致性，我们希望将post过滤器抛出的异常交给SendErrorFilter处理。因此，我们首先实现了ErrorFilter来捕获pre、route、post过滤器抛出的异常，并将相关参数保存到请求上下文中。然后，为了适应post过滤器抛出异常的情况，我们继续使用SendErrorFilter，并对其进行一些调整，让它在处理post过滤器异常时能够复用原有逻辑，具体实现如下：

       在实现过程中，我们面临如何判断异常是由哪个阶段的过滤器抛出的问题。为了解决这个问题，我们可以通过记录抛出异常的过滤器实例，然后在ErrorExtFilter过滤器的shouldFilter方法中获取该信息，以此判断异常是否来自post阶段的过滤器。通过扩展processZuulFilter(ZuulFilter filter)方法，我们可以在过滤器执行抛出异常时捕获异常并记录相关信息。接着，完善ErrorExtFilter的shouldFilter()方法，利用请求上下文中的信息作出正确的判断。

       最后，为了使优化后的过滤器处理逻辑生效，我们需要在应用主类中调用FilterProcessor.setProcessor(new DidiFilterProcessor())方法来启用自定义的核心处理器。通过这些步骤，我们不仅能够优化异常处理机制，还能确保整个应用在异常处理方面更加完善和可靠。

gateway和zuul的区别与联系

       gateway和zuul的区别与联系体现在性能、源代码维护组织中。

       1、性能

       spring cloud Gateway有一个全新的非堵塞的函数式Reactive Web框架，可以用来构建异步的、非堵塞的、事件驱动的服务，在伸缩性方面表现非常好，使用非阻塞API，Websockets得到支持，并且由于它与Spring紧密集成。Zuul是一个基于阻塞io的API Gateway，Zuul已经发布了Zuul2.x，基于Netty，也是非阻塞的，支持长连接，但Spring Cloud暂时还没有整合计划。

       2、源代码维护组织

       spring cloud Gateway是spring旗下spring cloud的一个子项目。还有一种说法是因为zuul2连续跳票和zuul1的性能表现不是很理想，所以催生了spring孵化Gateway项目。zuul则是netf1ix公司的项目，只是spring将zuul集成在spring cloud中使用而已。关键目前spring不打算集成zuul2.x。

Spring Cloud Gateway中几个重要的概念：

       1、路由：路由是网关最基础的部分，路由信息有一个ID、一个目的URL、一组断言和一组Filter组成。如果断言路由为真，则说明请求的URL和配置匹配。

       2、断言：匹配的规则。Java8中的断言函数。Spring Cloud Gateway中的断言函数输入类型是Spring5.0框架中的ServerWebExchange。Spring Cloud Gateway中的断言函数允许开发者去定义匹配来自于httprequest中的任何信息，比如请求头和参数等。

       3、过滤器：一个标准的Spring webFilter。Spring cloud gateway中的filter分为两种类型的Filter，分别是Gateway Filter和Global Filter。过滤器Filter将会对请求和响应进行修改处理。