1. 概述

1.1 为什么需要网关

网关功能：

• 身份认证和权限校验
• 服务路由、负载均衡
• 请求限流

1.2 SpringCloud Gateway

在SpringCloud微服务体系中，有个很重要的组件就是网关，在1.x版本中都是采用的Zuul网关；但在2.x版本中，zuul的升级一直跳票，SpringCloud最后自己研发了一个网关替代Zuul，那就是SpringCloud Gateway
       网上很多地方都说Zuul是阻塞的，Gateway是非阻塞的，这么说是不严谨的，准确的讲Zuul1.x是阻塞的，而在2.x的版本中，Zuul也是基于Netty，也是非阻塞的，如果一定要说性能，其实这个真没多大差距。
而官方出过一个测试项目，创建了一个benchmark的测试项目：
spring-cloud-gateway-bench，其中对比了：

• Spring Cloud Gateway
• Zuul1.x
• Linkerd

Proxy	Avg Latency	Avg Req/Sec/Thread
gateway	6.61ms	3.24k
linkered	7.62ms	2.82k
zuul	12.56ms	2.09k
none	2.09ms	11.77k

还有一点就是Gateway是基于WebFlux的。这里引出了WebFlux名词，那什么是WebFlux？

       左侧是传统的基于Servlet的Spring Web MVC框架，传统的Web框架，比如说：struts2，springmvc等都是基于Servlet API与Servlet容器基础之上运行的，在Servlet3.1之后才有了异步非阻塞的支持。
       右侧是5.0版本新引入的基于Reactive Streams的Spring WebFlux框架，从上到下依次是Router Functions，WebFlux，Reactive Streams三个新组件。
Router Functions: 对标@Controller，@RequestMapping等标准的Spring MVC注解，提供一套函数式风格的API，用于创建Router，Handler和Filter。
WebFlux: 核心组件，协调上下游各个组件提供响应式编程支持。
Reactive Streams: 一种支持背压（Backpressure）的异步数据流处理标准，主流实现有RxJava和Reactor，Spring WebFlux默认集成的是Reactor。
       在Web容器的选择上，Spring WebFlux既支持像Tomcat，Jetty这样的的传统容器（前提是支持Servlet 3.1 Non-Blocking IO API），又支持像Netty，Undertow那样的异步容器。不管是何种容器，Spring WebFlux都会将其输入输出流适配成Flux格式，以便进行统一处理。
       值得一提的是，除了新的Router Functions接口，Spring WebFlux同时支持使用老的Spring MVC注解声明Reactive Controller。和传统的MVC Controller不同，Reactive Controller操作的是非阻塞的ServerHttpRequest和ServerHttpResponse，而不再是Spring MVC里的HttpServletRequest和HttpServletResponse。
根据官方的说法，webflux主要在如下两方面体现出独有的优势：

• 1、非阻塞式
         其实在servlet3.1提供了非阻塞的API，WebFlux提供了一种比其更完美的解决方案。使用非阻塞的方式可以利用较小的线程或硬件资源来处理并发进而提高其可伸缩性
• 2、函数式编程端点
         老生常谈的编程方式了，Spring5必须让你使用java8，那么函数式编程就是java8重要的特点之一，而WebFlux支持函数式编程来定义路由端点处理请求。

2. gateway快速入门

搭建网关服务

搭建网关服务的步骤

1、创建新的module，引入SpringCloudGateway的依赖和nacos的服务发现依赖：

<!--网关依赖-->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-gateway</artifactId>
</dependency>
<!--nacos服务发现依赖-->
<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>

2、编写路由配置和nacos地址

server:port: 10010 # 网关端口
spring:application:name: gateway # 服务名称cloud:nacos:server-addr: localhost:8848 # nacos地址gateway:routes: # 网关路由配置- id: user-service # 路由id，自定义，只要唯一即可# uri: http://127.0.0.1:8081 # 路由的目标地址 http就是固定地址uri: lb://userservice # 路由的目标地址 lb就是负载均衡，后面跟服务名称predicates: # 路由断言，也就是判断请求是否符合路由规则的条件- Path=/user/** # 这个是按照路径匹配，只要以/user/开头就符合要求

3. 断言工厂

路由断言工厂Route Predicate Factory

网关路由可以配置的内容包括：

