Spring Cloud 路由网关(Gateway:异步,WebFlux) nacos配置

港控/mmm° 2022-12-18 07:58 183阅读 0赞

## Zuul支持 ##

[参考 Sentinel 网关限流][Sentinel](同步并阻塞)

若想跟 Sentinel Starter 配合使用，需要加上 `spring-cloud-alibaba-sentinel-gateway` 依赖，同时需要添加 `spring-cloud-starter-netflix-zuul` 依赖来让 `spring-cloud-alibaba-sentinel-gateway` 模块里的 Zuul 自动化配置类生效：

<dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
    </dependency>
    
    <dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-alibaba-sentinel-gateway</artifactId>
    </dependency>
    
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-zuul</artifactId>
    </dependency>

## 什么是 Spring Cloud Gateway ##

Spring Cloud Gateway 是 Spring 官方基于 Spring 5.0，Spring Boot 2.0 和 Project Reactor 等技术开发的网关，Spring Cloud Gateway 旨在为微服务架构提供一种简单而有效的统一的 API 路由管理方式。**Spring Cloud Gateway 作为 Spring Cloud 生态系中的网关，目标是替代 Netflix ZUUL**，其不仅提供统一的路由方式，并且基于 Filter 链的方式提供了网关基本的功能，例如：安全，监控/埋点，和限流等。

![b77fa3e1eb61c5a96719f138bfe05163.png][]

## Spring Cloud Gateway 功能特征 ##

*  基于 Spring Framework 5，Project Reactor 和 Spring Boot 2.0
 *  动态路由
 *  Predicates 和 Filters 作用于特定路由
 *  集成 Hystrix 断路器
 *  集成 Spring Cloud DiscoveryClient
 *  易于编写的 Predicates 和 Filters
 *  限流
 *  路径重写

## Spring Cloud Gateway 工程流程 ##

![9f961f963bc9854e5981d966576071db.png][]

客户端向 Spring Cloud Gateway 发出请求。然后在 Gateway Handler Mapping 中找到与请求相匹配的路由，将其发送到 Gateway Web Handler。Handler 再通过指定的过滤器链来将请求发送到我们实际的服务执行业务逻辑，然后返回。

过滤器之间用虚线分开是因为过滤器可能会在发送代理请求之前（`pre`）或之后（`post`）执行业务逻辑。

## 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">
        <modelVersion>4.0.0</modelVersion>
        <parent>
            <groupId>com.wj</groupId>
            <artifactId>hello-spring-cloud-alibaba-dependencies</artifactId>
            <version>1.0.0-SNAPSHOT</version>
            <relativePath>../hello-spring-cloud-alibaba-dependencies/pom.xml</relativePath>
        </parent>
    
        <artifactId>hello-spring-cloud-gateway</artifactId>
        <packaging>jar</packaging>
    
        <name>hello-spring-cloud-gateway</name>
    
        <dependencies>
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
            
    
            
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
            </dependency>
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-openfeign</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-gateway</artifactId>
            </dependency>
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
            </dependency>
            
    
            
            <dependency>
                <groupId>javax.servlet</groupId>
                <artifactId>javax.servlet-api</artifactId>
            </dependency>
            
        </dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                    <configuration>
                        <mainClass>com.wj.hello.gateway.GatewayApplication</mainClass>
                    </configuration>
                </plugin>
            </plugins>
        </build>
    
    </project>

主要增加了 `org.springframework.cloud:spring-cloud-starter-gateway` 依赖。

特别注意

*  Spring Cloud Gateway 不使用 Web 作为服务器，而是 使用 WebFlux 作为服务器，Gateway 项目已经依赖了 starter-webflux，所以这里 千万不要依赖 starter-web
 *  由于过滤器等功能依然需要 Servlet 支持，故这里还需要依赖 javax.servlet:javax.servlet-api

## Application ##

