devbox
IT小白
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

springCloud核心组件之网关(Gateway)_spring gateway

作者：IT小白 | 2024-03-24 09:30:07

赞

踩

spring gateway

目录

一、Gateway基本使用

1、Gateway定义

2、Gateway作用

3、Gateway的组成

4、Gateway的使用

       1、在以前的项目中创建一个新模块，名叫gateway

       2、导入依赖

       3、配置资源文件

二、路由定义

        一、以服务名的路由

                   资源文件：

        二、以自定义路由

                   资源文件：

​

三、动态路由设置 

        1、导入依赖

        1、在nacos中新注册一个配置，名叫dynamic-routing.json

        3、导入相关帮助类

        4、进行测试

一、Gateway基本使用

1、Gateway定义

Spring Cloud Gateway是Spring官方基于Spring5.0、SpringBoot2.0和Project Reactor等技术开发的网关，旨在为微服务框架提供一种简单而有效的统一的API路由管理方式，统一访问接口。

2、Gateway作用

Spring Cloud Gateway作为Spring Cloud生态体系中的网关，目标是替代Netflix的Zuul，其不仅提供统 一的路由方式，并且基于Filter链的方式提供了网关基本的功能，例如：安全、监控/埋点和限流等等。 它是基于Netty的响应式开发模式。

3、Gateway的组成

1️⃣路由（route）：路由是网关最基础的部分，路由信息由一个ID，一个目的URL、一组断言工厂和一 组Filter组成。如果断言为真，则说明请求URL和配置的路由匹配。

2️⃣断言（Predicate）：Java8中的断言函数，Spring Cloud Gateway中的断言函数输入类型是 Spring5.0框架中的ServerWebExchange。Spring Cloud Gateway中的断言函数允许开发者去定义匹配 来自http Request中的任何信息，比如请求头和参数等。

3️⃣过滤器（Filter）：一个标准的Spring WebFilter，Spring Cloud Gateway中的Filter分为两种类型： Gateway Filter和Global Filter。过滤器Filter可以对请求和响应进行处理。

4、Gateway的使用

       1、在以前的项目中创建一个新模块，名叫gateway

       2、导入依赖