• 路由id：路由唯一标示
• uri：路由目的地，支持lb和http两种
• predicates：路由断言，判断请求是否符合要求，符合则转发到路由目的地
• filters：路由过滤器，处理请求或响应
• 我们在配置文件中写的断言规则只是字符串，这些字符串会被Predicate Factory读取并处理，转变为路由判断的条件
• 例如Path=/user/**是按照路径匹配，这个规则是由org.springframework.cloud.gateway.handler.predicate.PathRoutePredicateFactory类来处理的
• 像这样的断言工厂在SpringCloudGateway还有十几个

Spring Cloud Gateway官网

名称	说明	示例
After	是某个时间点后的请求	- After=2037-01-20T17:42:47.789-07:00[America/Denver]
Before	是某个时间点之前的请求	- Before=2031-04-13T15:14:47.433+08:00[Asia/Shanghai]
Between	是某两个时间点之前的请求	- Between=2037-01-20T17:42:47.789-07:00[America/Denver], 2037-01-21T17:42:47.789-07:00[America/Denver]
Cookie	请求必须包含某些cookie	- Cookie=chocolate, ch.p
Header	请求必须包含某些header	- Header=X-Request-Id, \d+
Host	请求必须是访问某个host（域名）	- Host=.somehost.org,.anotherhost.org
Method	请求方式必须是指定方式	- Method=GET,POST
Path	请求路径必须符合指定规则	- Path=/red/{segment},/blue/**
Query	请求参数必须包含指定参数	- Query=name, Jack或者- Query=name
RemoteAddr	请求者的ip必须是指定范围	- RemoteAddr=192.168.1.1/24
Weight	权重处理

server:port: 10010 #网关端口
spring:application:name: gateway #服务名称cloud:nacos:server-addr: localhost:10086  #nacos地址gateway:routes:- id: user-service  #路由id，自定义，只要唯一就行
#          uri:  http://localhost:8881   #路由的目标地址，http就是固定地址uri: lb://userservice #路由的目标地址  lb就是负载均衡，后面接服务名称predicates:    #路由断言，也就是判断请求符合路由的规则- Path=/user/**   #这个是按照路由路径匹配，只要以 /user/开头就符合要求- id: order-serviceuri: lb://orderservicepredicates:- Path=/order/**- After=2023-01-20T17:42:47.789-07:00[America/Denver]

4. 过滤器工厂

路由过滤器 GatewayFilter

GatewayFilter是网关中提供的一种过滤器，可以对进入网关的请求和微服务返回的响应做处理：

Spring提供了31种不同的路由过滤器工厂。例如：

名称	说明
AddRequestHeader	给当前请求添加一个请求头
RemoveRequestHeader	移除请求中的一个请求头
AddResponseHeader	给响应结果中添加一个响应头
RemoveResponseHeader	从响应结果中移除有一个响应头
RequestRateLimiter	限制请求的流量
…

给单个微服务添加过滤器

spring:cloud:gateway:routes:- id: add_request_header_routeuri: https://example.orgpredicates:- Path=/red/{segment}filters:- AddRequestHeader=X-Request-Red, Blue-{segment}

默认过滤器

server:port: 10010 #网关端口
spring:application:name: gateway #服务名称cloud:nacos:server-addr: localhost:10086  #nacos地址gateway:routes:- id: user-service  #路由id，自定义，只要唯一就行
#          uri:  http://localhost:8881   #路由的目标地址，http就是固定地址uri: lb://userservice #路由的目标地址  lb就是负载均衡，后面接服务名称predicates:    #路由断言，也就是判断请求符合路由的规则- Path=/user/**   #这个是按照路由路径匹配，只要以 >/user/开头就符合要求
#          filters:
#            - AddRequestHeader=MyHead,jizhibing- id: order-serviceuri: lb://orderservicepredicates:- Path=/order/**- After=2023-01-20T17:42:47.789-07:00[America/Denver]default-filters:- AddRequestHeader=MyHead,jizhibing

@Slf4j
@RestController
@RequestMapping("/user")
public class UserController {@Autowiredprivate UserService userService;/*** 路径： /user/110** @param id 用户id* @return 用户*/@GetMapping("/{id}")public User queryById(@PathVariable("id") Long id,@RequestHeader(value = "MyHead",required = false) String myHead) {System.out.println("MyHead : "+myHead);return userService.queryById(id);}
}

