码迷,mamicode.com
首页 > 编程语言 > 详细

08.SpringCloud Gateway (新一代网关)

时间:2021-01-05 10:55:55      阅读:0      评论:0      收藏:0      [点我收藏+]

标签:日志监控   new   scope   fir   details   parameter   映射   正整数   path   

1.概述

基本说明

官网
上一代网关 zuul
当前gateway

是什么
技术图片
技术图片

一句话
Spring Cloud Gateway 使用的Webflux中的reactor-netty响应式编程组件,底层使用了Netty通讯框架
源码架构
技术图片

能干嘛
  • 反向代理
  • 鉴权
  • 流量控制
  • 熔断
  • 日志监控

微服务架构中网关在哪里
技术图片
有了Zuul了怎么又出来了gateway

我们为什么选择Gatway?

  • 1.neflix不太靠谱,zuul2.0一直跳票,迟迟不发布
技术图片

  • 2.SpringCloud Gateway具有如下特性
技术图片

  • 3.SpringCloud Gateway与Zuul的区别
技术图片

Zuul1.x模型

技术图片

GateWay模型

WebFlux是什么?
技术图片
技术图片

说明
技术图片

2.三大核心概念

Route(路由)

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

Predicate(断言)

参考的是java8的java.util.function.Predicate开发人员可以匹配HTTP请求中的所有内容(例如请求头或请求参数),如果请求与断言相匹配则进行路由

Filter(过滤)

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

总体
技术图片

3.Gateway工作流程

官网总结
技术图片
技术图片
核心逻辑
  • 路由转发+执行过滤器链

4.入门配置

新建模块cloud-gateway-gateway9527
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>springcloud2020</artifactId>
        <groupId>com.chl.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>
        <dependency>
            <groupId>com.chl.springcloud</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix</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>


</project>
yml
server:
  port: 9527
