尚硅谷—Cloud—GetWay 新一代网关（66～73）-java黑洞网

本站消息

站长简介/公众号

出租广告位,需要合作请联系站长

我很伤感

521

文章

243113

访问

+关注

分类

暂无分类

日期归档

2023-05(1)

2023-06(1)

尚硅谷—Cloud—GetWay 新一代网关（66～73）

发布于2021-05-30 00:38 阅读(542) 评论(0) 点赞(6) 收藏(2)

一：概念简介
二：三大核心概念
三：Gateway 工作流程
四：入门配置
五：通过微服务名实现动态路由
六：Predicate 的使用
七：Filter 的使用

一：概念简介

1）官网：https://docs.spring.io/spring-cloud-gateway/docs/current/reference/html/#gateway-starter

2）是什么：
a：Spring Cloud 全家桶中，有个很重要的组件，就是网关，在 1.x 版本中都是采用的 Zuul 网关。
b：2.x 中，使用 SpringCloud Getway 代替了 Zuul。（netty视频：https://www.bilibili.com/video/BV1DJ411m7NR）
c：一句话：SpringCloud Getway 使用的 WebFlux 中的 reactor-netty 响应式编程组件，底层使用量 Netty 通讯框架。

3）能干嘛：
a：反向代理：
b：鉴权：
c：限流：
d：熔断：重试、安全、
e：日志监控/指标：
f：。。。。。

4）微服务架构中，网关在哪里：（网关是所有为服务的入口）

5）有 Zuul 了，怎么又来了 Getway：
a：为什么我们选择 Getway：

- SpringCloud Getway 特性：（Getway：异步非阻塞模型）

- pringCloud Getway 与 Zuul 区别：

b：Zuul 1.x 模型：

c：GetWay 模型：（WebFlux）（异步非阻塞）

二：三大核心概念

1）Route（路由）
a：概念：

2）Predicate（断言）
a：概念：

3）Filter（过滤）
c：概念：

4）总体：

三：Gateway 工作流程

1）官网总结

2）核心逻辑：路由转发 + 执行过滤链

四：入门配置

1）新建 Module：cloud-getway-getway-9527
2）POM：


    <dependencies>
 
        <dependency>
            <groupId>com.atguigu.springcloud</groupId>
            <artifactId>cloud-api-commons</artifactId>
        </dependency>
 
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-gateway</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>

3）YML：


server:
  port: 9527
 
spring:
  application:
    name: cloud-getway-getway-9527
 
eureka:
  instance:
    hostname: cloud-getway-service
  client:
    register-with-eureka: true
    fetch-registry: true
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka

4）业务类：无

5）主启动类：


@EnableEurekaClient
@SpringBootApplication
public class GetwayGetway9527 {
 
    public static void main(String[] args) {
        SpringApplication.run(GetwayGetway9527.class, args);
    }
 
}

6）9527 网关，如何做路由映射：
a：cloud-provider-payment-8001 看看Controller的访问地址：(localhost:8001/getPayment?id=1)
b：我们不想暴露 8001 端口，希望在 8001 外面套一层 9527：

7）YML 新增网关配置：


server:
  port: 9527
 