在其中有gataway、nacos、以及loadbalancer的依赖，没有继承父依赖，所以的重新组织依赖

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <modelVersion>4.0.0</modelVersion>
  5.     <groupId>com.zj</groupId>
  6.     <artifactId>gateway</artifactId>
  7.     <version>0.0.1-SNAPSHOT</version>
  8.     <name>gateway</name>
  9.     <description>gateway</description>
  10.  
  11.  
  12.  
  13.     <properties>
  14.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  15.         <maven.compiler.source>1.7</maven.compiler.source>
  16.         <maven.compiler.target>1.7</maven.compiler.target>
  17.         <spring-boot.version>2.4.1</spring-boot.version>
  18.         <spring-cloud.version>2020.0.0</spring-cloud.version>
  19.         <spring-cloud-alibaba.version>2021.1</spring-cloud-alibaba.version>
  20.     </properties>
  21.  
  22.  
  23.  
  24.  
  25.  
  26.     <dependencies>
  27.         <dependency>
  28.             <groupId>org.springframework.boot</groupId>
  29.             <artifactId>spring-boot-starter</artifactId>
  30.         </dependency>
  31.         <dependency>
  32.             <groupId>org.springframework.boot</groupId>
  33.             <artifactId>spring-boot-starter-test</artifactId>
  34.             <scope>test</scope>
  35.         </dependency>
  36.         <dependency>
  37.             <groupId>org.springframework.boot</groupId>
  38.             <artifactId>spring-boot-starter-webflux</artifactId>
  39.         </dependency>
  40.         <dependency>
  41.             <groupId>org.springframework.cloud</groupId>
  42.             <artifactId>spring-cloud-starter-gateway</artifactId>
  43.         </dependency>
  44.         <dependency>
  45.             <groupId>org.springframework.boot</groupId>
  46.             <artifactId>spring-boot-starter-actuator</artifactId>
  47.         </dependency>
  48.         <dependency>
  49.             <groupId>com.alibaba.cloud</groupId>
  50.             <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
  51.         </dependency>
  52.         <dependency>
  53.             <groupId>org.springframework.cloud</groupId>
  54.             <artifactId>spring-cloud-loadbalancer</artifactId>
  55.         </dependency>
  56.     </dependencies>
  57.  
  58.     <dependencyManagement>
  59.         <dependencies>
  60.             <dependency>
  61.                 <groupId>org.springframework.boot</groupId>
  62.                 <artifactId>spring-boot-dependencies</artifactId>
  63.                 <version>${spring-boot.version}</version>
  64.                 <type>pom</type>
  65.                 <scope>import</scope>
  66.             </dependency>
  67.             <dependency>
  68.                 <groupId>org.springframework.cloud</groupId>
  69.                 <artifactId>spring-cloud-dependencies</artifactId>
  70.                 <version>${spring-cloud.version}</version>
  71.                 <type>pom</type>
  72.                 <scope>import</scope>
  73.             </dependency>
  74.             <dependency>
  75.                 <groupId>com.alibaba.cloud</groupId>
  76.                 <artifactId>spring-cloud-alibaba-dependencies</artifactId>
  77.                 <version>${spring-cloud-alibaba.version}</version>
  78.                 <type>pom</type>
  79.                 <scope>import</scope>
  80.             </dependency>
  81.         </dependencies>
  82.     </dependencyManagement>
  83.  
  84.  
  85.     <build>
  86.         <plugins>
  87.             <plugin>
  88.                 <groupId>org.apache.maven.plugins</groupId>
  89.                 <artifactId>maven-compiler-plugin</artifactId>
  90.                 <version>3.8.1</version>
  91.                 <configuration>
  92.                     <source>1.8</source>
  93.                     <target>1.8</target>
  94.                     <encoding>UTF-8</encoding>
  95.                 </configuration>
  96.             </plugin>
  97.             <plugin>
  98.                 <groupId>org.springframework.boot</groupId>
  99.                 <artifactId>spring-boot-maven-plugin</artifactId>
  100.                 <version>2.4.1</version>
  101.                 <configuration>
  102.                     <mainClass>com.zj.gateway.GatewayApplication</mainClass>
  103.                 </configuration>
  104.                 <executions>
  105.                     <execution>
  106.                         <id>repackage</id>
  107.                         <goals>
  108.                             <goal>repackage</goal>
  109.                         </goals>
  110.                     </execution>
  111.                 </executions>
  112.             </plugin>
  113.         </plugins>
  114.     </build>
  115.  
  116. </project>

       3、配置资源文件

server:
  #此处的8084端口号,就好像以前外置的tomcat的8080,让我们通过浏览器进行访问
  #但此服务只是做了一个路由,它会将请求路由到其它微服务(一般是消费者)进行处理
  port: 8085

