Spring Cloud Gateway + Nacos 实现动态路由

import org.springframework.cloud.gateway.route.RouteLocator;
import org.springframework.cloud.gateway.route.builder.RouteLocatorBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.reactive.function.server.RouterFunction;
import org.springframework.web.reactive.function.server.ServerResponse;
import reactor.core.publisher.Mono;
 
@Configuration
public class DynamicRouteConfig {
 
    @Bean
    public RouteLocator routeLocator(RouteLocatorBuilder builder) {
        return builder.routes()
                .route("path_route", r -> r.path("/image/png")
                        .uri("http://localhost:8081"))
                .route("host_route", r -> r.host("*.myhost.org")
                        .uri("http://localhost:8082"))
                .build();
    }
 
    // 假设这里有一个服务用于获取动态路由规则
    // 可以从Nacos配置中心获取路由配置
    // 示例中省略了获取配置的细节
    @Bean
    public RouteLocator dynamicRouteLocator(RouteLocatorBuilder builder) {
        // 假设从Nacos获取的路由配置如下
        Map<String, String> routes = getDynamicRouteFromNacos();
 
        return builder.routes()
                .route("dynamic_route", r -> r.path("/dynamic")
                        .filters(f -> f.addResponseHeader("Dynamic", "true"))
                        .uri(routes.get("dynamic_route")))
                .build();
    }
 
    // 示例方法，实际应从Nacos配置中心获取路由配置
    private Map<String, String> getDynamicRouteFromNacos() {
        Map<String, String> routes = new HashMap<>();
        // 假设这里从Nacos获取到的路由配置
        routes.put("dynamic_route", "http://localhost:8083");
        return routes;
    }
}

这个代码示例展示了如何在Spring Cloud Gateway中配置静态和动态路由，静态路由是直接在配置中指定的，而动态路由则是通过从Nacos配置中心获取的。在实际应用中，需要替换getDynamicRouteFromNacos()方法，从Nacos配置中心实时获取路由配置。