Spring Cloud Gateway 3.x 获取body中的数据鉴权

### 回答1： Spring Cloud Gateway 可以通过自定义过滤器来获取请求体（body）。具体步骤如下： 1. 创建一个自定义过滤器类，实现 GatewayFilter 接口。 2. 在过滤器类中重写 filter 方法，在该方法中获取请求体。 3. 在 Spring Cloud Gateway 配置文件中配置该过滤器。 示例代码如下： ```java @Component public class MyFilter implements GatewayFilter { @Override public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) { // 获取请求体 ServerHttpRequest request = exchange.getRequest(); Flux<DataBuffer> body = request.getBody(); // 处理请求体 // ... // 调用下一个过滤器 return chain.filter(exchange); } } ``` 在 Spring Cloud Gateway 配置文件中配置该过滤器： ```yaml spring: cloud: gateway: routes: - id: my_route uri: http://localhost:8080 predicates: - Path=/my_path/** filters: - MyFilter ``` 其中，MyFilter 是自定义过滤器类的名称。在 filters 配置中指定该过滤器即可。 ### 回答2： Spring Cloud Gateway是一个基于Spring Boot的API网关，它允许开发者以统一的方式管理和路由HTTP请求到多个微服务。在实际开发中，有时需要获取HTTP请求的body，在Spring Cloud Gateway中获取HTTP请求的body需要注意以下几点： 1. 所有的Route Predicate都需要配置读取HTTP请求体，否则在路由到下游服务时，请求体会丢失。 2. 如果请求体是将JSON字符串作为参数传递，则需要使用JSON库将字符串转成JSON对象。Spring Cloud Gateway中推荐使用与Spring Framework组件集成的Jackson JSON库。 3. HTTP请求的body只能读取一次，所以需要配置路由过滤器来实现将读取过的请求体保存在请求上下文中，以便后续的路由过滤器和路由处理器获取请求体。 在Spring Cloud Gateway中获取HTTP请求的body，可以通过自定义GatewayFilter来实现。下面给出获取HTTP请求体的代码示例： ```java public class BodyGatewayFilterFactory extends AbstractGatewayFilterFactory<BodyGatewayFilterFactory.Config> { public BodyGatewayFilterFactory() { super(Config.class); } @Override public GatewayFilter apply(Config config) { return (exchange, chain) -> { return DataBufferUtils.join(exchange.getRequest().getBody()) .flatMap(dataBuffer -> { byte[] bytes = new byte[dataBuffer.readableByteCount()]; dataBuffer.read(bytes); DataBufferUtils.release(dataBuffer); String requestBody = new String(bytes, Charset.forName("UTF-8")); exchange.getAttributes().put("requestBody", requestBody); return chain.filter(exchange); }); }; } public static class Config { } } ``` 在上面的代码中，使用DataBufferUtils.join()函数将请求体存储在字节数组中，并通过exchange的setAttribute()方法存储到请求上下文中。这样，在后续的路由过滤器和路由处理器中就可以通过读取exchange.getAttributes().get("requestBody")来获取HTTP请求的body，而无需重新读取请求体。 ### 回答3： Spring Cloud Gateway是一个基于Spring Boot的网关。它可以在微服务架构中起到路由、负载均衡、API管理等多种作用。 在Spring Cloud Gateway中，获取请求体有两种方式：获取单个请求体和获取多个请求体。 获取单个请求体： 在Spring Cloud Gateway中，获取单个请求体可以使用Exchange对象的getBody()方法。这个方法会返回一个Mono对象，需要使用subscribe()方法来订阅结果。 例如： ```java public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) { Mono<String> requestBody = exchange.getRequest().getBodyToMono(String.class); requestBody.subscribe(content -> { // 对请求体进行操作 }); return chain.filter(exchange); } ``` 上面代码中，我们使用getBodyToMono()获取请求体，然后使用subscribe()方法来订阅请求体的内容。订阅成功后，我们可以对请求体进行操作。 获取多个请求体： 在Spring Cloud Gateway中，获取多个请求体可以使用GlobalFilter。GlobalFilter是一种全局过滤器，可以对所有的请求进行处理。 我们可以创建一个自定义的GlobalFilter，然后在filter()方法中获取请求体。 例如： ```java @Component public class MyGlobalFilter implements GlobalFilter { @Override public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) { MediaType mediaType = exchange.getRequest().getHeaders().getContentType(); Flux<DataBuffer> body = exchange.getRequest().getBody(); return chain.filter(exchange.mutate().request( exchange.getRequest().mutate().body(Flux.just(body)).build()) .build()); } } ``` 上面代码中，我们创建了一个MyGlobalFilter类，并实现了GlobalFilter接口。在filter()方法中，我们使用getBody()获取请求体。获取请求体后，我们更改了请求体的数据，然后使用build()方法创建了一个新的Exchange对象，并返回chain.filter()。 总结： Spring Cloud Gateway可以通过Exchange对象来获取请求体。可以使用getBody()方法获取单个请求体，也可以使用GlobalFilter获取多个请求体。 注意：在Spring Cloud Gateway中，请求体是一个Flux对象。如果需要将请求体转换成其他类型，请使用getBodyToMono()方法。由于Flux对象可能包含多个元素，因此在订阅操作时需要注意。