spring:
  application:
    #微服务名
    name: gateway
  cloud:
    nacos:
      discovery:
        #指定nacos注册中心的地址
        server-addr: 127.0.0.1:8848
    gateway:
      discovery:
        locator:
          #是否与服务发现组件进行结合,通过service-id(必须设置成大写)转发到具体的服务实例。默认false
          #为true代表开启基于服务发现的路由规则。
          enabled: false
          #配置之后访问时service-id无需大写
          lower-case-service-id: true
      routes:
        # 路由标识(id：标识,具有唯一性)
        - id: user-consumer-api
          #目标服务地址(uri：地址,请求转发后的地址),会自动从注册中心获得服务的IP,不需要手动写死
          uri: lb://consumer
          #优先级,越小越优先
          #order: 999
          #路由条件(predicates：断言)
          predicates:
            # 路径匹配,
            - Path=/cum/**
          filters:
            #路径前缀删除示例：请求/name/bar/foo,StripPrefix=2,去除掉前面两个前缀之后,最后转发到目标服务的路径为/foo
            #前缀过滤,请求地址：http://localhost:8084/usr/hello
            #此处配置去掉1个路径前缀,再配置上面的 Path=/usr/**,就将**转发到指定的微服务
            #因为这个api相当于是服务名,只是为了方便以后nginx的代码加上去的,对于服务提供者service-client来说,不需要这段地址,所以需要去掉
            - StripPrefix=1
        # 路由标识(id：标识,具有唯一性)
        - id: user-provider-api
          #目标服务地址(uri：地址,请求转发后的地址),会自动从注册中心获得服务的IP,不需要手动写死
          uri: lb://provider
          #优先级,越小越优先
          #order: 999
          #路由条件(predicates：断言)
          predicates:
            # 路径匹配,
            - Path=/api/pro/**
          filters:
            #路径前缀删除示例：请求/name/bar/foo,StripPrefix=2,去除掉前面两个前缀之后,最后转发到目标服务的路径为/foo
            #前缀过滤,请求地址：http://localhost:8084/usr/hello
            #此处配置去掉1个路径前缀,再配置上面的 Path=/usr/**,就将**转发到指定的微服务
            #因为这个api相当于是服务名,只是为了方便以后nginx的代码加上去的,对于服务提供者service-client来说,不需要这段地址,所以需要去掉
            - StripPrefix=2
logging:
  level:
    #开启spring-Cloud-gateway的日志级别为debug,方便debug调试
    org.springframework.cloud.gateway: trace
    org.springframework.http.server.reactive: debug
    org.springframework.web.reactive: debug
    reactor.ipc.netty: debug
#springboot监控Actuator,暴露所有端点
management:
  endpoints:
    web:
      exposure:
        include: '*'
#自定义配置
gateway:
  nacos:
    server-addr: ${spring.cloud.nacos.discovery.server-addr}
    # namespace: xxx-xx-xx-xx
    data-id: dynamic-routing.json
    group: DEFAULT_GROUP

二、路由定义

        一、以服务名的路由

                   资源文件：

gateway:
  discovery:
    locator:
      #是否与服务发现组件进行结合,通过service-id(必须设置成大写)转发到具体的服务实例。默认false
      #为true代表开启基于服务发现的路由规则。
      enabled: true
      #配置之后访问时service-id无需大写
      lower-case-service-id: true

        二、以自定义路由

                   资源文件：

gateway:
  discovery:
    locator:
      #是否与服务发现组件进行结合,通过service-id(必须设置成大写)转发到具体的服务实例。默认false
      #为true代表开启基于服务发现的路由规则。
      enabled: false
      #配置之后访问时service-id无需大写
      lower-case-service-id: true
  routes:
    # 路由标识(id：标识,具有唯一性)
    - id: user-consumer-api
      #目标服务地址(uri：地址,请求转发后的地址),会自动从注册中心获得服务的IP,不需要手动写死
      uri: lb://consumer
      #优先级,越小越优先
      #order: 999
      #路由条件(predicates：断言)
      predicates:
        # 路径匹配,
        - Path=/cum/**
      filters:
        #路径前缀删除示例：请求/name/bar/foo,StripPrefix=2,去除掉前面两个前缀之后,最后转发到目标服务的路径为/foo
        #前缀过滤,请求地址：http://localhost:8084/usr/hello
        #此处配置去掉1个路径前缀,再配置上面的 Path=/usr/**,就将**转发到指定的微服务
        #因为这个api相当于是服务名,只是为了方便以后nginx的代码加上去的,对于服务提供者service-client来说,不需要这段地址,所以需要去掉
        - StripPrefix=1
    # 路由标识(id：标识,具有唯一性)
    - id: user-provider-api
      #目标服务地址(uri：地址,请求转发后的地址),会自动从注册中心获得服务的IP,不需要手动写死
      uri: lb://provider
      #优先级,越小越优先
      #order: 999
      #路由条件(predicates：断言)
      predicates:
        # 路径匹配,
        - Path=/api/pro/**
      filters:
        #路径前缀删除示例：请求/name/bar/foo,StripPrefix=2,去除掉前面两个前缀之后,最后转发到目标服务的路径为/foo
        #前缀过滤,请求地址：http://localhost:8084/usr/hello
        #此处配置去掉1个路径前缀,再配置上面的 Path=/usr/**,就将**转发到指定的微服务
        #因为这个api相当于是服务名,只是为了方便以后nginx的代码加上去的,对于服务提供者service-client来说,不需要这段地址,所以需要去掉
        - StripPrefix=2

enabled: false后的测试： 

三、动态路由设置 

        1、导入依赖

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <modelVersion>4.0.0</modelVersion>
  5.     <groupId>com.zj</groupId>
  6.     <artifactId>gateway</artifactId>
  7.     <version>0.0.1-SNAPSHOT</version>
  8.     <name>gateway</name>
  9.     <description>gateway</description>
  10.  
  11.  
  12.  
  13.     <properties>
  14.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  15.         <maven.compiler.source>1.7</maven.compiler.source>
  16.         <maven.compiler.target>1.7</maven.compiler.target>
  17.         <spring-boot.version>2.4.1</spring-boot.version>
  18.         <spring-cloud.version>2020.0.0</spring-cloud.version>
  19.         <spring-cloud-alibaba.version>2021.1</spring-cloud-alibaba.version>
  20.     </properties>
  21.  
  22.  
  23.  
  24.  
  25.  
  26.     <dependencies>
  27.         <dependency>
  28.             <groupId>org.springframework.boot</groupId>
  29.             <artifactId>spring-boot-starter</artifactId>
  30.         </dependency>
  31.         <dependency>
  32.             <groupId>org.springframework.boot</groupId>
  33.             <artifactId>spring-boot-starter-test</artifactId>
  34.             <scope>test</scope>
  35.         </dependency>
  36.         <dependency>
  37.             <groupId>org.springframework.boot</groupId>
  38.             <artifactId>spring-boot-starter-webflux</artifactId>
  39.         </dependency>
  40.         <dependency>
  41.             <groupId>org.springframework.cloud</groupId>
  42.             <artifactId>spring-cloud-starter-gateway</artifactId>
  43.         </dependency>
  44.         <dependency>
  45.             <groupId>org.springframework.boot</groupId>
  46.             <artifactId>spring-boot-starter-actuator</artifactId>
  47.         </dependency>
  48.         <dependency>
  49.             <groupId>com.alibaba.cloud</groupId>
  50.             <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
  51.         </dependency>
  52.         <dependency>
  53.             <groupId>org.springframework.cloud</groupId>
  54.             <artifactId>spring-cloud-loadbalancer</artifactId>
  55.         </dependency>
  56.         <dependency>
  57.             <groupId>org.projectlombok</groupId>
  58.             <artifactId>lombok</artifactId>
  59.         </dependency>
  60.         <dependency>
  61.             <groupId>com.alibaba</groupId>
  62.             <artifactId>fastjson</artifactId>
  63.             <version>1.2.35</version>
  64.         </dependency>
  65.     </dependencies>
  66.  
  67.     <dependencyManagement>
  68.         <dependencies>
  69.             <dependency>
  70.                 <groupId>org.springframework.boot</groupId>
  71.                 <artifactId>spring-boot-dependencies</artifactId>
  72.                 <version>${spring-boot.version}</version>
  73.                 <type>pom</type>
  74.                 <scope>import</scope>
  75.             </dependency>
  76.             <dependency>
  77.                 <groupId>org.springframework.cloud</groupId>
  78.                 <artifactId>spring-cloud-dependencies</artifactId>
  79.                 <version>${spring-cloud.version}</version>
  80.                 <type>pom</type>
  81.                 <scope>import</scope>
  82.             </dependency>
  83.             <dependency>
  84.                 <groupId>com.alibaba.cloud</groupId>
  85.                 <artifactId>spring-cloud-alibaba-dependencies</artifactId>
  86.                 <version>${spring-cloud-alibaba.version}</version>
  87.                 <type>pom</type>
  88.                 <scope>import</scope>
  89.             </dependency>
  90.         </dependencies>
  91.     </dependencyManagement>
  92.  
  93.  
  94.     <build>
  95.         <plugins>
  96.             <plugin>
  97.                 <groupId>org.apache.maven.plugins</groupId>
  98.                 <artifactId>maven-compiler-plugin</artifactId>
  99.                 <version>3.8.1</version>
  100.                 <configuration>
  101.                     <source>1.8</source>
  102.                     <target>1.8</target>
  103.                     <encoding>UTF-8</encoding>
  104.                 </configuration>
  105.             </plugin>
  106.             <plugin>
  107.                 <groupId>org.springframework.boot</groupId>
  108.                 <artifactId>spring-boot-maven-plugin</artifactId>
  109.                 <version>2.4.1</version>
  110.                 <configuration>
  111.                     <mainClass>com.zj.gateway.GatewayApplication</mainClass>
  112.                 </configuration>
  113.                 <executions>
  114.                     <execution>
  115.                         <id>repackage</id>
  116.                         <goals>
  117.                             <goal>repackage</goal>
  118.                         </goals>
  119.                     </execution>
  120.                 </executions>
  121.             </plugin>
  122.         </plugins>
  123.     </build>
  124.  
  125. </project>

        1、在nacos中新注册一个配置，名叫dynamic-routing.json

  1. {
  2.   "refreshGatewayRoute": true,
  3.   "routeList": [
  4.     {
  5.       "id": "consumer-api",
  6.       "predicates": [
  7.         {
  8.           "name": "Path",
  9.           "args": {
  10.             "_genkey_0": "/cum/**"
  11.           }
  12.         }
  13.       ],
  14.       "filters": [
  15.         {
  16.           "name": "StripPrefix",
  17.           "args": {
  18.             "_genkey_0": "1"
  19.           }
  20.         }
  21.       ],
  22.       "uri": "lb://consumer",
  23.       "order": 0
  24.     },
  25.     {
  26.       "id": "provider-api",
  27.       "predicates": [
  28.         {
  29.           "name": "Path",
  30.           "args": {
  31.             "_genkey_0": "/ccc/prv/**"
  32.           }
  33.         }
  34.       ],
  35.       "filters": [
  36.         {
  37.           "name": "StripPrefix",
  38.           "args": {
  39.             "_genkey_0": "2"
  40.           }
  41.         }
  42.       ],
  43.       "uri": "lb://provider",
  44.       "order": 0
  45.     }
  46.   ]
  47. }

        3、导入相关帮助类

DynamicRoutingConfig：
  1. package com.zj.gateway;
  2.  
  3. import com.alibaba.fastjson.JSON;
  4. import com.alibaba.fastjson.JSONObject;
  5. import com.alibaba.nacos.api.NacosFactory;
  6. import com.alibaba.nacos.api.PropertyKeyConst;
  7. import com.alibaba.nacos.api.config.ConfigService;
  8. import com.alibaba.nacos.api.config.listener.Listener;
  9. import com.alibaba.nacos.api.exception.NacosException;
  10. import com.fasterxml.jackson.databind.ObjectMapper;
  11. import com.zj.gateway.pojo.FilterEntity;
  12. import com.zj.gateway.pojo.GatewayNacosProperties;
  13. import com.zj.gateway.pojo.PredicateEntity;
  14. import com.zj.gateway.pojo.RouteEntity;
  15. import lombok.extern.slf4j.Slf4j;
  16. import org.springframework.beans.factory.annotation.Autowired;
  17. import org.springframework.cloud.gateway.event.RefreshRoutesEvent;
  18. import org.springframework.cloud.gateway.filter.FilterDefinition;
  19. import org.springframework.cloud.gateway.handler.predicate.PredicateDefinition;
  20. import org.springframework.cloud.gateway.route.RouteDefinition;
  21. import org.springframework.cloud.gateway.route.RouteDefinitionWriter;
  22. import org.springframework.context.ApplicationEventPublisher;
  23. import org.springframework.context.ApplicationEventPublisherAware;
  24. import org.springframework.context.annotation.Bean;
  25. import org.springframework.stereotype.Component;
  26. import org.springframework.web.util.UriComponentsBuilder;
  27. import reactor.core.publisher.Mono;
  28.  
  29. import java.net.URI;
  30. import java.util.ArrayList;
  31. import java.util.List;
  32. import java.util.Properties;
  33. import java.util.concurrent.Executor;
  34.  
  35. /**
  36.  * 此类实现了Spring Cloud Gateway + nacos 的动态路由,
  37.  * 它实现一个Spring提供的事件推送接口ApplicationEventPublisherAware
  38.  */
  39. @SuppressWarnings("all")
  40. @Slf4j
  41. @Component
  42. public class DynamicRoutingConfig implements ApplicationEventPublisherAware {
  43.  
  44.     @Autowired
  45.     private RouteDefinitionWriter routeDefinitionWriter;
  46.  
  47.     @Autowired
  48.     private GatewayNacosProperties gatewayProperties;
  49.  
  50.     @Autowired
  51.     private ObjectMapper mapper;
  52.  
  53.     private ApplicationEventPublisher applicationEventPublisher;
  54.  
  55.     @Override
  56.     public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) {
  57.         this.applicationEventPublisher = applicationEventPublisher;
  58.     }
  59.  
  60.     /**
  61.      * 这个方法主要负责监听Nacos的配置变化,这里先使用参数构建一个ConfigService,
  62.      * 再使用ConfigService开启一个监听,
  63.      * 并且在监听的方法中刷新路由信息。
  64.      */
  65.     @Bean
  66.     public void refreshRouting() throws NacosException {
  67.         //创建Properties配置类
  68.         Properties properties = new Properties();
  69.         System.out.println(gatewayProperties);
  70.         //设置nacos的服务器地址,从配置类GatewayProperties中获取
  71.         properties.put(PropertyKeyConst.SERVER_ADDR, gatewayProperties.getServerAddr());
  72.         //设置nacos的命名空间,表示从具体的命名空间中获取配置信息,不填代表默认从public获得
  73.         if (gatewayProperties.getNamespace() != null) {
  74.             properties.put(PropertyKeyConst.NAMESPACE, gatewayProperties.getNamespace());
  75.         }
  76.         //根据Properties配置创建ConfigService类
  77.         ConfigService configService = NacosFactory.createConfigService(properties);
  78.         //获得nacos中已有的路由配置
  79.         String json = configService.getConfig(gatewayProperties.getDataId(), gatewayProperties.getGroup(), 5000);
  80.         if(json==null) {
  81.             return;
  82.         }
  83.  
  84.         this.parseJson(json);
  85.  
  86.         //添加监听器,监听nacos中的数据修改事件
  87.         configService.addListener(gatewayProperties.getDataId(), gatewayProperties.getGroup(), new Listener() {
  88.             @Override
  89.             public Executor getExecutor() {
  90.                 return null;
  91.             }
  92.  
  93.             /**
  94.              * 用于接收远端nacos中数据修改后的回调方法
  95.              */
  96.             @Override
  97.             public void receiveConfigInfo(String configInfo) {
  98.                 log.warn(configInfo);
  99.                 //获取nacos中修改的数据并进行转换
  100.                 parseJson(configInfo);
  101.             }
  102.         });
  103.  
  104.     }
  105.  
  106.     /**
  107.      * 解析从nacos读取的路由配置信息(json格式)
  108.      */
  109.     public void parseJson(String json) {
  110.         log.warn("从Nacos返回的路由配置(JSON格式)：" + json);
  111.         boolean refreshGatewayRoute = JSONObject.parseObject(json).getBoolean("refreshGatewayRoute");
  112.         if (refreshGatewayRoute) {
  113.             List<RouteEntity> list = JSON.parseArray(JSONObject.parseObject(json).getString("routeList")).toJavaList(RouteEntity.class);
  114.             for (RouteEntity route : list) {
  115.                 update(assembleRouteDefinition(route));
  116.             }
  117.         } else {
  118.             log.warn("路由未发生变更");
  119.         }
  120.     }
  121.  
  122.  
  123.     /**
  124.      * 路由更新
  125.      */
  126.     public void update(RouteDefinition routeDefinition) {
  127.  
  128.         try {
  129.             this.routeDefinitionWriter.delete(Mono.just(routeDefinition.getId()));
  130.             log.warn("路由删除成功:" + routeDefinition.getId());
  131.         } catch (Exception e) {
  132.             log.error(e.getMessage(), e);
  133.         }
  134.         try {
  135.             routeDefinitionWriter.save(Mono.just(routeDefinition)).subscribe();
  136.             this.applicationEventPublisher.publishEvent(new RefreshRoutesEvent(this));
  137.             log.warn("路由更新成功:" + routeDefinition.getId());
  138.         } catch (Exception e) {
  139.             log.error(e.getMessage(), e);
  140.         }
  141.  
  142.     }
  143.  
  144.     /**
  145.      * 路由定义
  146.      */
  147.     public RouteDefinition assembleRouteDefinition(RouteEntity routeEntity) {
  148.  
  149.         RouteDefinition definition = new RouteDefinition();
  150.  
  151.         // ID
  152.         definition.setId(routeEntity.getId());
  153.  
  154.         // Predicates
  155.         List<PredicateDefinition> pdList = new ArrayList<>();
  156.         for (PredicateEntity predicateEntity : routeEntity.getPredicates()) {
  157.             PredicateDefinition predicateDefinition = new PredicateDefinition();
  158.             predicateDefinition.setArgs(predicateEntity.getArgs());
  159.             predicateDefinition.setName(predicateEntity.getName());
  160.             pdList.add(predicateDefinition);
  161.         }
  162.         definition.setPredicates(pdList);
  163.  
  164.         // Filters
  165.         List<FilterDefinition> fdList = new ArrayList<>();
  166.         for (FilterEntity filterEntity : routeEntity.getFilters()) {
  167.             FilterDefinition filterDefinition = new FilterDefinition();
  168.             filterDefinition.setArgs(filterEntity.getArgs());
  169.             filterDefinition.setName(filterEntity.getName());
  170.             fdList.add(filterDefinition);
  171.         }
  172.         definition.setFilters(fdList);
  173.  
  174.         // URI
  175.         URI uri = UriComponentsBuilder.fromUriString(routeEntity.getUri()).build().toUri();
  176.         definition.setUri(uri);
  177.  
  178.         return definition;
  179.     }
  180.  
  181. }
