5.1 微服务网关简介
第三章我们介绍了通过Spring Cloud LoadBalancer实现了微服务之间的调⽤和负载均衡，以及使⽤Spring Cloud OpenFeign声明式调⽤，那我们的各种微服务⼜要如何提供给外部应⽤调⽤呢？
当然，因为是REST API接⼝，外部客户端直接调⽤各个微服务是没有问题的。但出于种种原因，这并不是⼀个好的选择。让客户端直接与各个微服务通讯，会存在以下⼏个问题。
客户端会多次请求不同的微服务，增加了客户端的复杂性。
存在跨域请求，在⼀定场景下处理会变得相对⽐较复杂。
实现认证复杂，每个微服务都需要独⽴认证。
难以重构，项⽬迭代可能导致微服务重新划分。如果客户端直接与微服务通讯，那么重构将会很难实施。
如果某些微服务使⽤了防⽕墙、浏览器不友好的协议，直接访问会有⼀定困难。
面对类似上⾯的问题，我们要如何解决呢？答案就是：服务⽹关！在微服务系统中微服务资源⼀般不直接暴露给我外部客户端访问，这样做的好处是将内部服务隐藏起来，从⽽解决上述问题。
网关有很多重要的意义，具体体现在下⾯⼏个⽅⾯。
⽹关可以做⼀些身份认证、权限管理、防⽌⾮法请求操作服务等，对服务起⼀定保护作⽤。
⽹关将所有微服务统⼀管理，对外统⼀暴露，外界系统不需要知道微服务架构个服务相互调⽤的复杂性，同时也避免了内部服务⼀些敏感信息泄露问题。
易于监控。可在微服务⽹关收集监控数据并将其推送到外部系统进⾏分析。
客户端只跟服务⽹关打交道，减少了客户端与各个微服务之间的交互次数。
多渠道⽀持，可以根据不同客户端（WEB端、移动端、桌⾯端...）提供不同的API服务⽹关。
⽹关可以⽤来做流量监控。在⾼并发下，对服务限流、降级。
⽹关把服务从内部分离出来，⽅便测试。
微服务⽹关能够实现，路由、负载均衡等多种功能。类似Nginx，反向代理的功能。在微服务架构中，后端服务往往不直接开放给调⽤端，⽽是通过⼀个API⽹关根据请求的URL，路由到相应的服务。当添加API⽹关后，在第三⽅调⽤端和服务提供⽅之间就创建了⼀⾯墙，在API⽹关中进⾏权限控制，同时API⽹关将请求以负载均衡的⽅式发送给后端服务。
5.2 Spring Cloud Gateway简介
5.2.1 简介
SpringCloud Gateway 是 Spring Cloud 的⼀个全新项⽬，该项⽬是基于 Spring 5.0，Spring Boot 2.0 和 Project Reactor 等技术开发的⽹关，它旨在为微服务架构提供⼀种简单有效的统⼀的 API 路由管理⽅式。
SpringCloud Gateway 作为 Spring Cloud ⽣态系统中的⽹关，⽬标是替代 Zuul，在Spring Cloud 2.0以上版本中，没有对新版本的Zuul 2.0以上最新⾼性能版本进⾏集成，仍然还是使⽤的Zuul 2.0之前的⾮Reactor模式的⽼版本。⽽为了提升⽹关的性能，SpringCloud Gateway是基于WebFlux框架实现的，⽽WebFlux框架底层则使⽤了⾼性能的Reactor模式通信框架Netty。
Spring Cloud Gateway 的⽬标，不仅提供统⼀的路由⽅式，并且基于 Filter 链的⽅式提供了⽹关基本的功能，例如：安全，监控/指标，和限流。
注意：Spring Cloud Gateway 底层使⽤了⾼性能的通信框架Netty。
5.2.2 特征
SpringCloud官⽅，对SpringCloud Gateway 特征介绍如下：
基于 Spring Framework 5，Project Reactor 和 Spring Boot 2.0
集成 Spring Cloud DiscoveryClient
Predicates 和 Filters 作⽤于特定路由，易于编写的 Predicates 和 Filters
具备⼀些⽹关的⾼级功能：动态路由、限流、路径重写
集成Spring Cloud DiscoveryClient
集成熔断器CircuitBreaker
从以上的特征来说，和Zuul的特征差别不⼤。SpringCloud Gateway和Zuul主要的区别，还是在底层的通信框架上。
简单说明⼀下上⽂中的三个术语：
（1）Filter（过滤器）：
和Zuul的过滤器在概念上类似，可以使⽤它拦截和修改请求，并且对下游的响应，进⾏⼆次处理。 过滤器为org.springframework.cloud.gateway.filter.GatewayFilter类的实例。
（2）Route（路由）：
网关配置的基本组成模块，和Zuul的路由配置模块类似。⼀个Route模块由⼀个 ID，⼀个⽬标 URI，⼀组断⾔和⼀组过滤器定义。如果断⾔为真，则路由匹配，目标URI会被访问。
（3）Predicate（断⾔）：
这是⼀个 Java 8 的 Predicate，可以使⽤它来匹配来⾃ HTTP 请求的任何内容，例如 headers 或参数。断⾔的输⼊类型是⼀个 ServerWebExchange。
5.2.3 入门案例
创建微服务⽹关⼯程05_cloud_gateway。
1.添加依赖
添加依赖Eureka Discovery Client，Spring Cloud Gateway。
pom.xml完整代码如下。
<?xml version="1.0" encoding="UTF-8"?><project xmlns="/POM/4.0.0"xmlns:xsi="/2001/XMLSchema-instance"xsi:schemaLocation="/POM/4.0.0/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.4.9</version><relativePath/> <!-- lookup parent from repository --></parent><groupId>com.lxs.demo</groupId><artifactId>05_cloud_gateway</artifactId><version>0.0.1-SNAPSHOT</version><name>05_cloud_gateway</name><description>Demo project for Spring Boot</description><properties><java.version>1.8</java.version><spring-cloud.version>.0.3</spring-cloud.version></properties><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-gateway</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</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><dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>${spring-cloud.version}</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId><configuration><excludes><exclude><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></exclude></excludes></configuration></plugin></plugins></build></project>
2.启动器
@SpringBootApplication@EnableDiscoveryClientpublic class GatewayApplication {public static void main(String[] args) {SpringApplication.run(GatewayApplication.class, args);}}
3.配置⽂件
application.yml代码如下。
server: port: 9005 spring: application: name: api-gateway cloud: gateway: routes: - id: url-proxy-1 uri: predicates: - Path=/csdn eureka: client: service-url: defaultZone: http://127.0.0.1:9004/eureka
4.启动并测试
启动Eureka Server和⽹关微服务访问http://localhost:9005/csdn，发现路由到了CSDN博客 - 专业IT技术发表平台
5.2.4 处理流程
客户端向 Spring Cloud Gateway 发出请求。然后在 Gateway Handler Mapping 中找到与请求相匹配的路由，将其发送到 Gateway Web Handler。Handler 再通过指定的过滤器链来将请求发送到我们实际的服务执⾏业务逻辑，然后返回。过滤器之间⽤虚线分开是因为过滤器可能会在发送代理请求之前（“pre”）或之后（“post”）执⾏业务逻辑。如图所示。
5.3 路由配置⽅式
路由是⽹关配置的基本组成模块，和Zuul的路由配置模块类似。⼀个Route模块由⼀个 ID，⼀个⽬标 URI，⼀组断⾔和⼀组过滤器定义。如果断⾔为真，则路由匹配，⽬标URI会被访问。
5.3.1 基础路由配置方式
如果请求的目标地址，是单个的URI资源路径，配置⽂件实例如下。
spring: application: name: api-gateway cloud: gateway: routes: - id: service1 uri: predicates: - Path=/csdn
各字段含义如下。
id：我们⾃定义的路由 ID，保持唯⼀
uri：⽬标服务地址
predicates：路由条件，Predicate 接受⼀个输⼊参数，返回⼀个布尔值结果。该接⼝包含多种默认⽅法来将 Predicate 组合成其他复杂的逻辑（⽐如：与，或，非）。
上⾯这段配置的意思是，配置了⼀个 id 为 url-proxy-1的URI代理规则，路由的规则为，当访问地址 http://localhost:8080/csdn/1.jsp时，会路由到上游地址/1.jsp。
5.3.2 基于代码的路由配置⽅式
转发功能同样可以通过代码来实现，我们可以在启动类 GateWayApplication 中添加方法 customRouteLocator() 来定制转发规则。
@SpringBootApplication@EnableDiscoveryClientpublic class GatewayApplication {public static void main(String[] args) {SpringApplication.run(GatewayApplication.class, args);}@Beanpublic RouteLocator customRouteLocator(RouteLocatorBuilder builder) {return builder.routes().route("path_route", r -> r.path("/csdn").uri("")).build();}}
5.3.3 和注册中⼼相结合的路由配置⽅式
在uri的schema协议部分为⾃定义的lb:类型，表示从微服务注册中⼼（如Eureka）订阅服务，并且通过负载均衡进⾏服务的路由。代码如下。
server: port: 9005 spring: application: name: api-gateway cloud: gateway: routes: - id: service1 uri: predicates: - Path=/csdn - id: service2 # uri: http://127.0.0.1:9001 uri: lb://cloud-payment-service predicates: - Path=/payment/** eureka: client: service-url: defaultZone: http://127.0.0.1:9004/eureka
注册中⼼相结合的路由配置⽅式，与单个URI的路由配置，区别其实很⼩，仅仅在于URI的 schema协议不同。单个URI的地址的schema协议，⼀般为http或者https协议。启动多个⽀付微服务，会发现端⼝9000,9001轮流出现。
5.4 路由匹配规则
Spring Cloud Gateway的主要功能之⼀是转发请求，转发规则的定义主要包含三个部分。
Spring Cloud Gateway 的功能很强⼤，我们仅仅通过 Predicates 的设计就可以看出来，前⾯我们只是使⽤了 predicates 进⾏了简单的条件匹配，其实 Spring Cloud Gataway 帮我们内置了很多Predicates 功能。
Spring Cloud Gateway 是通过 Spring WebFlux 的 HandlerMapping 做为底层⽀持来匹配到转发路由，Spring Cloud Gateway 内置了很多 Predicates ⼯⼚，这些 Predicates ⼯⼚通过不同的 HTTP 请求参数来匹配，多个 Predicates ⼯⼚可以组合使⽤。
5.4.1 Predicate 断⾔条件
Predicate 来源于 Java 8，是 Java 8 中引⼊的⼀个函数，Predicate 接受⼀个输⼊参数，返回⼀个布尔值结果。该接⼝包含多种默认⽅法来将 Predicate 组合成其他复杂的逻辑（⽐如：与，或，⾮）。可以⽤于接⼝请求参数校验、判断新⽼数据是否有变化需要进⾏更新操作。
在 Spring Cloud Gateway 中 Spring 利⽤ Predicate 的特性实现了各种路由匹配规则，有通过Header、请求参数等不同的条件来进⾏作为条件匹配到对应的路由。⽹上有⼀张图总结了 Spring Cloud 内置的⼏种 Predicate 的实现。
说白了 Predicate 就是为了实现⼀组匹配规则，⽅便让请求过来找到对应的 Route 进⾏处理，接下来我们接下 Spring Cloud GateWay 内置⼏种 Predicate 的使⽤。转发规则（predicates），假设转发uri都设定为http://localhost:9001，常⻅Predicate
1.通过请求参数匹配
Query Route Predicate ⽀持传⼊两个参数，⼀个是属性名⼀个为属性值，属性值可以是正则表达式。
spring: cloud: gateway: routes: - id: service3 uri: order: 0 predicates: - Query=smile
这样配置，只要请求中包含 smile 属性的参数即可匹配路由。使⽤ curl 测试，命令⾏输⼊：curl localhost:9005?smile=x&id=2，经过测试发现只要请求汇总带有 smile 参数即会匹配路由，不带 smile 参数则不会匹配。
还可以将 Query 的值以键值对的⽅式进⾏配置，这样在请求过来时会对属性值和正则进⾏匹配，匹配上才会⾛路由。
spring: cloud: gateway: routes: - id: service3 uri: order: 0 predicates: - Query=keep, pu.
这样只要当请求中包含 keep 属性并且参数值是以 pu 开头的⻓度为三位的字符串才会进⾏匹配和路由。
使⽤ curl 测试，命令⾏输⼊：curl localhost:8080?keep=pub，测试可以返回⻚⾯代码，将 keep 的属性值改为 pubx 再次访问就会报 404，证明路由需要匹配正则表达式才会进⾏路由。
2.通过Header匹配
Header Route Predicate 和 Query Route Predicate ⼀样，也是接收 2 个参数，⼀个 header 中属性名称和⼀个正则表达式，这个属性值和正则表达式匹配则执行。
spring: cloud: gateway: routes: - id: service4 uri: order: 0 predicates: - Header=X-Request-Id, \d+
使⽤ curl 测试，命令⾏输⼊：curl http://localhost:9005 -H "X-Request-Id:88"，则返回⻚⾯代码证明匹配成功。将参数-H "X-Request-Id:88"改为-H "X-Request-Id:spring"，再次执⾏时返回 404证明没有匹配。
3.通过Cookie匹配
Cookie Route Predicate 可以接收两个参数，⼀个是 Cookie name ,⼀个是正则表达式，路由规则会通过获取对应的 Cookie name 值和正则表达式去匹配，如果匹配上就会执⾏路由，如果没有匹配上则不执⾏。
spring:cloud:gateway:routes:- id: service5uri: predicates:- Cookie=sessionId, test
使⽤ curl 测试，命令⾏输⼊，curl http://localhost:9005 --cookie "sessionId=test"，则会返回⻚⾯代码，如果去掉--cookie "sessionId=test"，后台汇报 404 错误。
4.通过Host匹配
Host Route Predicate 接收⼀组参数，⼀组匹配的域名列表，这个模板是⼀个 ant 分隔的模板，⽤.号作为分隔符。它通过参数中的主机地址作为匹配规则。
spring:cloud:gateway:routes:- id: service6uri: predicates:- Host=**.
使⽤ curl 测试，命令⾏输⼊，curl http://localhost:9005 -H "Host: "或者curl http://localhost:8080 -H "Host: "，经测试以上两种 host 均可匹配到 host_route 路由，去掉 host 参数则会报 404 错误。
5.通过请求⽅式匹配
可以通过是 POST、GET、PUT、DELETE 等不同的请求⽅式来进⾏路由。
spring: cloud: gateway: routes: - id: service7 uri: predicates: - Method=PUT
使⽤ curl 测试，命令⾏输⼊，curl -X PUT http://localhost:9005，测试返回⻚⾯代码，证明匹配到路由，以其他⽅式，返回 404 没有找到，证明没有匹配上路由
6.通过请求路径匹配
Path RoutePredicate 接收⼀个匹配路径的参数来判断是否路由。
spring: cloud: gateway: routes: - id: service8 uri: http://127.0.0.1:9001 predicates: - Path=/payment/{segment}
如果请求路径符合要求，则此路由将匹配， curl 测试，命令行输⼊，curl http://localhost:9005/payment/1，可以正常获取到⻚⾯返回值，curl http://localhost:9005/payment2/1，报404，证明路由是通过指定路由来匹配。
7.组合匹配
spring: cloud: gateway: routes: - id: service9 uri: order: 0 predicates: - Host=**. - Path=/headers - Method=GET - Header=X-Request-Id, \d+ - Query=foo, ba. - Query=baz - Cookie=chocolate, ch.p
各种 Predicates 同时存在于同⼀个路由时，请求必须同时满⾜所有的条件才被这个路由匹配。 ⼀个请求满⾜多个路由的断⾔条件时，请求只会被⾸个成功匹配的路由转发列举⼏个过滤器。
5.4.2 过滤器规则
1.PrefixPath
对所有的请求路径添加前缀
spring: cloud: gateway: routes: - id: service10 uri: http://127.0.0.1:9001 predicates: - Path=/{segment} filters: - PrefixPath=/payment
访问/123请求被发送到http://127.0.0.1:9001/payment/123。
2.StripPrefix
跳过指定的路径
spring: cloud: gateway: routes: - id: service11 uri: http://127.0.0.1:9001 predicates: - Path=/api/{segment} filters: - StripPrefix=1 - PrefixPath=/payment
此时访问http://localhost:9005/api/123，⾸先StripPrefix过滤器去掉⼀个/api，然后PrefixPath 过滤器加上⼀个/payment，能够正确访问到⽀付微服务。
3.RewritePath
spring: cloud: gateway: routes: - id: service12 uri: http://127.0.0.1:9001 predicates: - Path=/api/payment/** filters: - RewritePath=/api/(?<segment>.*), /$\{segment}
请求http://localhost:9005/api/payment/123路径，RewritePath过滤器将路径重写为 http://localhost:9005/payment/123，能够正确访问⽀付微服务。
4.SetPath
SetPath和Rewrite类似，代码如下。
spring: cloud: gateway: routes: - id: service13 uri: http://127.0.0.1:9001 predicates: - Path=/api/payment/{segment} filters: - SetPath=/payment/{segment}
请求http://localhost:9005/api/payment/123路径，SetPath过滤器将路径设置为 http://localhost:9005/payment/123，能够正确访问⽀付微服务。
5. RemoveRequestHeader
去掉某个请求头信息。
spring: cloud: gateway: routes: - id: removerequestheader_route uri: filters: - RemoveRequestHeader=X-Request-Foo
去掉请求头X-Request-Foo
6.RemoveResponseHeader
去掉某个回执头信息
spring:cloud:gateway:routes: #路由配置- id: removerequestheader_route uri: filters: - RemoveResponseHeader=X-Request-Foo
7.RemoveRequestParameter
去掉某个请求参数信息
spring:cloud:gateway:routes: #路由配置- id: removerequestparameter_route uri: filters: - RemoveRequestParameter=red
8.SetRequestHeader
设置请求头信息
spring:cloud:gateway:routes: #路由配置- id: setrequestheader_route uri: filters: - SetRequestHeader=X-Request-Red, Blue
9.default-filters
对所有的请求添加过滤器。
spring:cloud:gateway:routes: #路由配置- id: service14 uri: http://127.0.0.1:9001 predicates: - Path=/9001/{segment} - id: service15 uri: http://127.0.0.1:9000 predicates: - Path=/9000/{segment} default-filters: - StripPrefix=1 - PrefixPath=/payment
5.5 自定义过滤器
5.5.1 过滤器执⾏次序
Spring-Cloud-Gateway 基于过滤器实现，同 zuul 类似，有pre和post两种⽅式的 filter,分别处理前置逻辑和后置逻辑。客户端的请求先经过pre类型的 filter，然后将请求转发到具体的业务服务，收到业务服务的响应之后，再经过post类型的 filter 处理，最后返回响应到客户端。
过滤器执⾏流程如下，order 越⼤，优先级越低。
过滤器分为全局过滤器和局部过滤器。
全局过滤器：对所有路由⽣效。局部过滤器：对指定的路由⽣效。
5.5.2 全局过滤器
实现 GlobalFilter 和 Ordered，重写相关⽅法，加⼊到spring容器管理即可，⽆需配置，全局过滤器对所有的路由都有效。代码如下。
/*** 全局过滤器*///@Configuration@Slf4jpublic class FilterConfig {@Beanpublic GlobalFilter a() {return new AFilter();}@Beanpublic GlobalFilter b() {return new BFilter();}@Beanpublic GlobalFilter c() {return new CFilter();}@Beanpublic GlobalFilter myFilter() {return new MyAuthFilter();}static class AFilter implements GlobalFilter, Ordered {@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {log.info("AFilter前置逻辑");return chain.filter(exchange).then(Mono.fromRunnable(() -> {log.info("AFilter后置逻辑");})); //过滤器链，不执行会停止在这}//优先级@Overridepublic int getOrder() {return HIGHEST_PRECEDENCE + 100; //值越小请求级别越高}}static class BFilter implements GlobalFilter, Ordered {@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {log.info("BFilter前置逻辑");return chain.filter(exchange).then(Mono.fromRunnable(() -> {log.info("BFilter后置逻辑");})); //过滤器链，不执行会停止在这}//优先级@Overridepublic int getOrder() {return HIGHEST_PRECEDENCE + 200;}}static class CFilter implements GlobalFilter, Ordered {@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {log.info("CFilter前置逻辑");return chain.filter(exchange).then(Mono.fromRunnable(() -> {log.info("CFilter后置逻辑");})); //过滤器链，不执行会停止在这}//优先级@Overridepublic int getOrder() {return HIGHEST_PRECEDENCE + 300;}}static class MyAuthFilter implements GlobalFilter, Ordered {@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {log.info("MyAuthFilter过滤器执行");String token = exchange.getRequest().getHeaders().getFirst("token");if (StringUtils.isBlank(token)) {exchange.getResponse().setStatusCode(HttpStatus.UNAUTHORIZED);return exchange.getResponse().setComplete();}return chain.filter(exchange);}@Overridepublic int getOrder() {return HIGHEST_PRECEDENCE + 400;}}}
定义了4个全局过滤器，顺序为A>B>C>MyAuthFilter，其中全局过滤器MyAuthFilter中判断令牌是否存在，如果令牌不存在，则返回401状态码，表示没有权限访问，使⽤Postman执⾏请求。
5.5.3 局部过滤器
定义局部过滤器步骤如下。
（1）需要实现GatewayFilter, Ordered，实现相关的⽅法
（2）加⼊到过滤器⼯⼚，并且注册到spring容器中。
（3）在配置⽂件中进⾏配置，如果不配置则不启⽤此过滤器规则。
接下来定义局部过滤器，对于请求头user-id校验，如果不存在user-id请求头，直接返回状态码406。 代码如下。
@Component@Slf4jpublic class UserIdCheckGatewayFilterFactory extends AbstractGatewayFilterFactory<Object> {@Overridepublic GatewayFilter apply(Object config) {return new UserIdCheckGatewayFilter();}static class UserIdCheckGatewayFilter implements GatewayFilter, Ordered {@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {String url = exchange.getRequest().getPath().pathWithinApplication().value();log.info("请求url:" + url);log.info("请求method:" + exchange.getRequest().getMethod());//获取请求头String userId = exchange.getRequest().getHeaders().getFirst("user-id");if (StringUtils.isBlank(userId)) {log.info("user-id请求头不能为空");exchange.getResponse().setStatusCode(HttpStatus.NOT_ACCEPTABLE);return exchange.getResponse().setComplete();}return chain.filter(exchange);}@Overridepublic int getOrder() {return HIGHEST_PRECEDENCE;}}}
配置⽂件application.yml代码如下。
spring:application:name: api-gatewaycloud:gateway:routes: #路由配置- id: service15uri: lb://cloud-payment-servicepredicates:- Path=/{segment}default-filters:- PrefixPath=/payment- UserIdCheck
5.6 高级特性
5.6.1 熔断降级
在分布式系统中，⽹关作为流量的⼊⼝，因此会有⼤量的请求进⼊⽹关，向其他服务发起调⽤，其他服务不可避免的会出现调⽤失败（超时、异常），失败时不能让请求堆积在网关上，需要快速失败并返回给客户端，想要实现这个要求，就必须在⽹关上做熔断、降级操作。
为什么在⽹关上请求失败需要快速返回给客户端？因为当⼀个客户端请求发⽣故障的时候，这个请求会⼀直堆积在⽹关上，当然只有⼀个这种请求，⽹关肯定没有问题（如果⼀个请求就能造成整个系统瘫痪，那这个系统可以下架了），但是⽹关上堆积多了就会给⽹关乃⾄整个服务都造成巨⼤的压⼒，甚⾄整个服务宕掉。因此要对⼀些服务和⻚⾯进⾏有策略的降级，以此缓解服务器资源的的压⼒，以保证核⼼业务的正常运⾏，同时也保持了客户和⼤部分客户的得到正确的相应，所以需要⽹关上请求失败需要快速返回给客户端。
CircuitBreaker过滤器使⽤Spring Cloud CircuitBreaker API 将⽹关路由包装在断路器中。Spring Cloud CircuitBreaker ⽀持多个可与 Spring Cloud Gateway ⼀起使⽤熔断器库。⽐如，Spring Cloud ⽀持开箱即⽤的 Resilience4J。
要启⽤Spring Cloud CircuitBreaker过滤器，步骤如下。
1. 添加依赖
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-circuitbreaker-reactor- resilience4j</artifactId> </dependency>
2. 配置⽂件
server:port: 9005spring:application:name: api-gatewaycloud:gateway:routes: #路由配置- id: service16uri: lb://cloud-payment-servicepredicates:- Path=/payment/{segment} # Path会自动加在uri的后面filters:- name: CircuitBreakerargs:name: backendAfallbackUri: forward:/fallbackAeureka:client:service-url:defaultZone: http://127.0.0.1:9004/eurekaresilience4j:circuitbreaker:configs:default:failureRateThreshold: 30 #失败请求百分⽐，超过这个⽐例，CircuitBreaker变为 OPEN状态slidingWindowSize: 10 #滑动窗⼝的⼤⼩，配置COUNT_BASED,表示10个请求，配置 TIME_BASED表示10秒minimumNumberOfCalls: 5 #最⼩请求个数，只有在滑动窗⼝内，请求个数达到这个个 数，才会触发CircuitBreader对于断路器的判断slidingWindowType: TIME_BASED #滑动窗⼝的类型permittedNumberOfCallsInHalfOpenState: 3 #当CircuitBreaker处于 HALF_OPEN状态的时候，允许通过的请求个数automaticTransitionFromOpenToHalfOpenEnabled: true #设置true，表示⾃动从 OPEN变成HALF_OPEN，即使没有请求过来waitDurationInOpenState: 2s #从OPEN到HALF_OPEN状态需要等待的时间recordExceptions: #异常名单- java.lang.Exceptioninstances:backendA:baseConfig: defaultbackendB:failureRateThreshold: 50slowCallDurationThreshold: 2s #慢调⽤时间阈值，⾼于这个阈值的呼叫视为慢调⽤， 并增加慢调⽤⽐例。slowCallRateThreshold: 30 #慢调⽤百分⽐阈值，断路器把调⽤时间⼤于 slowCallDurationThreshold，视为慢调⽤，当慢调⽤⽐例⼤于阈值，断路器打开，并进⾏服务降级slidingWindowSize: 10slidingWindowType: TIME_BASEDminimumNumberOfCalls: 2permittedNumberOfCallsInHalfOpenState: 2waitDurationInOpenState: 120s #从OPEN到HALF_OPEN状态需要等待的时间
3. 全局过滤器
创建⼀个全局过滤器，打印熔断器状态，代码如下
/*** 局部过滤器，需要引用*/@Component@Slf4jpublic class CircuitBreakerLogFilter implements GlobalFilter, Ordered {@Autowiredprivate CircuitBreakerRegistry circuitBreakerRegistry;@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {String url = exchange.getRequest().getPath().pathWithinApplication().value();String status = circuitBreakerRegistry.circuitBreaker("backendA").getState().toString();//log.info("url : {} , status : {}", url, status);return chain.filter(exchange);}@Overridepublic int getOrder() {return HIGHEST_PRECEDENCE;}}
4.降级方法
@RestController@Slf4jpublic class FallbackController {@Autowiredprivate CircuitBreakerRegistry circuitBreakerRegistry;@GetMapping("fallbackA")public ResponseEntity fallback() {String status = circuitBreakerRegistry.circuitBreaker("backendA").getState().toString();log.info("status : " + status);return ResponseEntity.ok("服务不可用，降级");}}
使⽤JMeter⼯具同时1秒内并发发送20次请求，触发断路器backendA熔断条件，断路器打开，之后2秒后熔断器⾃动进⼊进⼊半开状态（automaticTransitionFromOpenToHalfOpenEnabled: true，waitDurationInOpenState: 2s），如图所示。
接下来2秒后再次请求熔断器处于半开状态，接下来启动⽀付微服务，服务能够正常访问熔断器关闭。
5.6.2 统⼀跨域请求
1. 跨域简介
跨域请求就是指：当前发起请求的域与该请求指向的资源所在的域不⼀样。这⾥的域指的是这样的⼀个概念：我们认为若协议 + 域名 + 端⼝号均相同，那么就是同域。
举个例⼦：假如⼀个域名为的⽹站，它发起⼀个资源路径为/books/getBookInfo的 Ajax 请求，那么这个请求是同域的，因为资源路径的协议、域名以及端⼝号与当前域⼀致（例⼦中协议名默认为http，端⼝号默认为80）。但是，如果发起⼀个资源路径为/pay/purchase的 Ajax 请求，那么这个请求就是跨域请求，因为域不⼀致，与此同时由于安全问题，这种请求会受到同源策略限制。
演示⼀下，创建index.html，发送ajax测试跨域，代码如下所示。
<!DOCTYPE html><html lang="en"><head><meta charset="UTF-8"><title>Title</title><script type="text/javascript" src="./js/jquery-1.6.js"></script><script> function sendAjax() {$.ajax({method: 'GET',url: "http://localhost:9005/payment/123",contentType: 'application/json; charset=UTF-8',success: function (o) {alert(o.id);alert(o.message);}});} </script></head><body><button onclick="sendAjax();">send ajax</button></body></html>
通过上述index.html，发送请求，因为浏览器同源策略，就会出现跨域访问问题。虽然在安全层⾯上同源限制是必要的，但有时同源策略会对我们的合理⽤途造成影响，为了避免开发的应⽤受到限制，有多种⽅式可以绕开同源策略，常⽤的做法JSONP, CORS。可以使⽤ @CrossOrigin，代码如下。
@RestController @RequestMapping("/payment") @CrossOrigin public class PaymentController { @Value("${server.port}") private String serverPort; @GetMapping("/{id}") public ResponseEntity<Payment> payment(@PathVariable("id") Integer id) { Payment payment = new Payment(id, "⽀付成功，服务端⼝=" + serverPort); return ResponseEntity.ok(payment); } }
2. 跨域配置
现在请求经过gatway⽹关是，可以通过⽹关统⼀配置跨域访问，代码如下。
spring:cloud:gateway: globalcors:cors-configurations:'[/**]':allowed-origin-patterns: "*" # spring boot 2.4配置allowed-headers: "*"allow-credentials: trueallowed-methods:- GET- POST- DELETE- PUT- OPTION