package com.wj.hello.spring.cloud.gateway;
    
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    import org.springframework.cloud.openfeign.EnableFeignClients;
    
    @SpringBootApplication
    @EnableDiscoveryClient
    @EnableFeignClients
    public class GatewayApplication {
        public static void main(String[] args) {
            SpringApplication.run(GatewayApplication.class,args);
        }
    }

## application.yml ##

spring:
      application:
        # 应用名称
        name: spring-gateway
      cloud:
        # 使用 Naoos 作为服务注册发现
        nacos:
          discovery:
            server-addr: 192.168.198.131:8848
        # 使用 Sentinel 作为熔断器
        sentinel:
          transport:
            port: 8720
            dashboard: 192.168.198.131:8858
        # 路由网关配置
        gateway:
          # 设置与服务注册发现组件结合，这样可以采用服务名的路由策略
          discovery:
            locator:
              enabled: true
          # 配置路由规则
          routes:
            # 采用自定义路由 ID（有固定用法，不同的 id 有不同的功能，详见：https://cloud.spring.io/spring-cloud-gateway/2.0.x/single/spring-cloud-gateway.html#gateway-route-filters）
            - id: NACOS-CONSUMER
              # 采用 LoadBalanceClient 方式请求，以 lb:// 开头，后面的是注册在 Nacos 上的服务名
              uri: lb://nacos-consumer
              # Predicate 翻译过来是“谓词”的意思，必须，主要作用是匹配用户的请求，有很多种用法
              predicates:
                # Method 方法谓词，这里是匹配 GET 和 POST 请求
                - Method=GET,POST
            - id: NACOS-CONSUMER-FEIGN
              uri: lb://nacos-consumer-feign
              predicates:
                - Method=GET,POST
    
    server:
      port: 9000
    
    # 目前无效
    feign:
      sentinel:
        enabled: true
    
    # 目前无效
    management:
      endpoints:
        web:
          exposure:
            include: "*"
    
    # 配置日志级别，方别调试
    logging:
      level:
        org.springframework.cloud.gateway: debug

注意：请仔细阅读注释

### 测试访问 ###

依次运行 Nacos 服务、NacosProviderApplication、NacosConsumerApplication、NacosConsumerFeignApplication、GatewayApplication

![9c280ae21e9c3e828705732d84c3c946.png][]

打开浏览器访问：`http://localhost:9000/nacos-consumer/echo/app/name` 浏览器显示

Hello Nacos Discovery nacos-consumer i am from port 8081

打开浏览器访问：`http://localhost:9000/nacos-consumer-feign/echo/hi` 浏览器显示

Hello Nacos Discovery Hi Feign i am from port 8081

**注意：请求方式是 http://路由网关IP:路由网关Port/服务名/**

至此说明 Spring Cloud Gateway 的路由功能配置成功

## 结构导图 ##

![7dba3007a4bf24e01a5ab5b2d9b380da.png][]

GateWay去Nacos根据服务名找到对应的IP，然后根据地址去访问

作者：直冲车  
链接：https://www.jianshu.com/p/208db28bb78c  
来源：简书  
著作权归作者所有。商业转载请联系作者获得授权，非商业转载请注明出处。

[Sentinel]: https://links.jianshu.com/go?to=https%3A%2F%2Fgithub.com%2Falibaba%2FSentinel%2Fwiki%2F%25E7%25BD%2591%25E5%2585%25B3%25E9%2599%2590%25E6%25B5%2581
[b77fa3e1eb61c5a96719f138bfe05163.png]: /images/20221122/dcccb1c3bc3e407fae8b76519ecd7a9c.png
[9f961f963bc9854e5981d966576071db.png]: /images/20221122/bf452a8086bd4d859aa41313a9ebee0e.png
[9c280ae21e9c3e828705732d84c3c946.png]: /images/20221122/86c8efb3ca47474495f73c67726e51a3.png
[7dba3007a4bf24e01a5ab5b2d9b380da.png]: /images/20221122/3c5c8d5262ee42dfa028a75b46906a4c.png