spring:
  application:
    name: cloud-getway-getway-9527
 
  cloud:
    gateway:
      routes:  # 路由：（id、目标URL、断言和过滤器）
        - id: payment_route  # 路由的 id：没有固定规则但要求 唯一，建议配合 服务名
          uri: http://localhost:8001  # 断言 匹配后，提供服务的 路由地址
          predicates: # 断言：请求 和 断言 匹配的，则进行路由
            - Path=/getPayment/**
        - id: payment_route_2
          uri: http://localhost:8001
          predicates:
            - Path=/create/**
eureka:
  instance:
    hostname: cloud-getway-service
  client:
    register-with-eureka: true
    fetch-registry: true
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka


spring:
  cloud:
    gateway:
      routes:  // # 路由：（id、目标URL、断言和过滤器）
        - id: payment_route // # 路由的 id：没有固定规则但要求 唯一，建议配合 服务名
          uri: http://localhost:8001 // # 断言 匹配后，提供服务的 路由地址
          predicates: // # 断言：请求 和 断言 匹配的，则进行路由
            - Path=/getPayment/**

8）测试：

a：正常访问：（localhost:8001/getPayment?id=1）
b：通过网关访问：（localhost:9527/getPayment?id=1）

9）YML 配置说明：
a：Getway 网关路由有两种配置方式：
1.在配置文件 yml 中配置：
2.代码中注入 RouteLocator 的 Bean：

10）编码方式进行网关配置：
a：官网案例：

b：百度国内新闻地址，需要外网：
c：自己写一个：


@Configuration
public class GetwayConfig {
 
    @Bean
    public RouteLocator routeLocator(RouteLocatorBuilder routeLocatorBuilder) {
 
        // 访问：  http://localhost:9527/guonei
        // 跳转到：https://news.baidu.com/guonei
        RouteLocatorBuilder.Builder routes = routeLocatorBuilder.routes();
        routes.route("path_route_baidu", (r) -> r.path("/guonei")
                .uri("https://news.baidu.com/guonei")).build();
 
        return routes.build();
    }
 
}

五：通过微服务名实现动态路由

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

2）启动：7001/7002 + 8001/8002 +
3）POM：


        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>

4）YML：


spring:
  application:
    name: cloud-getway-getway-9527
 
  cloud:
    gateway:
      discovery:
        locator:
          enabled: true  # 开启从 注册中心，动态创建路由的功能，利用为服务名进行路由。
 
      routes: # 路由：（id、目标URL、断言和过滤器）
        - id: payment_route  # 路由的 id：没有固定规则但要求 唯一，建议配合 服务名
          uri: lb://CLOUD-PROVIDER-PAYMENT  # 断言 匹配后，提供服务的 路由地址
          predicates: # 断言：请求 和 断言 匹配的，则进行路由
            - Path=/paymentInfo_OK/**
        - id: payment_route_2
          uri: lb://CLOUD-PROVIDER-PAYMENT
          predicates:
            - Path=/create/**

5）测试：（localhost:9527/getPayment?id=1）通过gateway 实现了负载均衡。

六：Predicate 的使用

1）是什么：启动 9527
a：启动中会显示如下：就有这么断言的方式。（11种）

2）Route Predicate Factories 是什么：

3）常用的 Route Predicate：
1.After：规定时间之后：2021-05-26T15:21:50.293+08:00[Asia/Shanghai]
2.Before：规定时间之前
--获取时间：

3.Between：规定区间时间之内
4.Cookie：规定携带什么样Cookie 才匹配：- Cookie=chocolate, ch.p（也就是 K：V）

测试：（curl http://localhost:9527/discover --cookie "username=zhangsan"）

5.Header：规定携带什么样 Header 才匹配： - Header=X-Request-Id, \d+（K，V）

6.Host：根据主机进行拦截：- Host=**.somehost.org,**.anotherhost.org

7.Method：根据请求方法类型进行拦截：- Method=GET,POST：

8.Path：根据请求路径进行拦截：- Path=/red/{segment},/blue/{segment}

9.Query：带查询条件，要带参数查询条件，值为参数才进行拦截：- Query=red, gree

10.小总结：
- 说白了，Predicate 就是为了实现一组匹配规则，让请求过来，找到我们对应的路由，进行处理。

七：Filter 的使用

1）是什么：

2）SpringCloud Gateway 的 Filter：
a：生命周期，Only Two：
- pre：前置拦截
- post：后置拦截

b：种类，Only Two：
- Gateway Filter：（31种之多）
- Global Filter：（10 种之多）

3）常见的 GatewayFilter：

4）自定义过滤器：（自定义全局 Global Filter ）
a：两个主要接口介绍：
- implements GlobalFilter ，Orderd
b：能干嘛：
- 全局日志记录：
- 统一网关鉴权：
- 。。。。。
c：案例代码：（判断请求是不是每次都带着 username 参数）
- 自定义日志实现类：继承两个接口：


@Slf4j
@Component
public class MyLogGatewayFilter implements GlobalFilter, Ordered {
 
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
 
        System.out.println("come in MyLogGatewayFilter" + new Date());
 
        String username = exchange.getRequest().getQueryParams().getFirst("username");
        if (username == null) {
            System.out.println("用户名为 null，非法");
            exchange.getResponse().setStatusCode(HttpStatus.MULTI_STATUS);
            return exchange.getResponse().setComplete();
        }
        //继续传下去
        return chain.filter(exchange);
    }
 
    @Override
    public int getOrder() {
        //过滤链，数字越小，优先级越高。Ordered.HIGHEST_PRECEDENCE
        return 0;
    }
 
}