显示效果：

04-23 08:00:03:112  INFO 95612 --- [nio-8880-exec-1] o.a.c.c.C.[Tomcat].[localhost].[/]       : Initializing Spring DispatcherServlet 'dispatcherServlet'
04-23 08:00:03:112  INFO 95612 --- [nio-8880-exec-1] o.s.web.servlet.DispatcherServlet        : Initializing Servlet 'dispatcherServlet'
04-23 08:00:03:116  INFO 95612 --- [nio-8880-exec-1] o.s.web.servlet.DispatcherServlet        : Completed initialization in 4 ms
MyHead : jizhibing
2
04-23 08:00:03:155  INFO 95612 --- [nio-8880-exec-1] com.zaxxer.hikari.HikariDataSource       : HikariPool-1 - Starting...
04-23 08:00:03:331  INFO 95612 --- [nio-8880-exec-1] com.zaxxer.hikari.HikariDataSource       : HikariPool-1 - Start completed.

5. 全局过滤器

全局过滤器 GlobalFilter

全局过滤器的作用也是处理一切进入网关的请求和微服务响应，与GatewayFilter的作用一样。 区别在于GatewayFilter通过配置定义，处理逻辑是固定的。而GlobalFilter的逻辑需要自己写代码实现。 定义方式是实现GlobalFilter接口。

public interface GlobalFilter {   /**   *  处理当前请求，有必要的话通过{@link GatewayFilterChain}将请求交给下一个过滤器处理* @param exchange 请求上下文，里面可以获取Request、Response等信息    * @param chain 用来把请求委托给下一个过滤器     * @return {@code Mono<Void>} 返回标示当前过滤器业务结束    */   Mono<Void> filter(ServerWebExchange exchange, >GatewayFilterChain chain);}

过滤器执行顺序

请求进入网关会碰到三类过滤器：当前路由的过滤器、DefaultFilter、GlobalFilter 请求路由后，会将当前路由过滤器和DefaultFilter、GlobalFilter，合并到一个过滤器链（集合）中，排序后依次执行每个过滤器

• 每一个过滤器都必须指定一个int类型的order值，order值越小，优先级越高，执行顺序越靠前。
• GlobalFilter通过实现Ordered接口，或者添加@Order注解来指定order值，由我们自己指定 路由过滤器和defaultFilter的order由Spring指定，默认是按照声明顺序从1递增。
• 当过滤器的order值一样时，会按照 defaultFilter > 路由过滤器 > GlobalFilter的顺序执行。

可以参考下面几个类的源码来查看：
org.springframework.cloud.gateway.route.RouteDefinitionRouteLocator#getFilters()方法是先加载defaultFilters，然后再加载某个route的filters，然后合并。

   private List<GatewayFilter> getFilters(RouteDefinition routeDefinition) {List<GatewayFilter> filters = new ArrayList();if (!this.gatewayProperties.getDefaultFilters().isEmpty()) {filters.addAll(this.loadGatewayFilters("defaultFilters", new ArrayList(this.gatewayProperties.getDefaultFilters())));}if (!routeDefinition.getFilters().isEmpty()) {>filters.addAll(this.loadGatewayFilters(routeDefinition.getId(), new ArrayList(routeDefinition.getFilters())));}AnnotationAwareOrderComparator.sort(filters);return filters;}

org.springframework.cloud.gateway.handler.FilteringWebHandler#handle()方法会加载全局过滤器，与前面的过滤器合并后根据order排序，组织过滤器链

   public Mono<Void> handle(ServerWebExchange exchange) {Route route = (Route)exchange.getRequiredAttribute(ServerWebExchangeUtils.GATEWAY_ROUTE_ATTR);List<GatewayFilter> gatewayFilters = route.getFilters();List<GatewayFilter> combined = new ArrayList(this.globalFilters);combined.addAll(gatewayFilters);AnnotationAwareOrderComparator.sort(combined);if (logger.isDebugEnabled()) {logger.debug("Sorted gatewayFilterFactories: " + combined);}return (new FilteringWebHandler.DefaultGatewayFilterChain(combined)).filter(exchange);}

网关自定义过滤器

