Gateway 简介
是什么？
Spring Cloud 全家桶中有个很重要的组件：网关。在 1.x 版本中使用的是 Zuul 网关，可是到了 2.x，因为Zuul的升级不断跳票，Spring Cloud 本身研发了一套网关组件：Spring Cloud Gateway。html
Spring Cloud Gateway基于 Spring Boot 2.x，Spring WebFlux 和 Project Reactor 构建，使用了 Webflux 中的 reactor-netty 响应式编程组件，底层使用了 Netty 通信框架。java
详见：官网react
能干吗？
反向代理git
鉴权github
流量控制正则表达式
熔断spring
日志监控编程
......浏览器
网关在微服务架构中的位置
Gateway 的三大概念
Route（路由）：路由是构建网关的基本模块，它由 ID、目标 URI、一系列的断言和过滤器组成，若是断言为 true 则匹配该路由cookie
Predicate（断言）：参考的是 Java8 中的 java.util.function.Predicate。开发人员能够匹配 HTTP 请求中的全部内容（例如请求头或请求参数），若是请求与断言相匹配则进行路由
Filter（过滤）：指的是 Spring 框架中 GatewayFilter 的实例，使用过滤器，能够在请求被路由以前或以后对请求进行修改
工做流程
Clients make requests to Spring Cloud Gateway. If the Gateway Handler Mapping determines that a request matches a route, it is sent to the Gateway Web Handler. This handler runs the request through a filter chain that is specific to the request. The reason the filters are divided by the dotted line is that filters can run logic both before and after the proxy request is sent. All “pre” filter logic is executed. Then the proxy request is made. After the proxy request is made, the “post” filter logic is run.
翻译：客户端向 Spring Cloud Gateway 发出请求。若是网关处理程序映射肯定请求与路由匹配，则将其发送到网关 Web 处理程序。该处理程序经过特定于请求的过滤器链来运行请求。 筛选器由虚线分隔的缘由是，筛选器能够在发送代理请求以前和以后运行逻辑。全部 “前置“ 过滤器逻辑均被执行，而后发出代理请求，发出代理请求后，将运行“ 后置 ”过滤器逻辑。
总结：路由转发 + 执行过滤器链
两种配置方式
配置文件方式
咱们以访问「百度新闻网」为例，添加以下配置
server:
port: 9527
spring:
application:
name: cloud-gateway9527
cloud:
gateway:
routes:
- id: news # 路由id
uri: http://news.baidu.com # 真实调用地址
predicates:
- Path=/guonei # 断言，符合规则进行路由
浏览器虽然输入 localhost:9527/guonei，却会转发到指定的地址
编码方式
新增配置文件
@Configuration
public class GatewayConfig {
@Bean
public RouteLocator routes(RouteLocatorBuilder builder) {
return builder.routes()
.route("news2", r -> r.path("/guoji").uri("http://news.baidu.com"))
.build();
}
}
效果：
动态路由
开启后，默认状况下 Gateway 会根据注册中心注册的服务列表，以注册中心上微服务名为路径建立动态路由进行转发，从而实现动态路由的功能
spring:
cloud:
gateway:
discovery:
locator:
enabled: true #开启从注册中心动态建立路由的功能，利用微服务名进行路由
routes:
- id: payment_routh1
#uri: http://localhost:8001 #静态，写死了地址，只能调用一个服务
uri: lb://CLOUD-PAYMENT-SERVICE #动态，lb://微服务名
predicates:
- Path=/payment/get/**
- id: payment_routh2
#uri: http://localhost:8001
uri: lb://CLOUD-PAYMENT-SERVICE
predicates:
- Path=/payment/lb/**
Predicate 的使用
时间相关配置
After：在指定时间之后进行路由
Before：在指定时间之前进行路由
Between：在指定时间之间进行路由
predicates:
- Path=/payment/lb/**
#- After=2020-04-25T16:30:58.215+08:00[Asia/Shanghai]
#- Before=2020-04-25T16:40:58.215+08:00[Asia/Shanghai]
- Between=2020-04-25T16:35:58.215+08:00[Asia/Shanghai],2020-04-25T16:40:58.215+08:00[Asia/Shanghai]
上述配置的时间格式能够经过如下代码获得
@Test
public void test(){
ZonedDateTime now = ZonedDateTime.now();
System.out.println(now);
}
请求相关配置
Cookie
配置说明：【Cookie=cookie名, cookie值的正则表达式规则】
predicates: - Path=/payment/lb/** - Cookie=id, [0-9]
使用 curl 工具模拟携带 cookie 发送请求
Header
配置说明：【Header=header名, header值的正则表达式规则】
predicates: - Path=/payment/lb/** - Header=h, [a-h]
Host
配置说明：【Host=主机名（可配置多个，也可使用通配符）】
predicates: - Path=/payment/lb/** - Host=**.a.com,**.b.cn
Method
配置说明：【Method=请求类型】
predicates: - Path=/payment/lb/** - Method=GET
Path
配置说明：【Path=请求路径】
predicates: - Path=/payment/lb/**
Query
配置说明：【Query=参数名，参数值】
predicates: - Path=/payment/lb/** - Query=name, zhangsan
详见：官网
Filter 的使用
- 生命周期：pre、post
- 种类：GatewayFilter、GlobalFilter
GatewayFilter 在官方文档有几十种！详细配置可参考 官网，这里主要介绍自定义全局过滤器。
@Component
@Slf4j
public class MyGlobalFilter implements GlobalFilter, Ordered {
@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
String username = exchange.getRequest().getQueryParams().getFirst("username");
//用户名为空时，给出错误响应
if (username == null) {
log.info("用户名为空，非法登陆");
exchange.getResponse().setStatusCode(HttpStatus.NOT_ACCEPTABLE);
return exchange.getResponse().setComplete();
}
return chain.filter(exchange);
}
@Override
public int getOrder() {
return 0;
}
}