SpringCloud网关Gateway认证鉴权【SpringCloud系列7】

在Spring Cloud Gateway中，我们可以通过定义过滤器来实现鉴权功能。以下是一个简单的例子，展示了如何创建一个自定义的过滤器来进行鉴权：

import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.core.io.buffer.DataBufferUtils;
import org.springframework.http.HttpStatus;
import org.springframework.http.server.reactive.ServerHttpResponse;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;
 
import java.nio.charset.StandardCharsets;
 
public class AuthFilter implements GlobalFilter {
 
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        // 获取请求中的Token
        String token = exchange.getRequest().getHeaders().getFirst("X-Auth-Token");
 
        // 进行鉴权逻辑，这里简单示例
        boolean authenticated = "expected-token".equals(token);
 
        if (authenticated) {
            // 鉴权通过，继续执行后续过滤器和路由
            return chain.filter(exchange);
        } else {
            // 鉴权失败，返回401 Unauthorized响应
            ServerHttpResponse response = exchange.getResponse();
            response.setStatusCode(HttpStatus.UNAUTHORIZED);
            response.getHeaders().set("Content-Type", "application/json");
            String body = "{\"message\":\"Invalid authentication token\"}";
            DataBufferUtils.write(response.bufferFactory().wrap(body.getBytes(StandardCharsets.UTF_8)), response.getBody());
            return Mono.empty();
        }
    }
}

然后，你需要将这个自定义的过滤器注册到Spring Cloud Gateway中：

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.cloud.gateway.route.RouteLocator;
import org.springframework.cloud.gateway.builder.RouteLocatorBuilder;
 
@Configuration
public class GatewayConfig {
 
    @Bean
    public RouteLocator customRouteLocator(RouteLocatorBuilder builder) {
        return builder.routes()
                .route("path_route", r -> r.path("/api/**")
                        .filters(f -> f.filter(new AuthFilter())) // 添加鉴权过滤器
                        .uri("http://backend"))
                .build();
    }
}

在这个配置中，我们定义了一个路由，将匹配/api/**的请求发送到后端服务，并且在发送之前应用了我们的鉴权过滤器。如果请求包含有效的鉴权token，它将被允许继续路由到后端服务；如果toke