springCloud(Gateway网关)

￡神魔★判官ぃ 2024-03-30 16:21 77阅读 0赞

Gateway是springCloud中的重要组件。官网上的定义概述是：

This project provides a library for building an API Gateway on top of Spring WebFlux. Spring Cloud Gateway aims to provide a simple, yet effective way to route to APIs and provide cross cutting concerns to them such as: security, monitoring/metrics, and resiliency.

翻译成中文：

这个项目提供了一个在Spring WebFlux之上构建API网关的库。Spring Cloud Gateway旨在提供一种简单而有效的方法来路由到api，并为它们提供交叉关注点，例如:安全性、监视/度量和弹性。

从定义上来看；网关主要解决服务API的路由，而且可以在网关这一层做一些安全校验，请求监控，统计的动作。

关键特性和作用：

基于Spring Framework 5、Project Reactor和Spring Boot 2.0构建

能够匹配任何请求属性的路由。

谓词和过滤器是特定于路由的。

断路器集成。

Spring Cloud DiscoveryClient集成

易于编写谓词和过滤器

请求速率限制

路径重写

源码示例：

@SpringBootApplication
    public class DemogatewayApplication {
        @Bean
        public RouteLocator customRouteLocator(RouteLocatorBuilder builder) {
            return builder.routes()
                .route("path_route", r -> r.path("/get")
                    .uri("http://httpbin.org"))
                .route("host_route", r -> r.host("*.myhost.org")
                    .uri("http://httpbin.org"))
                .route("rewrite_route", r -> r.host("*.rewrite.org")
                    .filters(f -> f.rewritePath("/foo/(?<segment>.*)", "/${segment}"))
                    .uri("http://httpbin.org"))
                .route("hystrix_route", r -> r.host("*.hystrix.org")
                    .filters(f -> f.hystrix(c -> c.setName("slowcmd")))
                    .uri("http://httpbin.org"))
                .route("hystrix_fallback_route", r -> r.host("*.hystrixfallback.org")
                    .filters(f -> f.hystrix(c -> c.setName("slowcmd").setFallbackUri("forward:/hystrixfallback")))
                    .uri("http://httpbin.org"))
                .route("limit_route", r -> r
                    .host("*.limited.org").and().path("/anything/**")
                    .filters(f -> f.requestRateLimiter(c -> c.setRateLimiter(redisRateLimiter())))
                    .uri("http://httpbin.org"))
                .build();
        }
    }

在springCloud中集成

spring-cloud-starter-gateway

鉴权，授权示例：

import org.springframework.cloud.gateway.filter.GatewayFilter;
    import org.springframework.cloud.gateway.filter.GatewayFilterChain;
    import org.springframework.core.Ordered;
    import org.springframework.http.HttpStatus;
    import org.springframework.stereotype.Component;
    import org.springframework.web.server.ServerWebExchange;
    
    import lombok.extern.slf4j.Slf4j;
    import reactor.core.publisher.Mono;
    
    @Slf4j
    @Component
    public class PermissionGatewayFilter implements GatewayFilter, Ordered {
    
        @Override
        public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
    
            log.info("执行了自定义的全局过滤器");
            //1.获取请求参数access-token
            String token = exchange.getRequest().getQueryParams().getFirst("access-token");
            //2.判断是否存在
            if(token == null) {
                //3.如果不存在 : 认证失败
                log.info("没有获取到token");
                exchange.getResponse().setStatusCode(HttpStatus.UNAUTHORIZED);
                return exchange.getResponse().setComplete(); //请求结束
            }
            //4.如果存在,继续执行
            return chain.filter(exchange); //继续向下执行
        }
    
        @Override
        public int getOrder() {
            return 0;
        }
    
    }