pojo--->FilterEntity
  1. package com.zj.gateway.pojo;
  2.  
  3. import lombok.AllArgsConstructor;
  4. import lombok.Data;
  5. import lombok.NoArgsConstructor;
  6. import lombok.experimental.Accessors;
  7.  
  8. import java.util.LinkedHashMap;
  9. import java.util.Map;
  10.  
  11. /**
  12.  * @author zj
  13.  */
  14. @SuppressWarnings("all")
  15. @Data
  16. @NoArgsConstructor
  17. @AllArgsConstructor
  18. @Accessors(chain = true)
  19. public class FilterEntity {
  20.  
  21.     //过滤器对应的Name
  22.     private String name;
  23.  
  24.     //路由规则
  25.     private Map<String, String> args = new LinkedHashMap<>();
  26.  
  27. }
pojo--->GatewayNacosProperties
  1. package com.zj.gateway.pojo;
  2.  
  3. import lombok.AllArgsConstructor;
  4. import lombok.Data;
  5. import lombok.NoArgsConstructor;
  6. import lombok.experimental.Accessors;
  7. import org.springframework.boot.context.properties.ConfigurationProperties;
  8. import org.springframework.stereotype.Component;
  9.  
  10. @SuppressWarnings("all")
  11. @Data
  12. @NoArgsConstructor
  13. @AllArgsConstructor
  14. @Accessors(chain = true)
  15. @ConfigurationProperties(prefix = "gateway.nacos")
  16. @Component
  17. public class GatewayNacosProperties {
  18.  
  19.     private String serverAddr;
  20.     private String dataId;
  21.     private String namespace;
  22.     private String group;
  23.  
  24. }
