springcloud整合Gateway

简介

1、是什么
springcloud gateway使用webflux的reactor-netty响应式编程组件，底层使用了Netty通讯框架
2、能干嘛
反向代理、鉴权、流量控制、熔断、日志监控
3、网关对比
gateway对比netflix和zuul来说都要靠谱一点
4、三大核心概念
路由(Route):链路URI和ID构成
断言(predicate)：请求参数是否匹配断言条件，匹配则进行路由
过滤(filter):使用过滤器可以在请求被路由前或者路由后进行修改

实战

1、建module
gateway-gateway9527
2、改pom

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><parent><artifactId>cloud2020</artifactId><groupId>com.atguigu.springcloud</groupId><version>1.0-SNAPSHOT</version></parent><modelVersion>4.0.0</modelVersion><artifactId>cloud-gateway-gateway9527</artifactId><dependencies><!--gateway--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-gateway</artifactId></dependency><!--eureka-client--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency><!-- 引入自己定义的api通用包，可以使用Payment支付Entity --><dependency><groupId>com.atguigu.springcloud</groupId><artifactId>cloud-api-commons</artifactId><version>${project.version}</version></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></project>

3、配yml

server:port: 9527spring:application:name: cloud-gatewaycloud:gateway:discovery:locator:enabled: true #开启从注册中心动态创建路由的功能，利用微服务名进行路由routes:- id: payment_routh #payment_route    #路由的ID，没有固定规则但要求唯一，建议配合服务名#uri: http://localhost:8001          #匹配后提供服务的路由地址uri: lb://cloud-payment-service #匹配后提供服务的路由地址predicates:- Path=/payment/get/**         # 断言，路径相匹配的进行路由- id: payment_routh2 #payment_route    #路由的ID，没有固定规则但要求唯一，建议配合服务名#uri: http://localhost:8001          #匹配后提供服务的路由地址uri: lb://cloud-payment-service #匹配后提供服务的路由地址predicates:- Path=/payment/lb/**         # 断言，路径相匹配的进行路由- 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]#            curl http://localhost:9527/payment/lb --cookie "username=zzyy"#            - Cookie=username,zzyy   #Cookie=cookieName,正则表达式# 请求头要有X-Request-Id属性并且值为整数的正则表达式 curl http://localhost:9527/payment/lb --cookie "username=zzyy" -H "X-Request-Id:11"
#            - Header=X-Request-Id, \d+
#            - Host=**.atguigu.com  # curl http://localhost:9527/payment/lb -H "Host:afae.atguigu.com"eureka:instance:hostname: cloud-gateway-serviceclient: #服务提供者provider注册进eureka服务列表内service-url:register-with-eureka: truefetch-registry: truedefaultZone: http://eureka7001.com:7001/eureka

4、主启动

@SpringBootApplication
@EnableEurekaClient
public class CloudGateway9527Application {public static void main(String[] args) {SpringApplication.run(CloudGateway9527Application.class, args);System.out.println("启动成功");}
}

5、测试：
添加网关前：http://localhost:8001/payment/get/31
添加网关后：http://localhost:9527/payment/get/31
6、通过9527访问外网地址
config配置

@Configuration
public class GateWayConfig {@Beanpublic RouteLocator customRouteLocator(RouteLocatorBuilder routeLocatorBuilder) {RouteLocatorBuilder.Builder routes = routeLocatorBuilder.routes();routes.route("path_route_atguigu", r -> r.path("/guoji").uri("http://news.baidu.com/guonei")).build();return routes.build();}
}

通过微服务名进行动态路由

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

predicate配置

1、After

   - After=2020-03-08T10:59:34.102+08:00[Asia/Shanghai]

2、Before

- Before=2020-03-08T10:59:34.102+08:00[Asia/Shanghai]

3、Between

   - Between=2020-03-08T10:59:34.102+08:00[Asia/Shanghai] ,  2020-03-08T10:59:34.102+08:00[Asia/Shanghai]

4、Cookie
需要配置两个参数，cookie name和正则表达式，当匹配上才会执行路由

- Cookie=username,zhangsan

5、Header

-Header=X-request-Id,\d+ #表示请求头要有X-request-Id属性，且还要有值为正数的表达式

6、Host

  - Host=**.dsf.com

7、Method

    - Method=GET

8、Query

  - Query=username, \d+ #要有参数名称并且是正整数才能路由

总结

说白了，Predicate就是为了实现一组匹配规则，让请求过来找到对应的Route进行处理

Filter

1、能干嘛？
用于修改进入的HTTP请求和返回HTTP响应
2、内置的filter配置
spring.cloud.routes.filters:-AddRequestParameter=X-Request-Id,1024.表示属性为X-Request-Id的参数值为1024
3、自定义全局的Global过滤器
作用：全局日志记录、统一网关鉴权等
demo：
需要实现GlobalFilter和Ordered接口

@Component
@Slf4j
public class MyLogGateWayFilter implements GlobalFilter, Ordered {@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {log.info("***********come in MyLogGateWayFilter:  " + new Date());// 获取请求参数中的 unameString uname = exchange.getRequest().getQueryParams().getFirst("uname");if (uname == null) {log.info("*******用户名为null，非法用户，o(╥﹏╥)o");exchange.getResponse().setStatusCode(HttpStatus.NOT_ACCEPTABLE);return exchange.getResponse().setComplete();}return chain.filter(exchange);}/*** 加载过滤器顺序，数字越小优先级越高** @return*/@Overridepublic int getOrder() {return 0;}
}

3、测试
正确：http://localhost:9527/payment/lb?uname=z3
错误：其他