spring:
  application:
    name: cloud-gateway
  cloud:
    gateway:
      discovery:
        locator:
          enabled: true  #开启从注册中心动态创建路由的功能,利用微服务名进行路由
      routes:
        - id: payment_routh #路由的ID,没有固定规则但要求唯一,建议配合服务名
          uri: http://localhost:8001   #匹配后提供服务的路由地址
          predicates:
            - Path=/payment/get/**   #断言,路径相匹配的进行路由

        - id: payment_routh2
          uri: http://localhost:8001   #匹配后提供服务的路由地址
          predicates:
            - Path=/payment/lb/**   #断言,路径相匹配的进行路由
         
eureka:
  instance:
    hostname: cloud-gateway-service
  client:
    service-url:
      register-with-eureka: true
      fetch-registry: true
      defaultZone: http://eureka7001.com:7001/eureka
主启动类
@SpringBootApplication
@EnableEurekaClient
public class GateWayMain9527 {
    public static void main(String[] args) {
            SpringApplication.run( GateWayMain9527.class,args);
        }
}
9527网关如何做路由映射那???
cloud-provider-payment8001看看controller的访问地址     get个lb
我们目前不想暴露8001端口,希望在8001外面套一层9527
yml新增网关配置
server:
  port: 9527
spring:
  application:
    name: cloud-gateway
  cloud:
    gateway:
      discovery:
        locator:
          enabled: true  #开启从注册中心动态创建路由的功能,利用微服务名进行路由
      routes:
        - id: payment_routh #路由的ID,没有固定规则但要求唯一,建议配合服务名
          uri: http://localhost:8001   #匹配后提供服务的路由地址
          predicates:
            - Path=/payment/get/**   #断言,路径相匹配的进行路由

        - id: payment_routh2
          uri: http://localhost:8001   #匹配后提供服务的路由地址
          predicates:
            - Path=/payment/lb/**   #断言,路径相匹配的进行路由
         
eureka:
  instance:
    hostname: cloud-gateway-service
  client:
    service-url:
      register-with-eureka: true
      fetch-registry: true
      defaultZone: http://eureka7001.com:7001/eureka
测试
1.启动7001  
2.启动8001  cloud-provider-payment8001
3.启动9527网关
4.访问说明
技术图片
  • 添加网关前
       http://localhost:8001/payment/get/31
  • 添加网关前

yml配置说明

Gateway网关路由有两种配置方式

在配置文件yml中配置

见前面步骤

代码中注入RouteLocator的Bean

官网案例
技术图片

百度国内新闻网址,需要外网

自己写一个测试下   百度新闻
业务需求
通过9527网关访问到外网的百度新闻网址
编码  cloud-gateway-gateway9527
实现业务  
添加配置bean
@Configuration
public class GateWayConfig {

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

5.通过微服务名实现动态路由

默认情况下Gateway会根据注册中心的服务列表,以注册中心上微服务名为路径创建动态路由进行转发,从而实现动态路由的功能
一个eureka7001+两个服务提供者8001/8002

yml配置

需要注意的是uri的协议为lb,表示启用Gateway的负载均衡功能。
lb://serviceName是spring cloud gateway在微服务中自动为我们创建的负载均衡uri
server:
  port: 9527
spring:
  application:
    name: cloud-gateway
  cloud:
    gateway:
      discovery:
        locator:
          enabled: true  #开启从注册中心动态创建路由的功能,利用微服务名进行路由
      routes:
        - id: payment_routh #路由的ID,没有固定规则但要求唯一,建议配合服务名
          #uri: http://localhost:8001   #匹配后提供服务的路由地址
          uri: lb://cloud-payment-service  #负载均衡,根据服务名找
          predicates:
            - Path=/payment/get/**   #断言,路径相匹配的进行路由

        - id: payment_routh2
          #uri: http://localhost:8001   #匹配后提供服务的路由地址
          uri: lb://cloud-payment-service  #负载均衡,根据服务名找
          predicates:
            - Path=/payment/lb/**   #断言,路径相匹配的进行路由
  
eureka:
  instance:
    hostname: cloud-gateway-service
  client:
    service-url:
      register-with-eureka: true
      fetch-registry: true
      defaultZone: http://eureka7001.com:7001/eureka
测试
8001/8002两个端口切换

6.Predicate的使用

是什么

启动我们的gatewat9527
技术图片

Route Predicate Factories这个是什么东东?
技术图片
技术图片

常用的Route Predicate

技术图片

1.After Route Predicate
技术图片
yml配置
            #这些是常用的断言,如果不符合,就返回404,找不到
            - After=2020-03-08T10:59:34.102+08:00[Asia/Shanghai]  这个时间后面访问才行

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

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

4. Cookie Route Predicate
技术图片
不带cookies访问
带上cookies访问   加入curl返回中文乱码   https://blog.csdn.net/leedee/article/details/82685636
  - Cookie=username,atguigu    #并且Cookie是username=zhangshuai才能访问

5. Header Route Predicate
技术图片

6.Host Route Predicate
  - Host=**.baidu.com

7.Method Route Predicate
    - Method=GET

8.Path Route Predicate

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

10.小总结
说白了,Predicate就是为了实现一组匹配规则,让请求过来找到对应的Route进行处理
server:
  port: 9527
spring:
  application:
    name: cloud-gateway
  cloud:
    gateway:
      discovery:
        locator:
          enabled: true  #开启从注册中心动态创建路由的功能,利用微服务名进行路由
      routes:
        - id: payment_routh #路由的ID,没有固定规则但要求唯一,建议配合服务名
          #uri: http://localhost:8001   #匹配后提供服务的路由地址
          uri: lb://cloud-payment-service  #负载均衡,根据服务名找
          predicates:
            - Path=/payment/get/**   #断言,路径相匹配的进行路由

        - id: payment_routh2
          #uri: http://localhost:8001   #匹配后提供服务的路由地址
          uri: lb://cloud-payment-service  #负载均衡,根据服务名找
          predicates:
            - Path=/payment/lb/**   #断言,路径相匹配的进行路由
            #这些是常用的断言,如果不符合,就返回404,找不到
            #- After=2020-03-08T10:59:34.102+08:00[Asia/Shanghai]  这个时间后面访问才行
            #- Cookie=username,zhangshuai #并且Cookie是username=zhangshuai才能访问
            #- Header=X-Request-Id, \d+ #请求头中要有X-Request-Id属性并且值为整数的正则表达式
            #- Host=**.atguigu.com #主机携带是这个才行
            #- Method=GET    #get 方法访问
            #- Query=username, \d+ #要有参数名称并且是正整数才能


eureka:
  instance:
    hostname: cloud-gateway-service
  client:
    service-url:
      register-with-eureka: true
      fetch-registry: true
      defaultZone: http://eureka7001.com:7001/eureka

7.Filter的使用

是什么

技术图片
技术图片

Spring Cloud Gateway的Filter 

生命周期 (2个)

  • Pre  在业务逻辑之前  
  • Post   在业务逻辑之后

种类(2个)

  • GatewayFilter   单一   gateway定义的,没啥用
技术图片

  • GlobalFilter    全局   都是用这个
技术图片

常用的GatewayFilter (gateway定义作用不大)

AddRequestParameter
技术图片

自定义过滤器(自定义全局GlobalFilter)

两个主要接口介绍
  •   GlobalFilter 
  • Ordered

能干嘛
全局日志记录
统一网关鉴权

案例代码
/**
 * 自定义全局的filter  Spring Cloud Gateway的Filter 没啥用,还是自己自定义的好用
 */
@Component
@Slf4j
public class MyLogGateWayFilter implements GlobalFilter, Ordered {
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {

        log.info("*********come in MyLogGateWayFilter: "+new Date());
        String uname = exchange.getRequest().getQueryParams().getFirst("uname");
        //不成功,就直接返回去
        if(StringUtils.isEmpty(uname)){
            log.info("*****用户名为Null 非法用户,(┬_┬)");
            exchange.getResponse().setStatusCode(HttpStatus.NOT_ACCEPTABLE);//给人家一个回应
            return exchange.getResponse().setComplete();
        }
        return chain.filter(exchange);
    }

    /**
     * order是过滤器的执行顺序,数字越小,执行顺序越前
     * @return
     */
    @Override
    public int getOrder() {
        return 0;
    }
}

08.SpringCloud Gateway (新一代网关)

标签:日志监控   new   scope   fir   details   parameter   映射   正整数   path   

原文地址:https://www.cnblogs.com/superComputer/p/14220125.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!