pojo--->PredicateEntity
  1. package com.zj.gateway.pojo;
  2.  
  3. import lombok.AllArgsConstructor;
  4. import lombok.Data;
  5. import lombok.NoArgsConstructor;
  6. import lombok.experimental.Accessors;
  7.  
  8. import java.util.LinkedHashMap;
  9. import java.util.Map;
  10.  
  11. /**
  12.  * @author zj
  13.  */
  14. @SuppressWarnings("all")
  15. @Data
  16. @NoArgsConstructor
  17. @AllArgsConstructor
  18. @Accessors(chain = true)
  19. public class PredicateEntity {
  20.  
  21.     //断言对应的Name
  22.     private String name;
  23.  
  24.     //断言规则
  25.     private Map<String, String> args = new LinkedHashMap<>();
  26.  
  27. }
pojo--->RouteEntity
  1. package com.zj.gateway.pojo;
  2.  
  3. import lombok.AllArgsConstructor;
  4. import lombok.Data;
  5. import lombok.NoArgsConstructor;
  6. import lombok.experimental.Accessors;
  7.  
  8. import java.util.ArrayList;
  9. import java.util.List;
  10.  
  11. /**
  12.  * @author hgh
  13.  */
  14. @SuppressWarnings("all")
  15. @Data
  16. @NoArgsConstructor
  17. @AllArgsConstructor
  18. @Accessors(chain = true)
  19. public class RouteEntity {
  20.  
  21.     //路由id
  22.     private String id;
  23.  
  24.     //路由断言集合
  25.     private List<PredicateEntity> predicates = new ArrayList<>();
  26.  
  27.     //路由过滤器集合
  28.     private List<FilterEntity> filters = new ArrayList<>();
  29.  
  30.     //路由转发的目标uri
  31.     private String uri;
  32.  
  33.     //路由执行的顺序
  34.     private int order = 0;
  35.  
  36. }

        4、进行测试

 当我在配置中修改路径之后就访问不到了

这就实现了动态路由

今天的知识就分享到这了，希望能够帮助到你！ 

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/IT小白/article/detail/301431
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号