模拟用户登陆权限过滤器

package com.cloud.gateway;import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.core.Ordered;
import org.springframework.core.annotation.Order;
import org.springframework.http.HttpStatus;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.stereotype.Component;
import org.springframework.util.MultiValueMap;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;//@Order(-1)
@Component
public class AuthorizeFilter implements GlobalFilter ,Ordered {@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {//1、获取请求参数ServerHttpRequest request = exchange.getRequest();MultiValueMap<String, String> queryParams = request.getQueryParams();//2、获取请求中的authorization参数String authorization = queryParams.getFirst("authorization");//3、判断参数值是否等于 adminif("admin".equals(authorization)){//4、是 放行return chain.filter(exchange);}//5、否 拦截//5.1设置状态码  401>exchange.getResponse().setStatusCode(HttpStatus.UNAUTHORIZED);//5.2请求拦截return exchange.getResponse().setComplete();}@Overridepublic int getOrder() {return -1;}
}

不加请求头授权信息 authorization

添加请求头授权信息
authorization = admin

6. 跨域问题

跨域问题以及Ajax和Axios的区别

跨域：域名不一致就是跨域，主要包括：

• 域名不同： www.taobao.com 和 www.taobao.org 和 www.jd.com 和 miaosha.jd.com
• 域名相同，端口不同：localhost:8080和localhost：8081

跨域问题：浏览器禁止请求的发起者与服务端发生跨域ajax请求，请求被浏览器拦截的问题的解决方案：CORS
网关处理跨域采用的同样是CORS方案，并且只需要简单配置即可实现：

spring:cloud:gateway:globalcors: # 全局的跨域处理add-to-simple-url-handler-mapping: true # 解决options请求被拦截问题corsConfigurations:'[/**]':allowedOrigins: # 允许哪些网站的跨域请求- "http://localhost:8090"- "http://www.leyou.com"allowedMethods: # 允许的跨域ajax的请求方式- "GET"- "POST"- "DELETE"- "PUT"- "OPTIONS"allowedHeaders: "*" # 允许在请求中携带的头信息allowCredentials: true # 是否允许携带cookiemaxAge: 360000 # 这次跨域检测的有效期

7. 限流过滤器

限流：对应用服务器的请求做限制，避免因过多请求而导致服务器过载甚至宕机。限流算法常见的包括两种：

• 计数器算法，又包括窗口计数器算法、滑动窗口计数器算法
• 漏桶算法(Leaky Bucket)
• 令牌桶算法（Token Bucket）

7.1 限流过滤器-计数器算法

固定窗口计数器算法概念如下：

• 将时间划分为多个窗口；
• 在每个窗口内每有一次请求就将计数器加一，当时间到达下一个窗口时，计数器重置；
• 如果计数器超过了限制数量，则本窗口内所有的请求都被丢弃。
  

7.2 限流过滤器-漏桶算法

漏桶算法说明：

• 将每个请求视作"水滴"放入"漏桶"进行存储；
• "漏桶"以固定速率向外"漏"出请求来执行，如果"漏桶"空了则停止"漏水”；
• 如果"漏桶"满了则多余的"水滴"会被直接丢弃。
  

7.3 限流过滤器-令牌桶算法

漏桶算法说明：

• 以固定的速率生成令牌，存入令牌桶中，如果令牌桶满了以后，多余令牌丢弃
• 请求进入后，必须先尝试从桶中获取令牌，获取到令牌后才可以被处理
• 如果令牌桶中没有令牌，则请求等待或丢弃
  

【微服务】—— 统一网关Gateway相关推荐

1. 微服务---统一网关Gateway

   为什么需要网关 网关的技术实现 总结 搭建网关服务 总结 路由断言工厂Route Perdicate Factory 总结 路由过滤器GatewayFilter 总结 全局过滤器GlobalFilte ...

2. 【微服务技术09】统一网关Gateway

   [微服务技术09]统一网关Gateway 案例代码:https://gitee.com/pikachu2333/spring-cloud-hexuan 1.网关作用 网关功能: 身份认证和权限校验 服 ...

3. gateway动态路由_微服务与网关技术（SIA-GateWay）

