5.服务网关：GateWay

0.1概念

cloud全家桶中有个很重要的组件就是网关，为微服务架构提供一种简单有效的统一的API路由管理方式。

在1.x版本中都是采用的Zuul网关，但在2.x版本中，zuul的升级一直跳票。SpringCloud最后自己研发了一个网关替代Zuul，那就是SpringCloud Gateway，Gateway是原zuul1.x版的替代。

SpringCloud Gateway使用的Webflux中的reactor-netty响应式编程组件，底层使用了Netty通讯框架。

主要功能：

反向代理

鉴权

流量控制

熔断

日志监控

官网：https://cloud.spring.io/spring-cloud-static/spring-cloud-gateway/2.2.1.RELEASE/reference/html/

微服务架构中网关位置：

0.2为什么选择Gateway?

SpringCloud Gateway具有如下特性：

SpringCloud Gateway与Zuul的区别：

0.3GateWay三大核心

Route(路由)：路由是构建网关的基本模块，它由ID，目标URI，一系列的断言和过滤器组成，如果断言为true则匹配该路由

Predicate(断言)：如果请求满足断言规则，则进行相对应的路由

Filter(过滤)：指的是Spring框架中GatewayFilter的实例，使用过滤器，可以在请求被路由前或者之后对请求进行修改。

总结：

web请求，通过一些匹配条件，定位到真正的服务节点。并在这个转发过程的前后，进行一些精细化控制。

predicate就是我们的匹配条件，而filter，就可以理解为一个无所不能的拦截器。

有了这两个元素，再加上目标uri，就可以实现一个具体的路由了。

0.4GateWay搭建

(1)创建Maven工程为网关(cloud-gateway-gateway9527)

(2)添加GateWay依赖

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-gateway</artifactId>
</dependency>

(3)application.yml

server:port: 9527
spring:application:name: cloud-gatewaycloud:gateway:routes:- id: payment_routh #路由的ID,要求唯一，建议配合服务名uri: http://localhost:8001   #匹配后提供服务的路由地址，这个是写死的地址predicates:- Path=/payment/get/**  #断言,路径相匹配的进行路由- id: payment_routh2uri: http://localhost:8001predicates:- Path=/payment/lb/**  #断言,路径相匹配的进行路由
#省略eureka配置

9527网关如何做路由映射？

看yml的的Path=/payment/get/**，跟controller里的访问地址是否一致。

(4)测试：

启动7001Eureka

cloud-provider-payment8001

9527网关

添加网关前：http://localhost:8001/payment/get/31，直接访问8001

添加网关后：http://localhost:9527/payment/get/31，让网关在前面挡一层，使用网关的ip加端口加controller层的访问地址

0.5GateWay通过微服务名称实现动态路由

默认情况下Gateway会根据注册中心的服务列表，以微服务名为路径创建动态路由进行转发，从而实现动态路由的功能。

(1)修改9527的application.yml，在gateway下加

discovery:locator:enabled: true  #开启从注册中心动态创建路由的功能，利用微服务名进行路由

(2)上面配置中的uri是写死的地址，现在可以使用下面的uri

cloud-payment-service是cloud-provider-payment8001的微服务名称

uri: lb://cloud-payment-service #匹配后提供服务的路由地址，需要注意的是uri的协议为lb，表示启用Gateway的负载均衡功能

(3)测试

启动7001Eureka、8001和8002服务提供者

访问：http://localhost:9527/payment/lb，8001和8002两个端口互相切换，负载均衡成功

0.6predicate(断言)的使用

- After=2020-03-08T10:59:34.102+08:00[Asia/Shanghai]：在该时间以后有效
- Before=2020-03-08T10:59:34.102+08:00[Asia/Shanghai]：在该时间以前有效
- Between=2020-03-08T10:59:34.102+08:00[Asia/Shanghai] ,  2020-03-08T10:59:34.102+08:00[Asia/Shanghai]：在这之间有效
- Cooie=username,zzyyCookie需要两个参数，Cookie name和正则表达式。路由规则会通过获取对应的Cooie name值和正则表达式去匹配。cmd后输入：http://localhost:9527/payment/lb没有带Cookie报错输入：http://localhost:9527/payment/lb --cookie "username=zzyy"，成功访问
- Header=X-Request-Id, \d+：请求头中要有X-Request-Id属性并且值为整数的正则表达式cmd输入：http://localhost:9527/payment/lb -H "X-Request-Id:123"
- Host=**.atguigu.com：接收一组参数，一组匹配的域名列表，用,号做分隔符，通过参数中的主机地址作为匹配规则
- Method=GET：get请求才可以访问
- Query=username, \d+ #要有参数名称username并且值是正整数才能路由

0.7Filter(过滤)的使用

生命周期：在业务逻辑之前，在业务逻辑之后

种类：单一,全局

内置的太多了，自行百度

(1)案例：9527里

@Component
@Slf4j
public class MyLogGateWayFilter implements GlobalFilter, Ordered {@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {log.info("*********come in MyLogGateWayFilter: "+new Date());String uname = exchange.getRequest().getQueryParams().getFirst("uname"); //表示请求地址要带一个参数名为unameif(StringUtils.isEmpty(uname)){log.info("*****用户名为Null 非法用户,(┬＿┬)");exchange.getResponse().setStatusCode(HttpStatus.NOT_ACCEPTABLE);//给人家一个回应return exchange.getResponse().setComplete();}return chain.filter(exchange); //给下一个filter链，或者放行}@Overridepublic int getOrder() {return 0; //优先级，越小优先级越高}
}