欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

gateway实现动态路由

程序员文章站 2022-06-13 15:38:35
...

情景:
一般情况下,不需要动态路由,前端请求进入网关后,路由分发到fegin项目,在这里在进行分发到各个业务项目。
此时另一种情况导致了动态路由的出现,加入有一个网关,两套系统controller,在网关里面就要分配一次,进入各自系统后,在进行分发各自的;

实现一:不借助nacos配置中心

eureka:
  client:
    service-url:
      #设置与Eureka Server交互的地址,查询服务和注册服务都需要依赖这个地址。默认是http://localhost:8761/eureka ;多个地址可使用 , 分隔。
      defaultZone: http://127.0.0.1:8761/eureka/

server:
  port: 8888

spring:
  application:
    name: gateway
  cloud:
      gateway:
        routes:
        - id: product-app-api
          uri: lb://product-app-api
          order: 1
          predicates:
          - Path=/app/product-app-api/**
          filters:
          - name: AppAuth
            args:
              name: app
          #- RewritePath=/product-app-api/(?<segment>.*), /$\{segment}
          - StripPrefix=2
        - id: product-web-api
          uri: lb://product-web-api
          order: 1
          predicates:
          - Path=/web/product-app-api/**
          filters:
          - name: WebAuth
            args:
              name: app
          #- RewritePath=/product-app-api/(?<segment>.*), /$\{segment}
          - StripPrefix=2
        - id: index-app-api
          uri: lb://index-app-api
          order: 1
          predicates:
          - Path=/app/index-app-api/**
          filters:
          - name: AppAuth
            args:
              name: app
          #- RewritePath=/product-app-api/(?<segment>.*), /$\{segment}
          - StripPrefix=2
        - id: index-web-api
          uri: lb://index-web-api
          order: 1
          predicates:
          - Path=/web/index-app-api/**
          filters:
          - name: WebAuth
            args:
              name: app
          #- RewritePath=/product-app-api/(?<segment>.*), /$\{segment}
          - StripPrefix=2

在这里配置了三套路由分发,其中

   - id: index-web-api
          uri: lb://index-web-api
          order: 1
          predicates:
          - Path=/web/index-app-api/**
          filters:
          - name: WebAuth
            args:
              name: app
          #- RewritePath=/product-app-api/(?<segment>.*), /$\{segment}
          - StripPrefix=2

为一组

实现二:借助nacos实现动态路由分发

1.监听器监听nacos

Spring Cloud Gateway本身还不支持直接从Nacos动态加载路由配置表,需要自己编写监听器监听配置变化并刷新路由表。

NacosDynamicRouteService.java

@Component
public class NacosDynamicRouteService implements ApplicationEventPublisherAware {
 
    private String dataId = "gateway-router";
 
    private String group = "DEFAULT_GROUP";
 
    @Value("${spring.cloud.nacos.config.server-addr}")
    private String serverAddr;
 
    @Autowired
    private RouteDefinitionWriter routeDefinitionWriter;
 
    private ApplicationEventPublisher applicationEventPublisher;
 
    private static final List<String> ROUTE_LIST = new ArrayList<>();
 
    @PostConstruct
    public void dynamicRouteByNacosListener() {
        try {
            ConfigService configService = NacosFactory.createConfigService(serverAddr);
            configService.getConfig(dataId, group, 5000);
            configService.addListener(dataId, group, new Listener() {
                @Override
                public void receiveConfigInfo(String configInfo) {
                    clearRoute();
                    try {
                        List<RouteDefinition> gatewayRouteDefinitions = JSONObject.parseArray(configInfo, RouteDefinition.class);
                        for (RouteDefinition routeDefinition : gatewayRouteDefinitions) {
                            addRoute(routeDefinition);
                        }
                        publish();
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }
 
                @Override
                public Executor getExecutor() {
                    return null;
                }
            });
        } catch (NacosException e) {
            e.printStackTrace();
        }
    }
 
    private void clearRoute() {
        for(String id : ROUTE_LIST) {
            this.routeDefinitionWriter.delete(Mono.just(id)).subscribe();
        }
        ROUTE_LIST.clear();
    }
 
    private void addRoute(RouteDefinition definition) {
        try {
            routeDefinitionWriter.save(Mono.just(definition)).subscribe();
            ROUTE_LIST.add(definition.getId());
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
 
    private void publish() {
        this.applicationEventPublisher.publishEvent(new RefreshRoutesEvent(this.routeDefinitionWriter));
    }
 
    @Override
    public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) {
        this.applicationEventPublisher = applicationEventPublisher;
    }
}

2.新增配置
代码中监听的配置ID为gateway-router,按此ID在Nacos中创建配置
gateway实现动态路由
假设上面图片下面的配置文件信息为:

[{
    "id": "account-router",
    "order": 0,
    "predicates": [{
        "args": {
            "pattern": "/acc/**"
        },
        "name": "Path"
    }],
    "uri": "lb://account-service"
},{
    "id": "payment-router",
    "order": 2,
    "predicates": [{
        "args": {
            "pattern": "/pay/**"
        },
        "name": "Path"
    }],
    "uri": "lb://payment-service"
}]

就可以根据请求来进行分发了

三:案例:

http://127.0.0.1:9001//acc/basic-manage/selectAllRiskDesc
请求会根据acc分发到acc的项目

http://127.0.0.1:9001//pay/basic-manage/selectAllRiskDesc
请求会根据pay分发到pay的项目