   一.背景 软件架构,总是在不断的演进中... 把时间退回到二十年之前,当时企业级领域研发主要推崇的还是C/S模式,PB.Delphi这样的开发软件是企业应用开发的主流.随着时间的推移,基于浏览器的B/ ...

4. 【Spring Cloud Alibaba 实战 | 总结篇】Spring Cloud Gateway + Spring Security OAuth2 + JWT 实现微服务统一认证授权和鉴权

   一. 前言 hi,大家好~ 好久没更文了,期间主要致力于项目的功能升级和问题修复中,经过一年时间这里只贴出关键部分代码的打磨,[有来]终于迎来v2.0版本,相较于v1.x版本主要完善了OAuth2认证 ...

5. 微服务 API 网关架构演进 Spring Cloud Gateway ShenYu APISIX

   目录 后台服务网关 Spring Cloud Gateway 遇到问题 Apache ShenYu Higress fizz-gateway-community 企业案例 前台流量网关 APISIX ...

6. vivo亿级微服务 API 网关架构实践

   一.背景介绍 网关作为微服务生态中的重要一环,由于历史原因,中间件团队没有统一的微服务API网关,为此准备技术预研打造一个功能齐全.可用性高的业务网关. 二.技术选型 常见的开源网关按照语言分类有如下 ...

7. day02 Nacos集群配置、Feign远程调用和统一网关Gateway

   1.Nacos配置管理 Nacos除了可以做注册中心,同样可以做配置管理来使用. 统一配置管理 当微服务部署的实例越来越多,达到数十.数百时,逐个修改微服务配置就会让人抓狂,而且很容易出错.我们需要一 ...

8. 一文吃透何为微服务、网关、服务发现/注册？

   点击上方"Java基基",选择"设为星标" 做积极的人,而不是积极废人! 每天 14:00 更新文章,每天掉亿点点头发... 源码精品专栏 原创 | Java ...

9. 一文吃透何为微服务、网关、服务发现/注册

   Part1序 随着互联网业务复杂性慢慢提高,单机服务的架构慢慢出现了生产效率问题 微服务架构带来的有优点也有缺点,使用前需要调研清楚 微服务架构的网关设计.服务注册/发现.配置管理都是关键点 Part ...

10. 何为微服务、网关、服务发现/注册？

    点击上方"芋道源码",选择"设为星标" 管她前浪,还是后浪? 能浪的浪,才是好浪! 每天 10:33 更新文章,每天掉亿点点头发... 源码精品专栏 原创 | ...

最新文章

1. 建校百年，哈工大计算机学部成立！NLP专家刘挺挑大梁
2. R语言ggplot2可视化绘制多条基本线图（Basic line plot）、使用gghighlight包突出高亮其中的某一条线图（highlight line plot）
3. 让用VS2012/VS2013编写的程序在XP中顺利运行
4. 巧妙设置Android来方便管理Linux和Windows
5. php-Arrays函数-array_flip-交换数组的键值
6. Apollo分布式配置中心踩坑
7. [转]Microsoft Solution Framework 微软解决方案框架结构
8. 是未来的风口还是无声的战争，中国的saas平台究竟能不能做起来？
9. php循环建立新的文件根据文件名移动文件到指定文件夹修改文件名称
10. 【Elasticsearch】Elasticsearch：Searchable snapshot - 可搜索的快照
11. label mpchart 饼图_Android MPChart—饼图-Go语言中文社区
12. 在新窗口中打开链接 javascript
13. 面向对象的三个特点：封装、继承、多态
14. 你不知道的Retrofit缓存库RxCache
15. php curl 12306,pany
16. PSINS捷联惯导更新算法
17. php 实现url rewrite 伪静态
18. OpenHarmony学习笔记——南向开发环境搭建
19. 论文阅读：Reducing Transformer Depth On Demand With Structured Dropout
20. 安全设备相关知识总结

热门文章

1. BCNF与3NF的区别例子
2. MySQL 排序语句
3. XSS注入进阶练习篇（三） XSS原型链污染
4. java minma_Java Core.minMaxLoc方法代码示例
5. ————《metasploit 魔鬼训练营》学习笔记序言
6. static 函数和变量
7. 论玩镜头的三种境界[转自无忌fruitbear]
8. Kubernetes调度
9. HTML5视频播放器jQuery插件
10. Mathtype7的安装与在Word中使用的方法